Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Not able to send records from Kafka MSK to elastic search using Kafka connect

Is there a way in the S3 Kafka sink connector to ensure all records are consumed

How to Handle Different Timezone in Kafka Streams?

why kafka offsets are stored at consumer end of application?

apache-kafka

How to consume from latest offset using Sarama Go Kafka Consumer

Error handling - Consumer - apache kafka and spring

In Kafka java api, what does the key and value of the concumerRecord mean?

Kafka Avro Console Consumer not working after enabling SSL encryption and authentication

Apache Kafka: ...StringDeserializer is not an instance of ...Deserializer

Creating topic in kafka_2.12-2.2.0 causes “Timed out waiting for a node assignment” error

apache-kafka

Is AdminClient in package kafka-clients thread safe?

java apache-kafka

Apache Kafka Scaling Topics using partitions

apache-kafka

Spring-Kafka: How to insert an application.yml topic in Producer Kafka

Kafka Streams - Unknown magic byte on GenericAvroSerde

kafka streams - joining partitioned topics