Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Is it better to keep a Kafka Producer open or to create a new one for each message?

Dataflow reading from Kafka without data loss?

How to finish kafka consumer safety?(Is there meaning to call thread#join inside shutdownHook ? )

Skip record if Exception occurs in Topology

Not acknowledging the kafka message at all in MANUAL_IMMEDIATE mode

kafka partition rebalancing (assignment) is taking too much time

How to choose Kafka transaction id for several applications, hosted in Kubernetes?

Spring boot Kafka Consumer Bootstrap Servers always picking Localhost 9092

debezium sqlserver connector outputs encoded values for numeric/decimal fields

How to configure kafka transaction manager with spring transaction in spring boot app

Create Kafka connector but start as paused

Deserialize Kafka AVRO messages using Apache Beam

Get plugin version installed in logstash

Define Kafka ACL to limit topic creation

Spring Boot Manual Acknowledgement of kafka messages is not working

How to Improve Performance of Kafka Producer when used in Synchronous Mode

Encoding / formatting issues with python kafka library

Kafka Cannot Configure Topics on Application Startup, but Later Can Communicate

SpringBoot Kafka + openjdk 17: org.xerial.snappy.SnappyError: [UNSUPPORTED_PLATFORM] pure-java snappy requires access to java.nio.Buffer raw address

Debezium, Kafka connect: is there a way to send only payload and not schema?