如何解决Apache Kafka:“由于未知的成员ID,尝试加入组xxxxxxxxxxx失败”关于为什么会发生的任何想法
版本:0.9 卡夫卡消费者在日志中抛出以下错误消息
“由于未知的成员ID,尝试加入组xxxxxxxxxxx失败”。关于为什么会发生这种情况的任何想法
运行3个使用者时,当我为使用者组运行kafka-consumer-groups.sh命令时,只有一个使用者出现。
对为什么会发生这种情况有任何想法吗?
消费者属性:
Properties props = new java.util.Properties();
props.put("bootstrap.servers",config.getServerList());
props.put("group.id",config.getGroupName());
props.put("key.deserializer",config.getKeyDeSerilizar());
props.put("value.deserializer",config.getValueDeSerilizar());
props.put("fetch.wait.max.ms","1000");
props.put("partition.assignment.strategy","org.apache.kafka.clients.consumer.RoundRobinAssignor");
if (!StringUtils.isEmpty(config.getEnableAutoCommit())) {
props.put("enable.auto.commit",config.getEnableAutoCommit());
} else {
props.put("enable.auto.commit","true");
}
if (!StringUtils.isEmpty(config.getAutoCommitIntervalMillis())) {
props.put("auto.commit.interval.ms",config.getAutoCommitIntervalMillis());
} else {
props.put("auto.commit.interval.ms","1000");
}
if (!StringUtils.isEmpty(config.getAutoOffsetReset())) {
props.put("auto.offset.reset",config.getAutoOffsetReset());
} else {
props.put("auto.offset.reset","latest");
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。