Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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?

Mystery about Kafka's retention period

apache-kafka

Failed to lock the state directory for task 0_13

How to integrate Oracle and Kafka

Kafka streams - KSQL - Split messages and publish to another topic

apache-kafka ksqldb

OpenTracing with Kafka Streams - How to?

Cannot convert Catalyst type IntegerType to Avro type ["null","int"]

Bucket records based on time(kafka-hdfs-connector)

Example on how to use Headers with Confluent Kafka C# library

Reading messages offset in Apache Kafka

Difference between Spring Kafka lib and native Kafka Java API

apache-kafka spring-kafka