| 일 | 월 | 화 | 수 | 목 | 금 | 토 |
|---|---|---|---|---|---|---|
| 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 |
- 항해99
- EC2
- 스웨거
- visualvm
- 스프링의 정석
- MYSQL
- 데이터베이스
- 스파르타코딩클럽
- @jsonproperty
- AWS
- 생성자 주입
- 카프카
- 시큐리티
- emqx
- Spring Security
- JavaScript
- 프로그래머스
- Kafka
- java
- 남궁성과 끝까지 간다
- 쇼트유알엘
- 개인프로젝트
- 패스트캠퍼스
- 웹개발
- DB
- docker
- JWT
- WEB SOCKET
- CentOS
- Spring
- Today
- Total
목록kafka streams (2)
Nellie's Blog
[Kafka] 카프카 컨슈머에서 받은 데이터 MariaDB로 전송하기
카프카 스트림즈로 필터링된 토픽을 컨슈밍하는 컨슈머를 만들고, 그 컨슈머에서 받은 데이터를 DB로 insert하도록 하는 기능을 구현했다. 카프카 커넥트로 하려고 했으나, 번거로워서 직접 컨슈머 코드 안에서 dao를 사용하여 db에 접근하여 insert 하도록 했다. 전체 코드이다. 프로듀서import org.apache.kafka.clients.producer.*;import java.util.Properties;public class KafkaProducerTest { /** * SASL 인증을 위한 JAAS Template */ private static final String JAAS_TEMPLATE = "org.apache.kafka.common.security.s..
[Kafka] 스프링 부트에 Kafka Streams 적용하기
카프카 스트림즈(Kafka Streams)란? 카프카 스트림즈란 연속적인 이벤트 스트림이 들어올때마다 그때그때 처리하고 분석하여 의미있는 정보를 추출하고 실시간으로 작업을 처리하는 자바 라이브러리 기능이다. 이전에는 카프카 컨슈머 및 프로듀서 조합으로 필터링하여 다시 토픽에 넘겨주는 작업을 해주었지만 카프카 스트림즈는 매우 간단한 스트림즈 DSL 이란 기능으로 강력한 필터링 기능을 제공한다. 아래 그림으로 비교를 해보자. 기존의 필터링 방식 카프카 스트림즈를 이용한 필터링 방식또한 내장 DB 인 Rocks DB를 이용하여 key-value Store 기능도 제공한다. 2. 카프카 스트림즈 예제 코드 간단한 스프링부트 코드로 스트림즈 예제를 실습해보았다. 1. 스트림즈 DSL 라이브러리 ..