If you are using Kafka broker versions prior to 2.4, then this value should be set to at least 1.Starting with version 3.0.8, the binder uses -1 as the default value, which indicates that the broker 'default.replication.factor' property will be used to determine the number of replicas. GitHub - joelbraun/KafkaRetry: Sample .NET Core implementation of Uber ... Integer. Password of the private key in the key store file. . KafkaProducer class provides send method to send messages asynchronously to a topic. Quarkus - Apache Kafka Reference Guide The config acks is the number of acknowledgments the producer needs to receive before considering a successful commit. For applications that are written in functional style, this API enables Kafka interactions to be integrated easily without requiring non-functional asynchronous produce or consume APIs to be incorporated into the application logic. Example 1. Kafka Tutorial: Creating Advanced Kafka Producers in Java Confluent.Kafka nuget version: 0.9.5; Apache Kafka version: 2.12-0.10.2.1 . Step 2: Create the Kafka Topic. { // select a partition based on some logic // return the partition number return 0} } partitionMetadata is an array of partitions . Every connector in Logic Apps is an API behind the scenes. MockProducer (boolean autoComplete, Partitioner partitioner, Serializer < K > keySerializer, Serializer < V > valueSerializer) Create a new mock producer with invented metadata the given autoComplete setting, partitioner and key\value serializers. What parameters of Kafka Producer config are needed to be changed so that the producer should: 1) Retry n times 2) After n interval for the same message in case if the broker is down. However, if a producer ack times out or receives an error, it might retry sending the message assuming that the message was not written to the Kafka topic. The producer is thread-safe and can be used to publish records to multiple partitions. Get a terminal into the Kafka container and use the kafka-console-producer.sh to send messages. . Kafka Producer Retries | Learn Apache Kafka with Conduktor