1、Error: Executing consumer group command failed due to org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
查询topic消费情况的时候,出现了该异常
排查:
确认zookeeper没有问题,查看kafka的日志server.log
出现类似错误 ERROR [KafkaApi-3] Number of alive brokers ‘0’ does not meet the required replication factor ‘3’ for the offsets topic (configured via ‘offsets.topic.replication.factor’). This error can be ignored if the cluster is starting up and not all brokers are up yet. (kafka.server.KafkaApis)
解决:一一重启kafka集群中有类似错误的实例。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐