책/카프카 핵심 가이드 (2) 썸네일형 리스트형 Chapter 3. Kafka Producer [카프카로 메시지 전달하기] 3.3 카프카로 메시지 전달하기 메시지를 전송하는 가장 간단한 방법은 다음과 같다 try (Producer producer = new KafkaProducer(kafkaProps)) { // 메시지 생성 및 토픽으로 전송 String message = "Hello, Kafka!"; ProducerRecord record = new ProducerRecord(topic, message); producer.send(record); System.out.println("메시지 전송 성공: " + message); } catch (Exception e) { e.printStackTrace(); } 1. producer는 ProducerRecord 객체를 받으므로 이 객체를 생성하는 것에부터 시작함. 조금 있다가 .. Chapter 3. Kafka Producer [카프카에 메시지 쓰기] 카프카를 큐로 사용하든 메시지 버스나 데이터 저장 플랫폼(data storage platform)으로 사용하든 간에 카프카를 사용할 때는 카프카에 데이터를 쓸 때 사용하는 프로듀서나 읽어 올때 사용하는 컨슈머, 혹은 두 가지 기능 모두를 수행하는 application을 생성해야한다 카프카는 개발자들이 카프카와 상호작용하는 application을 개발할 때 사용할 수 있는 client API와 함께 배포된다. 프로듀서의 디자인과 주요 요소의 전체적인 모습을 살펴본 뒤 KafkaProducer 와 ProducerRecord 객체를 어떻게 생성하는지, 어떻게 카프카에 레코드를 전송하는지, 그리고 리턴할 수 있는 에러를 어떻게 처리 대응하는지 알아보자 끝으로 파티션 할당 방식을 정의하는 파티셔너과 객체의 직렬화.. 이전 1 다음
