python (65.2k questions)

javascript (44.3k questions)

reactjs (22.7k questions)

java (20.8k questions)

c# (17.4k questions)

html (16.3k questions)

r (13.7k questions)

android (13k questions)

Questions - quarkus-kafka

Get partition assigned by Kafka

I’m using Quarkus Kafka consumer. And I need to know to which partitions my consumer has been assigned by Kafka broker. Any listener that I can use, just like the one that Kafka client provide. Otherw...
test-img

paul

java

apache-kafka

kafka-consumer-api

quarkus

quarkus-kafka

Votes: 0

Answers: 1

Latest Answer

From the Quarkus docs, I think you can use rebalance listener. It should be called, because the initial assignment of partitions to your client (from no partitions to some partitions) can be considere...
test-img

Hitobat

Change log level for smallrye kafka consumer extension

I have a quarkus app which uses the quarkus-smallrye-reactive-messaging-kafka extension. At runtime it produces a tons of debug logs: rent-orchestrator-service | 16:44:11.508 [smallrye-kafka-consum...
test-img

Vincenzo

logging

kafka-consumer-api

quarkus

smallrye-reactive-messaging

quarkus-kafka

Votes: 0

Answers: 1

Latest Answer

Make sure you do not have another logger in your classpath. So, if you are using maven, check with mvn dependency:tree and exclude any logger that may be pulled: <dependency> <groupId>f...
test-img

Clement

Posts

Questions

Blogs

Jobs