Page History

Map<String, Object> producerConfig = new HashMap<>();
producerConfig.put("key.serializers", "kafka.serializers.KafkaAvroDeserializer, org.apache.kafka.common.serialization.StringSerializerLargeMessageSerializer");
producerConfig.put("large.message.payload.store.class", "myclient.serializers.payload.store.CustomS3Store")
producerConfig.put("large.message.threshold.bytes", "1MB");
producerConfig.put("s3.bucket", "my-bucket")
producerConfig.put("s3.retry.attempts", "3");
producerConfig.put("s3.connection.timeout.ms", "5000");
producerConfig.put("bootstrap.servers", "localhost:9092");

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