Kafka 는 분산 스트리밍 플랫폼. Stream 형태의 데이터를 발행하고 구독할 수 있도록 한다. (메시지 큐 또는 기업형 메시징 시스템과 비슷하다.)결함 또는 고장이 발생하여도 정상적 혹은 부분적으로 기능을 수행할 수 있는 시스템.데이터가 발생했을때 처리가 가능하다. Kafka의 장점시스템 또는 어플리케이션이 확실하게 데이터를 얻을 수 있도록 데이터 파이프라인 설계에 용이하다.스트림 데이터를 전송하는 실시간 스트리밍 어플리케이션 설계에 용이하다. Kafka 개념Kafka 는 한대 혹은 여러대의 서버로 클러스터링 되어 운영된다.카프카 클러스터는 ‘record’ 스트림 데이터를 ‘토픽’이라는 카테고리로 저장한다.각 record 는 [key, value, timestamp] 로 구성된다.Producer A..
1. https://www.apache.org/dyn/closer.cgi?path=/kafka/0.11.0.0/kafka_2.11-0.11.0.0.tgz 에서 0.11.0 버전 다운로드2.tar -xzf kafka_2.11-0.11.0.0.tgz - 압출풀기3.Kafka 서버 구동 - Kafka 는 주키퍼 서버를 사용하기 때문에 주키퍼 서버를 먼저 시작해야 한다. ( bin/zookeeper-server-start.sh config/zookeeper.properties ) - Kafka 서버 시작 ( bin/kafka-server-start.sh config/server.properties )4. Topic 생성 - 'test' 라는 이름의 토픽을 생성한다. ( bin/kafka-topics.sh --c..
- Total
- Today
- Yesterday
- spring cloud gateway
- circurit breaker
- HashMap
- dynamodb
- RoutePredication
- ResultSet
- aurora
- GlobalFilter
- referencedColumnName
- Flux
- reactor
- DyanomoDB
- rate limit
- wait()
- msyql-connector-java
- N+1
- reative
- AbstractMethodError
- mariada-connector
- router
- Lazy
- RouteDefinition
- ConcurrentHashMap
- mariadb-connector-j
- getBoolean
- notify()
- Seperate Chaining
- MariaDB
- custom config data convertion
- notifyAll()
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
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 |