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