我们如何从 IDE 本地写入 Kafka 主题并读取 kafka 主题答案

【问题标题】：How can we write to a Kafka topic and read from a kafka topic locally from IDE我们如何从 IDE 本地写入 Kafka 主题并读取 kafka 主题
【发布时间】：2020-02-26 15:34:14
【问题描述】：

我已经使用终端在本地创建了一个 kafka 主题

> bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

然后我尝试从 intellij 写到这个主题。我的代码采用以下参数

--group group-1 --topic test --brokers localhost:9092 --schemaRegistryUrl https://schema-registry.com

但是当我使用指定的代理运行我的代码时，它会说

java.net.ConnectException：连接被拒绝

无法建立到节点 -1 (localhost/127.0.0.1:9092) 的连接。经纪人可能不可用。

我不确定我是否按照正确的程序连接本地主机或从 Ide 写入主题。任何导航建议或链接都会有所帮助。

【问题讨论】：

尝试组装一个jar并传递相同的参数，看看它是否与参数/代码有关，而不是IDE设置
请出示您的代码。根据错误，看来 Kafka 可能已经崩溃了

标签： scala apache-kafka

【解决方案1】：

IDE 与终端没有什么不同。

请确保Kafka进程仍在运行

【讨论】：

kafka 进程正在运行，现在我遇到类似 DEBUG o.a.kafka.common.network.Selector - [Producer clientId=producer-1] Connection with localhost/127.0.0.1 disconnected java.io.EOFException: EOF during handshake, handshake status is NEED_UNWRAP 的运行错误，还有这些 [kafka-producer-network-thread | producer-1] DEBUG o.a.k.c.network.SslTransportLayer - [SslTransportLayer channelId=-1 key=sun.nio.ch.SelectionKeyImpl@7ff2b41b] Failed to send SSL Close message java.io.IOException: Broken pipe
1) 确保您的客户端版本与您的代理匹配 2) 如果您没有修改任何设置，则说明您没有使用 SSL