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

pebbles辉 发表于: 2021-12-31 最后更新时间: 2021-12-31 15:52:16 1,587 游览

前提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是没问题的

kafka

发表于 2021-12-31

pebbles辉

添加评论

参考一下 kafka实战kerberos（笔记）

回答于 2年前

半兽人

pebbles辉 -> 半兽人 2年前

我这个使用的是sasl不是keberos，然后现在生产者没有问题了不报超时了，但是我消费者没法消费到消息

半兽人 -> pebbles辉 2年前

我看你并没有把jaas带进去，可以关注一下broker的日志，是否报什么异常。
参考一下 kafka实战SASL/PLAIN认证

pebbles辉 -> 半兽人 2年前

之前已经代进去了，现在的报错反而是消费者那边，显示的是group coordinator is not available

半兽人 -> pebbles辉 2年前

这是个警告吧，可以忽视。

你看看是否还有更多信息可以提供，没有错误很难下手。

pebbles辉 -> 半兽人 2年前

我用的是plumber工具进行读写测试的，完整错误是

ERRO[0010] unable to complete read for backend 'kafka': unable to complete 'regular' read: unable to read message (exiting): [15] Group Coordinator Not Available: the broker returns this error code for group coordinator requests, offset commits, and most group management requests if the offsets topic has not yet been created, or if the group coordinator is not active pkg=plumber

pebbles辉 -> 半兽人 2年前

使用官方脚本，生产者和消费者都正常，但是消费者无法消费到生产者生产的消息

半兽人 -> pebbles辉 2年前

你去kafka节点看看日志，那里应该有错误原因。

pebbles辉 -> 半兽人 2年前

看了下，好像是消费者分区出了问题，里面所有的参数都为0，然后消费者启动时就显示找不到leader

你的答案

查看kafka相关的其他问题或提一个您自己的问题。

提问

找不到想要的答案？提一个您自己的问题。

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

你的答案

昵称