kafka-consumer-api

355 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
How to add fixed delay for each Task in monix without building up delay
user_14157600
•
2
0
131
monix apache-kafka-streams kafka-consumer-api apache-kafka scala
Implement Reactive Kafka Listener in Spring Boot application
user_67977890
•
8
1
5895
reactor-kafka reactive-kafka spring-kafka kafka-consumer-api java
Kafka Consumer not consuming reprocessed data with Spark
user_27026300
•
2
0
96
kafka-consumer-api apache-kafka apache-spark python
Kafka consumer group keeps rebalancing
user_54744800
•
2
0
277
kafka-consumer-api apache-kafka python
How does Apache Kafka Work With Multiple Brokers and Single Broker
user_113854850
•
3
2
4326
kafka-producer-api apache-kafka-streams kafka-consumer-api apache-kafka
Not acknowledging the kafka message at all in MANUAL_IMMEDIATE mode
user_46534230
•
2
1
1342
spring-kafka kafka-consumer-api apache-kafka
Making Kafka ConcurrentMessageListenerContainer Work as a Batch
user_145506460
•
2
1
450
spring-kafka kafka-consumer-api apache-kafka java
KafkaConsumer Position() vs Committed()
user_34269300
•
2
1
549
kafka-consumer-api apache-kafka scala
kafka Manager not showing consumer lag or Sum of partition offsets
user_66181330
•
2
0
367
kafka-producer-api spring-kafka apache-kafka-streams kafka-consumer-api apache-kafka
Getting `'utf-32-be' codec can't decode bytes in position 4-7: code point not in range(0x110000)` while consuming Kafka message in python
user_53465910
•
2
0
244
kafka-producer-api kafka-consumer-api python-3.x
Hot Questions