ошибка при выполнении сценария группы kafka-customer на консоли сервера kafka - PullRequest
Новая
       9

ошибка при выполнении сценария группы kafka-customer на консоли сервера kafka

0 голосов
/ 22 сентября 2018

Я обнаружил сайт, демонстрирующий возможность использования API-интерфейса Kafka Consumer для чтения всех существующих групп потребителей, а с помощью другого сценария можно считывать смещения для указанной группы.При следующем выполнении скрипта выдается следующая ошибка: 

]#./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list
 Note: This will not show information about old Zookeeper-based consumers.

   [2018-09-22 09:00:21,043] WARN Connection to node -1 could not be 
   established. Broker may not be available. 
   (org.apache.kafka.clients.NetworkClient)
    Error: Executing consumer group command failed due to Request METADATA 
    failed on brokers List(127.0.0.1:9092 (id: -1 rack: null))


  ]# ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
  Note: This will not show information about old Zookeeper-based 
  consumers.
  [2018-09-22 09:00:39,070] WARN Connection to node -1 could not be 
    established. Broker may not be available. 
    (org.apache.kafka.clients.NetworkClient)
    Error: Executing consumer group command failed due to Request METADATA 
    failed on brokers List(localhost:9092 (id: -1 rack: null))


 ]# ./kafka-consumer-groups.sh --zookeeper localhost:9092 --list
   Note: This will only show information about consumers that use 
     ZooKeeper (not those using the Java consumer API).

    [2018-09-22 09:02:30,369] WARN Session 0x0 for server null, unexpected 
     error, closing socket connection and attempting reconnect 
    (org.apache.zookeeper.ClientCnxn)
    java.net.ConnectException: Connection refused

Попытка изменить сервер начальной загрузки на zookeeper и localhost с 127.0.0.1.Может кто-нибудь определить, в чем проблема и как ее решить?Если я смогу определить, как работают эти скрипты, возможно, я попытаюсь вызвать их и выполнить удаленно из Java-приложения.

Спасибо

...