This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2021-04-28
Channels
- # asami (13)
- # babashka (6)
- # beginners (38)
- # calva (14)
- # cider (15)
- # circleci (13)
- # clj-kondo (4)
- # cljsrn (18)
- # clojure (164)
- # clojure-bay-area (3)
- # clojure-europe (46)
- # clojure-italy (8)
- # clojure-losangeles (3)
- # clojure-norway (3)
- # clojure-sweden (24)
- # clojure-uk (115)
- # clojurescript (79)
- # cursive (11)
- # datomic (24)
- # docker (2)
- # events (9)
- # figwheel-main (31)
- # fulcro (5)
- # honeysql (6)
- # jackdaw (7)
- # jobs (3)
- # jobs-discuss (16)
- # joker (1)
- # kaocha (6)
- # keechma (1)
- # lein-figwheel (1)
- # malli (6)
- # pathom (10)
- # podcasts-discuss (13)
- # practicalli (3)
- # react (4)
- # reagent (3)
- # reitit (8)
- # remote-jobs (3)
- # shadow-cljs (21)
- # sql (12)
- # tools-deps (20)
- # xtdb (24)
When I try to poll, I'm getting this:
WARN [org.apache.kafka.clients.NetworkClient:725] - [Consumer clientId=consumer-1, groupId=app Connection to node 2147483646 (/172.18.0.4:9092) could not be established. Broker may not be available.
[org.apache.kafka.clients.consumer.internals.AbstractCoordinator:727] - [Consumer clientId=consumer-1, groupId=app] Group coordinator 172.18.0.4:9092 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery
The error says your client can't reach your broker at the address 172.18.0.4:9092, there's little to do with jackdaw here, it's just about getting your clients to talk to your kafka server, there are a number of tutorials online.
Yeah, I got that, but where do you think it's going wrong? I thought the whole docker yml file may have issues, so now configured each service separately in a docker container now. But still getting the same error.
leave polling, even when I try to use a watch method to see the data in a topic it is returning nothing but it is showing this: docker run -it --name watch --link zk:zookeeper --link kaf:kafka debezium/kafka:1.4 watch-topic -a -k public.app.chatroom this I did to see the contents of chatroom topic and it returned this:
WARNING: Using default BROKER_ID=1, which is valid only for non-clustered installations.
Using ZOOKEEPER_CONNECT=172.17.0.2:2181
Using KAFKA_LISTENERS=: and KAFKA_ADVERTISED_LISTENERS=
Using KAFKA_BROKER=172.17.0.3:9092
Contents of topic public.app.chatroom:
Now here it is saying BROKER_ID=1, and KAFKA_LISTENERS=: and KAFKA_ADVERTISED_LISTENERS= but in my server.properties file BROKER_ID=0 and KAFKA_LISTENERS AND ADVERTISED_LISTENERS isn't configured?
Do you use docker-compose? I think the ip's of the advertised listeners might be wrong. I usually do it like https://github.com/gklijs/bkes-demo/blob/main/docker-cluster.yml so that I can easily connect from other docker compose files, or locally.