Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in spring-kafka

How to set message headers using KafkaTemplate?

spring kafka - set consumer log level manually (spring 5)

Cannot convert from [java.lang.String] to [com.example.demo.User]

What should be an appropriate value for Kafka consumer concurrency (regard to scaling)?

apache-kafka spring-kafka

How to decide the concurrency to be set in spring kafka?

Spring Kafka don't respect max.poll.records with strange behavior

Spring kafka consumer lag metric is always 0

Kafka consumer/partition vs thread/partition relationship

spring kafka ssl classpath truststore

java ssl spring-kafka

Differences between embedded kafka and testcontainers kafka?

spring-boot spring-kafka

Spring Apache Kafka onFailure Callback of KafkaTemplate not fired on connection error

Unable to unit test a @KafkaListener annotated method

kafka batch processing, ack granularity and dead letter queue

apache-kafka spring-kafka

Embedded Kafka Spring test executes before embedded Kafka is ready

Consumer 'group_name' group is rebalancing forever

Validating Spring Kafka payloads