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