Notice
Recent Posts
Recent Comments
Link
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
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 |
Tags
- 카프카
- statestore
- gradle
- reactive
- kafkastreams
- schema registry
- avo
- spring-batch
- coursera
- RabbitMQ
- scala
- 플레이 프레임워크
- spring-kafka
- Logstash
- springboot
- aws
- confluent
- 한빛미디어
- kafka interactive query
- Elasticsearch
- spring-cloud-stream
- Slick
- Elk
- scala 2.10
- play framework
- enablekafkastreams
- kafkastream
- Spring
- Kafka
- kafka streams
Archives
- Today
- Total
목록kafka elapsed timem (1)
b
카프카 메시지간의 event time 측정하기 logstash elapsed plugin
현재 업무에서 메지시의 상태는 하나의 필드로 정의하고 있다. 예를 들어 결제 요청이 들어오면 APPROVAL_REQUESTED:type 을 정의하여 payment topic에 적재하고 이 후 저 메시지를 컨슘하여 결제가 완료된다면 '동일한 토픽에' APPROVAL_COMPLETED:type 으로 하나의 메시지를 추가한다.즉, APPROVAL_REQUESTED 상태는 APPROVAL_COMPLETED or APPROVAL_FAILED 상태로 변경 가능하다.각각은 Kafka에 의해 Header에 event time이 기록되어 있지만, 별개로 actBy라는 timestamp 필드도 추가하였다. REQUESTED 상태에서 COMPLETED 상태로 변경되기까지의 시간을 어떻게 측정할 것인가? 무난한 방법으로 하나..
카테고리 없음
2018. 7. 30. 19:33