현재 테스트 서버에 아래와 같은 Demo를 구성 하였습니다.
Nosql기반의 저장소인 Elasticsearch 에 Presto 엔진이 붙어 Elastic의 DSL쿼리를 SQL쿼리로 변환하여 데이터를 추출 후 Logstash 가 해당 Data를 Kafka의 특정 Topic에 전송 합니다.
'Kafka' 카테고리의 다른 글
| Kcat(Kafkacat) (0) | 2023.02.20 |
|---|---|
| Apache Beam (0) | 2023.01.26 |
| Apache Flume(Kafka To Hadoop) (0) | 2022.10.21 |
| Supervisor (0) | 2022.10.20 |
| Filebeat+Logstash를 통한 Nginx To Kafka (0) | 2022.10.06 |