Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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

How to deserialize BigDecimal value received from kafka broker through debezium CDC mechanism?

kafka-node several consumers

node.js apache-kafka

Clojure: implementing stateful Java interface