Page History

Map<String, Object> producerConfig = new HashMap<>();
producerConfig.put("key.serializerserializers", "kafka.serializers.KafkaAvroDeserializer, org.apache.kafka.common.serialization.StringSerializer");
producerConfig.put("value.serializerslarge.message.payload.store.class",
        "org.apache.kafka.common.serialization.DoubleSerializer,org.apache.kafka.common.serialization.LargeMessageSerializer");  "myclient.serializers.payload.store.CustomS3Store")
producerConfig.put("large.message.threshold.bytes", "1MB");
producerConfig.put("large.message.payload.store.classs3.bucket", "my-bucket")
producerConfig.put("s3.retry.attempts", "CustomS3Store3");
 producerConfig.put("s3.connection.buckettimeout.ms", "my-bucket5000");
producerConfig.put("bootstrap.servers", "localhost:9092");

KafkaProducer<String, Double> producer = new KafkaProducer<>(producerConfig);