docker kafka 修改hostname导致的问题
昨天发现开发环境的3台kafka无法消费,所以今日kafka的容器执行如下语句
bash-4.4# ./kafka-topics.sh --describe --zookeeper 192.168.0.170:2181 --topic nova2_plantree_topic
Topic:nova2_plantree_topic PartitionCount:3 ReplicationFactor:3 Configs:
Topic: nova2_plantree_topic Partition: 0 Leader: 2 Replicas: 2,1,0 Isr: 2,1,0
Topic: nova2_plantree_topic Partition: 1 Leader: 0 Replicas: 0,2,1 Isr: 0,2,1
Topic: nova2_plantree_topic Partition: 2 Leader: 1 Replicas: 1,0,2 Isr: 1,0,2
发现topic是好的
然后执行
bash-4.4# ./kafka-consumer-groups.sh --bootstrap-server 192.168.0.170:9092 --list
发现消费者group是空的,或者直接报错
然后查看java的消费者日志,报错很多
2019-03-13 09:42:39.641 org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1 WARN org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:846) - Error while fetching metadata with correlation id 879 : {nova2_plantree_topic=LEADER_NOT_AVAILABLE}
后面网上查了一下,说可能是hostname被修改了而没有修改kafka的配置的原因,和同事沟通了一下发现确实这几天修改了hostname
所以我在docker 里对kafka的/opt/kafka_2.12-2.1.0/config/server.properties 加了如下的配置
advertised.host.name=win-jrh378d7scu.auth.hpicorp.net
然后重启所有的三台docker上的zookeeper和kafka
然后再看java消费者的日志,没有报错LEADER_NOT_AVAILABLE了,但是239的kafka好像还是有问题,后面看了239的kafka的docker日志,发现连不上183和3的zookeeper
检查了一下3台的zookeeper都是正常的监听了2181端口,所以肯定是docker机器开机的时候没有关闭防火墙,后来把防火墙关闭了没有重启docker导致有的zookeeper的端口访问不了
所以我把三台的docker都systemctl stop后再start
再把三台zookeeper和kafka都启动就好了
在kafka中执行也可以查询到消费group了
bash-4.4# ./kafka-consumer-groups.sh --bootstrap-server 15.31.213.183:9094 --list
plantree_group
最新文章
- [WCF编程]11.错误:错误类型
- Android驱动开发前的准备
- 在centos配置nginx+php的环境
- django多条件筛选搜索(项目实例)
- 20个优秀的 JavaScript 键盘事件处理库
- 关于外部引用JS,中文乱码的问题
- Spring注解@Scheduled定时任务
- 2015-11-02-js
- Top 5 Free Screen Recording Softwares For Windows
- APP中数据加载的6种方式-b
- Linux Shell 数学运算
- DataTable一些操作
- maintenance ShellScripts
- cakephp 复杂查询
- js 常用正则表达式表单验证代码
- sqlite3API函数
- 总结vue中父向子,子向父以及兄弟之间通信的几种方式
- opensips redis配置记录
- keystone系列一:keystone基础
- cJSON库的简单介绍及使用