spring-kafka-test polling records from topics

SpringBoot CloudStream (Kafka) and JPA

Handling backpressure and avoiding rebalances on a slow consumer kafka

Spring Cloud Stream Kafka Aggregate with KStream

Kafka Spring: How to create Listeners dynamically or in a loop?

Spring Cloud Stream - Can't get configured kafka's broker address

Kafka consumer process order with concurrency

Kafka how to set producer retries to Infinity

Spring kafka transaction id is wrong at start?

Report Metrics from Kafka to Actuator

Spring Kafka Producer logging

Kafka Consumer/Producer test in Spring Kafka

API which waits for a message using Spring-Kafka

How to seek Offset for Time Stamp with Spring for Kafka

Kafka Message migration

Kafka consumer receives the message in different format when producer sends as List<Object>

Spring-Kafka: How to configure producer to be as concurrent as consumer?

Custom spring-kafka deserializer for LocalDateTime

How to use spring-kafka for sending a message again

Spring kafka: What’s the relationship b/w concurrency we set and listeners?

Kafka: The message when serialized is larger than the maximum request size you have configured with the max.request.size configuration

Calling seek of ConsumConsumerSeekCallback from a spring boot application

Spring-Kafka - How can I specify a range of partitions for Listeners using annotations?

spring-kafka: autoconfiguration issue using ReplyingKafkaTemplate

Spring kafka 2.2 type mappings class loader mismatch

@KafkaListener Read from beginning every time

DefaultKafkaProducerFactory with multiple JsonSerializer mappings

Kafka keeps producing requests even if broker is down

Adding ConsumerRebalanceListener to the ConcurrentKafkaListenerContainerFactory

Spring Boot, Spring-Kafka, and Spring-Cloud compatibility

List Kafka Topics via Spring-Kafka

Kafka is marking the coordinator dead when autoscaling is on

Spring-kafka-test - Not able to get value from ConsumerRecord

spring kafka listener is looking ContainerProperties at wrong place

How to activate KafkaBatchListener via application.properties (factory.setBatchListener(true))

Spring cloud streams could not autowire Source.class

Spring cloud stream kafka pause/resume binders

Spring cloud stream 2.0 and startOffset latest

Spring-boot and Spring-Kafka compatibility matrix

Seek to an offset via an external trigger

Spring Cloud - Dispatcher has no subscribers for channel

Spring Cloud Stream Reactive - How to do the Error Handling in case of reactive stream pipeline?

spring kafka ssl classpath truststore

Spring Cloud Stream Reactive - which kafka-binder is appropriate in case of reactive stream pipeline?

"No transaction is in process" with Spring Kafka using ReplyingKafkaTemplate, @KafkaListener and @SendTo

Enable/Disable the kafka binding in spring cloud stream using properties

Send a json payload to Apache Kafka topic in Spring

Connect to multiple Kafka servers using springboot

Kafka reset offsets to earliest

How to parallelize Kafka message consumption

Spring kafka + sleuth without annotation

How to skip corrupt (non-serializable) messages in Spring Kafka Consumer?

Spring Cloud Stream Binder

Spring Boot Kafka Consumer throwing No bean named 'kafkaListenerContainerFactory' available

How to setup one spring kafka consumer with SASL and one without?

Partitioned Kafka Topic for DLQ for spring-cloud-stream

Spring Kafka Always rebalance after 5 min even i pause consumer

Where should I write my Kafka Adapter/Connector to read the data from the topic?

Use KafkaListener in class not managed by Spring

What are the alternatives to spring-kafka?

CommitFailedException spring-kafka

Buffering Kafka Data For Backup

spring boot properties yaml

Status of accessing the current offset of a consumer?

Spring Kafka producer requires restart

Spring boot Kafka messaging. How to use SpEL to manage handler access

controlling kafka listeners consumption

Kafka state store returns null when using Avro

Spring Kafka - access offsetsForTimes to start consuming from specific offset

Kafka consumer fails silently to connect to broker

Deleting an entry from Kafka state store

Is it possible to aggregate an object instad of a string with spring cloud stream api?

Spring kafka embedded testing

EmbeddedKafka AdminClient shuts down before Spring app starts for tests

spring-kafka Request Reply: Different Types for Request and Reply

Multiple Consumers Spring Kafka

unable to read from Kafka

Spring Kafka replay old messages

Testing with EmbeddedKafka - Test report

Unable to connect to Kafka run in container from Spring Boot app run outside container

KafkaTestUtils.getRecords() returns only firs sent record

Delayed ACK in Spring Kafka

Spring Boot 2.1 Micrometer Kafka consumer metric statistic COUNT is "NaN"

Retrieve both payload and headers of a Kafka message that could not be deserialized

Mirror kafka topics with custom configuration as a standalone application

fetch 1 message at given offset when debugging app using spring-kafka

Default values for ProducerConfigs in Spring-Boot Apache Kafka

KafkaStreams.cleanUp() doesn't remove the correct directory

Testing exceptions on a ConsumerAwareRebalanceListener

transactional behavior in spring-kafka

Spring Kafka Batch Option: ClassCastException using SeekToCurrentBatchErrorHandler

Unable to send messages from Kafka using KafkaTemplate

Registering kafkalistenerContainers with KafkaListenerEndpointRegistry

How to test a ConsumerAwareRebalanceListener?

Error handler not called until after all retries are attempted in Spring Cloud Stream

Spring kafka consumer single batch pull is fetching data from different partitions

Error management in Spring Cloud Stream with Kafka Stream

Kafka Producer Thread, huge amound of threads even when no message is send

How to convert int to boolean in Avro + Spring Kafka?

How to set Kafka consumer configuration to consume messages from now?