consumer — topic에서 메시지를 읽는 주체orders topic에 주문 이벤트가 쌓인다. 이제 그 메시지를 읽어 처리해야 한다 — 주문 처리 서비스가 읽어가고, 분석 서비스가 따로 읽는다. 이 "topic에서 메시지를 읽는 주체"가 consumer다.이 글은 consumer가 뭔지부터 시작해, 실제 설정과 코드, auto-commit의 위험, LAG 모니터링까지 다룬다.consumer란 — topic에서 메시지를 읽는 클라이언트consumer도 producer처럼 앱에 내장되는 클라이언트 라이브러리다.Java consumer 기본 코드// 1. 설정Properties props = new Properties();props.put("bootstrap.servers", "localhost:9092..
producer — 메시지를 topic에 보내는 주체쇼핑몰 주문 API가 주문 이벤트를 orders topic에 넣는다(장 02). 이때 "메시지를 topic에 보내는 주체"가 producer다. 애플리케이션에 내장되는 클라이언트로, producer.send(...) 한 줄로 메시지를 쏜다.이 글은 producer가 뭔지부터 시작해, 실제 설정과 코드로 어떻게 쓰는지, acks·idempotent producer로 신뢰성을 어떻게 확보하는지까지 다룬다.producer란 — topic에 메시지를 보내는 클라이언트producer는 앱에 내장되는 클라이언트 라이브러리다. 별도 서버가 아니라, 주문 API·배치 잡·로그 수집기 같은 앱 프로세스 안에서 동작한다.Java producer 기본 코드// 1. 설정P..
Archive
consumer — topic에서 메시지를 읽는 주체orders topic에 주문 이벤트가 쌓인다. 이제 그 메시지를 읽어 처리해야 한다 — 주문 처리 서비스가 읽어가고, 분석 서비스가 따로 읽는다. 이 "topic에서 메시지를 읽는 주체"가 consumer다.이 글은 consumer가 뭔지부터 시작해, 실제 설정과 코드, auto-commit의 위험, LAG 모니터링까지 다룬다.consumer란 — topic에서 메시지를 읽는 클라이언트consumer도 producer처럼 앱에 내장되는 클라이언트 라이브러리다.Java consumer 기본 코드// 1. 설정Properties props = new Properties();props.put("bootstrap.servers", "localhost:9092..
producer — 메시지를 topic에 보내는 주체쇼핑몰 주문 API가 주문 이벤트를 orders topic에 넣는다(장 02). 이때 "메시지를 topic에 보내는 주체"가 producer다. 애플리케이션에 내장되는 클라이언트로, producer.send(...) 한 줄로 메시지를 쏜다.이 글은 producer가 뭔지부터 시작해, 실제 설정과 코드로 어떻게 쓰는지, acks·idempotent producer로 신뢰성을 어떻게 확보하는지까지 다룬다.producer란 — topic에 메시지를 보내는 클라이언트producer는 앱에 내장되는 클라이언트 라이브러리다. 별도 서버가 아니라, 주문 API·배치 잡·로그 수집기 같은 앱 프로세스 안에서 동작한다.Java producer 기본 코드// 1. 설정P..
wall
방문 흔적을 남겨주세요. 질문이나 인사 모두 환영합니다.
