Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How local cache is managed by Confluent Schema Registry

Kafka: consume all messages on demand

The default Kafka partitioner create hash key collision

Hardware requirement for 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