Problems with Kafka

[Werner Gresshoff]

Hello,

I'm using Kafka for the first time and have problems to consume messages.
I deployed Kafka in Kubernetes (with Bitnami helm chart) and it's running. My client seems to connect to Kafka as well but when I send a message to a topic nothing arrives there (running kafka-console-consumer.sh shows noting). There is no exception thrown when the message is sent. I set the log level to DEBUG and produced the following output:
```
2021-02-10 10:50:44,775 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:44,775 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:44,775 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6444) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:44,775 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:44,836 DEBUG [org.apa.kaf.cli.con.int.AbstractCoordinator] (kafka-coordinator-heartbeat-thread | da36b99c-3530-4d0d-883c-50ec67ccf173) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending Heartbeat request with generation 1 and member id kafka-consumer-authorities-8a6c21a0-f9ca-4647-936a-5cebdd26f3b4 to coordinator kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 2147483647 rack: null)
2021-02-10 10:50:44,837 DEBUG [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Received successful Heartbeat response
2021-02-10 10:50:45,277 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:45,277 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:45,277 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6445) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:45,277 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:45,610 DEBUG [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='authorities')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:45,778 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:45,778 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:45,778 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6446) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:45,778 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:45,779 DEBUG [org.apa.kaf.cli.Metadata] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Updating last seen epoch from 0 to 0 for partition authorities-0
2021-02-10 10:50:45,779 DEBUG [org.apa.kaf.cli.Metadata] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Updated cluster metadata updateVersion 13 to MetadataCache{clusterId='lS5tWaoGRKSWfSBMsmc5bw', nodes={0=kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)}, partitions=[PartitionMetadata(, error=NONE, partition=authorities-0, leader=Optional[0], leaderEpoch=Optional[0], replicas=0, isr=0, offlineReplicas=)], controller=kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)}
2021-02-10 10:50:46,280 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:46,280 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:46,280 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6447) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:46,280 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:46,781 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:46,781 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:46,781 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6448) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:46,781 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:47,283 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:47,283 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:47,283 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6449) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:47,283 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:47,784 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:47,785 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:47,785 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6450) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:47,785 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:47,836 DEBUG [org.apa.kaf.cli.con.int.AbstractCoordinator] (kafka-coordinator-heartbeat-thread | da36b99c-3530-4d0d-883c-50ec67ccf173) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending Heartbeat request with generation 1 and member id kafka-consumer-authorities-8a6c21a0-f9ca-4647-936a-5cebdd26f3b4 to coordinator kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 2147483647 rack: null)
2021-02-10 10:50:47,839 DEBUG [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Received successful Heartbeat response
2021-02-10 10:50:48,287 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:48,288 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:48,288 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6451) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:48,288 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:48,790 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:48,790 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:48,790 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6452) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:48,790 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:49,292 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (kafka-coordinator-heartbeat-thread | da36b99c-3530-4d0d-883c-50ec67ccf173) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:49,292 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:49,293 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6453) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:49,293 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:49,800 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:49,800 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:49,800 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6454) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:49,800 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:50,302 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:50,302 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:50,302 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6455) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:50,302 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:50,805 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:50,806 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:50,806 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6456) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:50,806 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:50,836 DEBUG [org.apa.kaf.cli.con.int.AbstractCoordinator] (kafka-coordinator-heartbeat-thread | da36b99c-3530-4d0d-883c-50ec67ccf173) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending Heartbeat request with generation 1 and member id kafka-consumer-authorities-8a6c21a0-f9ca-4647-936a-5cebdd26f3b4 to coordinator kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 2147483647 rack: null)
2021-02-10 10:50:50,839 DEBUG [org.apa.kaf.cli.con.int.AbstractCoordinator] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Received successful Heartbeat response
2021-02-10 10:50:51,307 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 1853540142 with 0 response partition(s), 1 implied partition(s)
2021-02-10 10:50:51,307 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Added READ_UNCOMMITTED fetch request for partition authorities-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)], epoch=0}} to node kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
2021-02-10 10:50:51,307 DEBUG [org.apa.kaf.cli.FetchSessionHandler] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Built incremental fetch (sessionId=1853540142, epoch=6457) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s)
2021-02-10 10:50:51,307 DEBUG [org.apa.kaf.cli.con.int.Fetcher] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-authorities, groupId=da36b99c-3530-4d0d-883c-50ec67ccf173] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(authorities-0)) to broker kafka-0.kafka-headless.ulb-authorities-management-dev.svc.cluster.local:9092 (id: 0 rack: null)
```

My project is accessible here: https://drive.google.com/file/d/13gYa8O9tsjOQzNHiqKsLDUAHgniyW5MK/view?usp=sharing

Best regards

Werner

[clement escoffier]

Hello,

You can't call an @Outgoing method directly. That would not do anything.

With your current code, the call to send is not doing anything and Quarkus calls the send method on startup which return an empty stream.

To send a message, you need to use an Emitter. See [1] and [2] as examples.

Clement

[1] - https://quarkus.io/blog/reactive-messaging-emitter/

[2] - https://quarkus.io/blog/getting-started-kafka/

--
You received this message because you are subscribed to the Google Groups "Quarkus Development mailing list" group.
To unsubscribe from this group and stop receiving emails from it, send an email to quarkus-dev...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/quarkus-dev/b729b0ef-dd6b-483c-9518-6859f0ee2b13n%40googlegroups.com.

[Werner Gresshoff]

Hello Clement,

thanks for your help! I did not understand that correctly and will come back to (hopefully) report success!

Best regards

Werner

[Werner Gresshoff]

Hello again,

great! It works now! Thank you very much!!!

Regards

Werner