Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Partition not getting created in kafka spring boot

How to disable Kafka internal log?

java apache-kafka log4j

Fetching and Updating Kafka Topic Configurations through Java API

Multi broker cluster

java apache-kafka

Cannot connect to kafka docker container from logstash docker container

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