Код: Выделить всё
@Bean
public KafkaTemplate kafkaTemplate() {
return new KafkaTemplate(producerFactory());
}
@Bean
public ProducerFactory producerFactory() {
configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1:9092");
configProps.put("spring.kafka.bootstrap-servers", "127.0.0.1:9092");
configProps.put("spring.kafka.consumer.auto-offset-reset","earliest");
configProps.put("spring.kafka.consumer.group-id","data-group");
configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class.getName());
configProps.put(ConsumerConfig.CLIENT_ID_CONFIG,"ClientIDdata-group");
return new DefaultKafkaProducerFactory(configProps);
}
ListenableFuture futureResult = kafkaTemplate.send(topic, binarydata);
futureResult.addCallback(PublishCallback());
Убедено, что клиент kafka 2.7.1 включен в jar и добавлен в pom.xml
Подробнее здесь: https://stackoverflow.com/questions/779 ... -mvn-sprin