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?
