Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

How to create unit test with kafka embedded in the spring cloud stream

Kafka - Deserializing the object in Consumer

Adding custom header using Spring Kafka

Failed to construct kafka producer with Springboot

Spring kafka error Caused by: java.lang.ClassNotFoundException: org.springframework.kafka.transaction.KafkaAwareTransactionManager

Kafka Consumer: Stop processing messages when exception was raised

How to make a Spring Boot application quit on tomcat failure

How to set offset in kafkalistener

Avoiding Kafka Streams to start in tests using Spring Boot 1.5

Is it possible to ReKey a GlobalKTable?

Spring Kafka - Event sourcing - Example of how to query some entity state using Kafka + KafkaStreams API

Read data from KSQL tables

Spring kafka and Kafka Cluster

apache-kafka spring-kafka

spring kafka thorws InstanceAlreadyExistsException exception after setting concurrency > 1

Spring Kafka error handling - v1.1.x

AWS Kafka (MSK) - How to generate Keystore and truststore and use the same in my Spring Cloud Stream application?

EmbeddedKafka how to check received messages in unit test