[KAFKA] Consumer Java API, Shutdown

코드 public class ConsumerDemo { private static final Logger log = LoggerFactory.getLogger(ConsumerDemo.class.getSimpleName()); public static void main(String[] args) { log.info("kafka Consumer"); String groupId = "java-app"; String topic = "demo_topic"; // 프로듀서 설정 Properties properties = new Properties(); properties.setProperty("bootstrap.servers", "127.0.0.1:9092"); //브로커와 연결 properties.setProperty("key.deserializer", StringDeserializer.class.getName()); //직렬화 properties.setProperty("value.deser...

원문링크 : [KAFKA] Consumer Java API, Shutdown