无法写入卡夫卡，经纪人倒闭答案

【问题标题】：Cannot write to kafka, brokers are down无法写入卡夫卡，经纪人倒闭
【发布时间】：2020-05-29 15:04:31
【问题描述】：

我在本地运行 Kafka。当我尝试写信给 Kafka 时，出现以下错误：

kafkacat -b localhost:9092 -t req -T -P -l  msgs
hello
world
% ERROR: Local: Broker transport failure: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT)
% ERROR: Local: All broker connections are down: 1/1 brokers are down : terminating

我让 Kafka 监听 9092 端口：

bash-3.2$ netstat -an | grep 9092
tcp4       0      0  127.0.0.1.9092         127.0.0.1.50994        ESTABLISHED
tcp4       0      0  127.0.0.1.50994        127.0.0.1.9092         ESTABLISHED
tcp4       0      0  127.0.0.1.9092         127.0.0.1.50986        ESTABLISHED
tcp4       0      0  127.0.0.1.50986        127.0.0.1.9092         ESTABLISHED
tcp4       0      0  127.0.0.1.9092         127.0.0.1.50984        ESTABLISHED
tcp4       0      0  127.0.0.1.50984        127.0.0.1.9092         ESTABLISHED
tcp4       0      0  127.0.0.1.9092         *.*                    LISTEN
bash-3.2$
bash-3.2$ telnet 127.0.0.1 9092
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.

这里是 kafka 配置的相关部分：

# The id of the broker. This must be set to a unique integer for each broker.
broker.id=0

# Hostname and port the broker will advertise to producers and consumers. If not set,
# it uses the value for "listeners" if configured.  Otherwise, it will use the value
# returned from java.net.InetAddress.getCanonicalHostName().
advertised.listeners=PLAINTEXT://127.0.0.1:9092
bootstrap.servers=127.0.0.1:9092

我做错了什么？为什么我不能在本地 Kafka 中写一些条目？

附言

当我使用 Kafka 自带的脚本时，我可以创建主题：

/usr/local/bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Hoffman02
Created topic Hoffman02.

但是当我使用 kafkacat kafkacat -b localhost:9092 -t Hoffman04 -P 时，它会永远挂起，但我仍然可以在日志文件夹 ls -lrt /usr/local/var/lib/kafka-logs 中找到文件 Hoffman04：

drwxr-xr-x  6 jenia  admin   192 28 May 11:17 Hoffman04-0

【问题讨论】：

nothing realted ，但我更喜欢独立使用 Kafka 而不是 kafkacat
kafkacat 是一款出色的诊断工具，我会一直使用它进行此类故障排除。
@jenia kafkacat -b localhost:9092 -L 的输出是什么？
@RobinMoffatt 输出是一个很长的分区列表：...partition 49，leader 0，replicas：0，isrs：0 topic "Hoffman02" with 1 partitions：partition 0，leader 0，副本：0，isrs：0 ...
您能否编辑您的问题以包括上述命令的输出，只是经纪人列表（不是主题详细信息）

标签： apache-kafka kafkacat

【解决方案1】：

根据您的操作系统（尤其是 OSX），localhost 可能会解析为 ipv4 和 ipv6 地址，而您的代理仅绑定到 IPv4 地址。您可以通过在 kafkacat 命令行中添加 -X broker.address.family=v4 来将地址族限制为 kafkacat 中的 IPv4。

【讨论】：