kafka使用生产者脚本出现超时问题修订版本明细

源

采纳

编辑于 3年前

pebbles辉

kafka使用生产者脚本出现超时问题

kafka

前提1：配置了sasl_plaintext的kafka在使用生产者脚本的时候，报超时错误：错误如下
前提2：使用消费者没有报错（确实收不到）
前提3：换成localhost:9092，生产者以及消费者可以正常执行

server.properties 配置

listeners=SASL_PLAINTEXT://dcim-broker-hjsxxa-02:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN

运行生产者的指令：
./kafka-console-producer.sh --broker-list dcim-broker-hjsxxa-02:9092 --topic test --producer-property security.protocol=SASL_PLAINTEXT --producer-property sasl.mechanism=PLAIN

错误消息：

TimeoutException: Expiring 2 record(s) for test-0: 1548 ms has passed since batch creation plus linger time

telnet是没问题的

预览