Skip to main content

Migrate kafka client to latest version

I want to migrate old Java code which uses
org.apache.kafka:kafka-clients:1.0.1-mapr-1803 but I get missing Java
methods:

public Producer kafkaProducer() {
final Properties producerproperties = new Properties();
producerproperties.put(ProducerConfig.STREAMS_BUFFER_TIME_CONFIG,
kafkaProducerConfiguration.getBufferTimeInMilliSeconds());
producerproperties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
kafkaProducerConfiguration.getProducerBootstrapServers());
return new Producer<String, String>(producerproperties);
}

STREAMS_BUFFER_TIME_CONFIG ("streams.buffer.max.time.ms") is missing.

private void setHeaders(SimpleMapMessage message, ConsumerRecord<K, V> record) {
message.setHeader("partition", String.valueOf(record.partition()));
message.setHeader("producer", record.producer());
}

producer() is missing.

Do you know how I have to replace producer() into the latest kafka client?

Comments