草庐IT

AdminClient

全部标签

Kafka 之 AdminClient 配置

目录一.前言二.AdminClient原理和功能2.1.AdminClient原理2.2. AdminClient功能三. AdminClient配置四. Kafka>=2.0.0 版本五.Kafka>= 2.1.0版本六. Kafka>=2.7 版本一.前言  一般情况下,我们都习惯使用kafka-topics.sh脚本来管理主题,但有些时候我们希望将主题管理类的功能集成到公司内部的系统中,打造集管理、监控、运维、告警为一体的生态平台,那么就需要以程序调用API的方式去实现。  Kafka社区于0.11版本正式推出了Java客户端版的AdminClient,并不断地在后续的版本中对它进行完善

WARN [AdminClient clientId=adminclient-1] Connection to node -1 (/127.0.0.1:9092) could not be estab

kafka中使用./kafka-topics.sh--list--bootstrap-server127.0.0.1:9092命令提示WARN[AdminClientclientId=adminclient-1]Connectiontonode-1(/127.0.0.1:9092)couldnotbeestablished.Brokermaynotbeavailable.(org.apache.kafka.clients.NetworkClient)查看了其他文章说的是没有启动kafka导致;ps-ef|grepkafka发现是启动了kafka的解决:将127.0.0.1:9092更换成配置文