[KAFKA] JAVA 연동 및 CallBack, Partitioner

코드 public class ProducerDemo { private static final Logger log = LoggerFactory.getLogger(ProducerDemo.class.getSimpleName()); public static void main(String[] args) { log.info("hello world"); // 프로듀서 설정 Properties properties = new Properties(); properties.setProperty("bootstrap.severs", "127.0.0.1:9092"); //브로커와 연결 properties.setProperty("key.serializer", StringSerializer.class.getName()); //직렬화 properties.setProperty("value.serializer", StringSerializer.class.getName()); // 프로듀서 생성 final KafkaP...

원문링크 : [KAFKA] JAVA 연동 및 CallBack, Partitioner