kafka Unrecognized token 'Test': was expecting ('true', 'false' or 'null')

how to handle TaskRejectedException in SpringBoot

Kafka with SASL_PLAINTEXT authentication

generate json with backslash using jackson

Spring cloud stream kafka avro deserialization

How to handle errors and retries in spring-kafka

Consume multiple topics in one listener in spring boot kafka

KStream object when Autowired not printing value

Pass BlockingQueue to Spring KafkaListener

spring boot tomcat connector startup order

Kafka Acknowledgement.acknowledge() only the offset a Listener finished processing

Event based commit in transaction KafkaTemplate using KafkaTransactionManager

Batching Records with kafka template

Kafka: Multiple instances in the same consumer group listening to the same partition inside for topic

Kafka consumer poll with offset 0 not returning message

Maybe not public or not valid? Using Spring's Websocket and Kafka

Embedded Kafka migration State Store between two instances with different @StreamListener

Spring kafka Consumer Not Working When deployed in Tomcat

Spring Kafka and Transactions

Synchronising transactions between database and Kafka producer

How to pause/start/stop Kafka Producer / Kafka Template

KTable returns no data in Spring Boot application, however it can be queried

How to get message by key from kafka topic

spring integration kafka - DSL KafkaListener message payload deserialised to incorrect object type

setConsumerRebalanceListener how to get consumer

Accessing Kafka Stream State Store with Spring

How to get kafka consumer-id for logging

Transactions in Spring kafka

Kafka Pausing partition and taking long time (10 min) in resuming it again

Make Kafka Consumer wait for Events

@KafkaListener concurrency multiple topics

springboot-kafka java 8 time serialization

how to process message received in kafka using spring integration transformer

Spring Kafka SeekToCurrentErrorHandler Find Out Which Record Has Failed

Spring Kafka and Kafka Streams

How to use Spring-Kafka to read AVRO message with Confluent Schema registry?

Set content-type of topic with periods in Spring Cloud Stream

Kafka stream enrichment - Sourcing a lookup table

Spring for Apache Kafka: How to seekToEnd of a partition?

Seeking to a Kafka Offset with Spring Cloud Stream

Use two Kafka producer factories in KafkaEmbedded unit test

I 'd like to stop @KafkaListener after some time

how to Change config in kafka appender for log4j2.xml?

reading data from Kafka and storing it in dynamo db

Kafka Consumer Shutdown in Tomcat

Springboot integration with kafka zipkin and elasticsearch

how to aggregate multiple partition in kafka streams

Kafka removing consumer from group

Confused about preventing duplicates with new Kafka idempotent producer API

Spring Kafka - How to Retry with @KafkaListener

spring integration kafka - pause/seek consumer from my listener for a small time

Spring-Boot and Kafka : How to handle broker not available?

SpringKafka Disable Consumer Rebalancing

Spring Kafka- Prevent consumer to connect Kafka topic during build in Spring Boot

Handling Repository and Kafka Transactions

How can I query a Kafka topic to get all the records based on some criteria?

spring boot KafkaListener with mulitple group ids

Spring Kafka discard message by condition in listener

how to define two instances of StreamsBuilderFactoryBean

Spring Kafka The class is not in the trusted packages

How to authenticate interactive store queries between stream application instances

Kafka sprint plugin is not distributing all partitions

Spring Kafka configure number of partitions for topic

Use a KTable or Kstream with Spring Cloud Stream and use Avro

Kafka publishing in multiple threads to the same partition

How to implement a stateful message listener using Spring Kafka?

Spring Kafka multiple consumer for single topic consume different messages

Spring Cloud Kafka Stream: Can't get WindowedAggregateSessions working with custom Serdes

Spring Kafka Retry Logging

Spring boot spring.kafka.bootstrap-servers not getting picked up by consumer config

kafka Burrow reports Multiple Offsets for same consumer_group and same topic

Spring Kafka, manual committing successful records in batch listener while retry returns only failed records

Transactional Kafka Listener and Producer

Java Message Object Enum Spring integration Error

Idempotent and Transactions

Kafka listener, get all messages

spring-kafka consumer group does not list as active

Difference between Spring Kafka lib and native Kafka Java API

Session Windows in Kstreams does not work as expected with Exactly once semantics

Kafka __consumer_offsets growing in size

Kafka throwing "org.apache.kafka.clients.consumer.CommitFailedException"

How to filter Kafka messages before consumer consume in spring Kafka

Kafka --from-begining CLI vs Kafka Java API

Kafka outbound channel can't take message from a channel

Define generic Protobuf converter based on annotated method value type

How can i send a message to disconnected customers with spring kafka?

my kafka consumer start up with error logs : this is not the correct coordinator

Spring Cloud Stream Kafka DLQ via Retryable/Recover

Spring Cloud Stream "BindingServiceError" using Kafka Binder

How not to call (spy) methods of static member (KafkaTemplate UT)

org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for com.logging.sdk-2: 2038 ms has passed since batch creation plus linger time

How spring kafka delivre message while client was disconnected?

Spring EmbeddedKafka: KTable-KTable leftJoin null right hand side

Embedded Kafka: KTable+KTable leftJoin produces duplicate records

Problems with Kafka configuration using SpringBoot

Embedded Kafka tests (ran by SBT) intermittently fails with ZooKeeperServer errors

Specify client.id per KafkaTemplate

Terminate Spring Kafka transaction if Kafka server is unavailable

Properly seekToBeginning() all consumers in a group

Kafka Offsets.storage