![](http://i1.daumcdn.net/thumb/C148x148.fwebp.q85/?fname=https://blog.kakaocdn.net/dn/cFOsmK/btsK0ksPFi8/5QqebKmtXQX46zWlkKKa31/img.png)
Consumer카프카에서 데이터를 읽는 애플리케이션을 토픽을 구독(subscribe)하고 구독한 토픽들로부터 메시지를 받기 위해 KafkaConsumer를 사용한다. 카프카에서 데이터를 읽는 것은 다른 메시지 브로커들과 조금 달라 이러한 개념들을 먼저 이해하지 않다면 컨슈머 API 사용법을 이해하는 것은 어려울 수 있다. 따라서 이러한 개념을 먼저 살펴보자. KafkaConsumer 생성public class SimpleConsumer { public static void main(String[] args) { String topicName = "simple-topic"; Properties props = new Properties(); props.setProp..
기타/kafka
2024. 12. 3. 18:25
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- Today
- Yesterday
링크
TAG
- spring webflux
- Java
- 람다
- Kafka
- nginx
- annotation
- postgresql
- 카프카
- 넥스트스탭
- Synchronized
- 트랜잭션
- NeXTSTEP
- 자바 네티
- socket
- 네티 스레딩 모델
- 비관적 락
- 구름톤챌린지
- TDD
- mdcfilter
- transaction
- 구름톤 챌린지
- redis session
- sql
- pessimistic lock
- 스프링 네티
- jvm 메모리 구조
- mysql
- 분산 락
- nginx configuration
- spring session
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | ||||||
2 | 3 | 4 | 5 | 6 | 7 | 8 |
9 | 10 | 11 | 12 | 13 | 14 | 15 |
16 | 17 | 18 | 19 | 20 | 21 | 22 |
23 | 24 | 25 | 26 | 27 | 28 |
글 보관함