Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to disable/enable - Confluent KAFKA Interceptor using Spring boot profile?

KafkaConsumer.commitAsync() behavior with a lower offset than previous

AWS MSK kafka Not authorized to access topics

Deserializing a kafka message without schema registry

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