spring-kafka

399 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
How can I map incoming headers as String instead of byte[] in my Spring Cloud Stream project?
user_6421560
•
7
1
3225
spring-integration-dsl spring-integration spring-kafka spring-cloud-stream spring
How to commit after each kafka message in spring-kafka?
user_33469310
•
3
2
2159
spring-kafka kafka-consumer-api apache-kafka java
get Kafka unconsumed messages count in Java
user_28813080
•
3
2
1928
spring-kafka kafka-consumer-api apache-kafka java
how to send batched data with Spring Kafka producer
user_143160
•
4
3
10605
spring-kafka apache-kafka java
How to disable `@EnableKafka` in Spring Boot tests?
user_2964270
•
4
3
7596
spring-kafka spring-boot-test spring-boot spring java
How to achieve Always retry policy/Custom Retry Policy for a Kafka Consumer without causing a rebalance in the group
user_122294450
•
2
1
3604
spring-retry spring-kafka apache-kafka spring-boot java
Can spring cloud stream kafka binder allow/deny retry for specific exceptions?
user_88027890
•
2
1
878
spring-retry spring-kafka spring-cloud-stream spring-boot
Spring kafka NonResponsiveConsumerEvent even trigger time when broker is down
user_91698940
•
2
1
1695
spring-kafka apache-kafka spring-boot spring java
Routing messages from Kafka to web socket clients connected to application server cluster
user_85501830
•
5
2
1570
spring-kafka apache-kafka websocket
Spring Kafka - Consume last N messages for partitions(s) for any topic
user_26838140
•
5
2
1699
spring-kafka apache-kafka-streams apache-kafka spring java
Hot Questions