![](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 session
- annotation
- mysql
- transaction
- NeXTSTEP
- nginx configuration
- Java
- 카프카
- 람다
- spring webflux
- redis session
- 분산 락
- TDD
- Synchronized
- nginx
- socket
- mdcfilter
- pessimistic lock
- 트랜잭션
- postgresql
- sql
- Kafka
- jvm 메모리 구조
- 구름톤챌린지
- 네티 스레딩 모델
- 구름톤 챌린지
- 자바 네티
- 넥스트스탭
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
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 |
글 보관함