Создайте потребителя кафки, используя zookeeper в scala - PullRequest
Новая
       15

Создайте потребителя кафки, используя zookeeper в scala

0 голосов
/ 27 мая 2019

Попытка создать потребителя в kafka с помощью zookeeper, но не смогла. Но с помощью загрузчика сервера началось прослушивание потребителем сервера. Может ли кто-нибудь помочь, если это хорошая идея, чтобы подключиться к брокеру напрямую без Zookeeper. Если мы хотим подключиться с помощью zookeeper, как этого добиться. 

val properties = new Properties()
    properties.put("bootstrap.servers", "localhost:9092")
    properties.put("group.id","grp1")
    properties.put("key.deserialize", classOf[StringDeserializer])
    properties.put("value.deserializer", classOf[StringDeserializer])

как мы можем подключиться к зоопарку.

...