我已经安装了zookeeper和kafka,
第一步 :
通过以下命令运行zookeeper:
bin/zkServer.sh start
bin/zkCli.sh
第二步 :
运行卡夫卡服务器
bin/kafka-server-start.sh config/server.properties
kafka 应该在 localhost:9092 运行
但我收到以下错误:
WARN Unexpected error from /0:0:0:0:0:0:0:1; closing connection (org.apache.kafka.common.network.Selector)
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104857600)
我正在关注以下链接:Link1 https://scotch.io/tutorials/build-a-distributed-streaming-system-with-apache-kafka-and-python
Link2 https://www.tutorialspoint.com/apache_kafka/apache_kafka_installation_steps.htm
我是卡夫卡新手,请帮我设置它。
1195725856 是GET[space]
编码为大端、四字节整数(请参阅here https://chrisdown.name/2020/01/13/1195725856-and-friends-the-origins-of-mysterious-numbers.html有关其工作原理的更多信息)。这表明 HTTP 流量正在发送到 Kafka 端口 9092,但 Kafka 不接受 HTTP 流量,它只接受自己的协议(它将前四个字节作为接收大小,因此会出现错误)。
由于错误是在启动时收到的,因此它可能是良性的,并且可能表明您的网络扫描端口上存在扫描服务或类似的服务,并且使用 Kafka 不理解的协议。
为了找到原因,您可以使用 tcpdump 查找 HTTP 流量来自何处:
tcpdump -i any -w trap.pcap dst port 9092
# ...wait for logs to appear again, then ^C...
tcpdump -qX -r trap.pcap | less +/HEAD
总的来说,这可能很烦人但无害。至少卡夫卡实际上并没有分配/弄脏内存。 :-)
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)