spring-boot-starter-kafka示例程序

package org.chobit.kbs.kafka; import org.chobit.kafka.KafkaProducerFactory; import org.chobit.kafka.Processor; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Component public class MyProcessor implements Processor<String> { @Autowired private KafkaProducerFactory producerFactory; @Override public boolean process(String topic, String message) { System.out.println(topic + " - " + message); producerFactory.getById("test-producer").send(topic, message); return true; } @Override public void shutdown() { } @Override public void awaitShutdown() { } }