Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to enable caching on in-memory Kafka Streams state store

Kafka streams fail on decoding timestamp metadata inside StreamTask

Kafka retention policies

apache-kafka

SerializationException: Size of data received by IntegerDeserializer is not 4

Kafka, Spring Kafka and redelivering old messages

Open Source alternative for Confluent Kafka Connect MQTT Source and Sink connectors [closed]

How to advance the consumer offset in a Kafka consumer group to the end?

Is the leader part of ISR list

How to consume messages in last N days using confluent-kafka-python?

Avro serialization exception - java.time.Instant cannot be cast to java.lang.Long

Kafka Connect JDBC Sink - pk.fields for each topic (table) in one sink configuration

Configure Kafka Connect distributed connector log (connectDistributed.out)

Kafka KSQLDB server logs constantly "found no committed offset for partition"

apache-kafka ksqldb

How to start @KafkaListener based on start flag

java apache-kafka

How to pass JAAS configuration kafka env variables kubernetes

kubernetes apache-kafka

Kafka KSQL Re partition and rekey problem

apache-kafka ksqldb

Kafka message ordering in partition while producer retry

KSQL table not showing data but Stream with same structure returning data

apache-kafka ksqldb

Cost of an unused Kafka topic/partition

Error connecting to local Bitnami Docker Kafka from Spring Boot application

docker apache-kafka