背景是拿备份数据启kafka服务，之后项目就连不上kafka

输出大致是这样的：

[      Thread-27] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=111] Group coordinator xxxxx:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
[      Thread-27] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=111] Discovered group coordinator xxxxx:9092 (id: 2147483647 rack: null)
[      Thread-27] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=111] Group coordinator xxxxx:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery

原因有很多：

1. kafka 相应的hostname 和ip 对应本地没有配置,telnet检查下

可能因为异常重启，造成__consumer_offsets的清理一直没有进行，积累了大量历史数据，kafka一直加载__consumer_offsets，导致__consumer_offsets无法正常工作，从而提示Coordinator unavailable 。

解决方案：删除kafka_log/__consumer_offsets的历史文件，再启动Kafka进程即可。

在IDE上创建maven项目，pom文件添加依赖 <!-- https://mvnrepository.com/artifact/org.apache. kafka / kafka -clients --> <dependency> < group Id>org.apache. kafka </ group Id> <artifactId> kafka -clients</artifactId> <v er sion 要么 消费 很缓慢 Group coordi nat or ip:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt red is cove ry 重启节点也没用 单节点情况下 coordi nat or 压力太大了 __con sum er _offsets这个元主题的历史消息量分配不均衡 有分区kb、M级别正常，有几个分区直接几十G，如果 消费 的主题在这些压力大的分区，就会 消费 阻塞 因为这个元主 kafka Template包装生产者工厂，生产者工厂包含具体的send发送send er Props参数，往topic里发， Concurrent Kafka Listen er Contain er Factory监听器包装 消费 者工厂， 消费 者工厂包含具体的con sum er 消费 con sum er Props参数，从topic里 消费 ，该topic要和生产者的一致。 Collecting package metadata (current_repodata.json): failed UnavailableInvalidChannel: The channel is not accessible or is invalid. channel name: simple channel url: https://pypi.tuna.tsinghua.edu.cn/simple er ror code: 404 You will need to adjus