1

ローカルで 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

ポート 9092 でリッスンしている Kafka があります。

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 configの関連部分があります:

# 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 にいくつかのエントリを書き込めないのはなぜですか?

PS

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、永久にハングしますが、それでもログ フォルダーにファイル Hoffman04 が見つかりますls -lrt /usr/local/var/lib/kafka-logs。

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

1 に答える 1

2

OS (特に OSX) によっては、localhost は ipv4 と ipv6 の両方のアドレスに解決される場合がありますが、ブローカーは IPv4 アドレスにのみバインドされます。-X broker.address.family=v4kafkacat コマンド ラインに追加することで、kafkacat でアドレス ファミリを IPv4 に制限できます。

于 2020-05-29T07:04:31.983 に答える