Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-producer-api

Using Kafka's Log Compaction, what can I do to guarantee consumers don't miss messages, if they are not lagging behind by some defined timelimit?

how to send message to kafka topic protected with SSL

How to write application logs using log4j appender for kafka?

What is the ideal number of partitions in kafka topic?

kafka server TimeoutException: Expiring 1 record(s) for

Pushing UDP messages to Kafka topic

How to proxy Apache Kafka producer requests on the Kafka broker, and redirect to a separate Kafka cluster?

IllegalStateException: No entry found for connection 1001 Kafka Kubernetes

How to parse json data which comes from kafka topic in Storm scheme class?

How to match Kafka producer's record and RecordMetadata

Kafka topic constantly rolling new log segments, no overrides, logfiles tiny

Apache Kafka Producer Config Error

Kafka Streams Threading Model with more than one Stream on the same instance and JVM

How to use truststore.jks & keystore.jks files to build a producer application in .NET using Confluent Kafka

Error while fetching metadata with correlation id 92 : {myTest=UNKNOWN_TOPIC_OR_PARTITION}

Kafka console producer not allowing to write message

Kafka Producer - Spring Boot Application - Unable to Produce Messages

Header information in kafka producer API

Kafka producer infinite log message: Error while fetching metadata with correlation id 18345 : {input-topic=UNKNOWN_TOPIC_OR_PARTITION}