메모장

이전 글에서 Producer를 생성하여 Message를 발행하고, Consumer를 생성하여 Message를 수신하였다. 2020/07/19 - [Kafka] - Kafka Producer를 생성하여 Message를 보내보자! (Java) Kafka Producer를 생성하여 Message를 보내보자! (Java) 먼저, 지난 글에서 IntelliJ에 Kafka 개발 환경을 구축했다. 오늘은 Kafka Producer를 생성하여 새로운 Message를 보내보겠다. 이제 새로운 Class를 만들어보자. 나는 MyKafkaProducer Class를 생성했다. 다음으.. bachong.tistory.com 2020/07/19 - [Kafka] - Kafka Consumer를 생성하여 Message를 받아보자..

이전 글에서 Kfaka Producer를 생성하여 Message를 발행해보았다. 이번 글에서는 Consumer를 생성하여 Message를 받아보도록 하겠다. 스타또~ import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.cl..

먼저, 지난 글에서 IntelliJ에 Kafka 개발 환경을 구축했다. 오늘은 Kafka Producer를 생성하여 새로운 Message를 보내보겠다. 이제 새로운 Class를 만들어보자. 나는 MyKafkaProducer Class를 생성했다. 다음으로, 코드를 짜보자. 나는 '카프카, 데이터플랫폼의 최강자-실시간 비동기 스트리밍 솔루션 Kafka의 기본부터 확장 응용까지' 라는 책을 참고했다. import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; import jav..

Kafka 개발환경 구축에 관한 다른 블로그들의 글을 읽어보면, Spring boot로 생성하라고 하는데.. 나는 어디에서도 Spring Boot를 볼 수 없었다. Plug-in에 검색해도 나오지 않았다. 그 이유를 찾고보니 IntelliJ community 버전은 지원하지 않는 것 같다.ㅠㅠ 검색 결과, 다음 사이트에서 Spring boot 프로젝트를 생성할 수 있었다. https://start.spring.io/ 나는 Gradle프로젝트를 생성했고, ADD DEPENDENCIES 버튼을 눌러 다음과 같이 구성하였다. 설정을 한 후에 GENERATE 버튼을 눌러 프로젝트 압축 파일을 다운받는다. 파일은 다운로드 디렉토리에 받아지고, 나는 IntelliJ workspace에 압축을 풀었다. 이제 Inte..

이번 글에서는 Topic, Producer를 생성하여 Message를 보내고, Consumer를 생성하여 Message를 받아보겠다. 1. Topic 생성 및 Message 발행하기 1) Topic 생성 다음과 같은 명령어로 Topic을 생성한다. 토픽 명 tp-song으로 새로운 topic을 생성했다. topic명은 아무거나 입력해도 상관없다. 장비가 1대이기 때문에 replication-factor와 partitions를 1로 설정했다. .\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic [토픽명] 토픽을 정상적으로 생성하면 Created topic [토픽명] ..

1. Kafka 설치 https://www.apache.org/dyn/closer.cgi?path=/kafka/2.5.0/kafka_2.12-2.5.0.tgz Apache Download Mirrors Copyright © 2019 The Apache Software Foundation, Licensed under the Apache License, Version 2.0. Apache and the Apache feather logo are trademarks of The Apache Software Foundation. www.apache.org 위 링크에서 Kafka를 설치한다. 2. 설치한 Kafka 압축 파일을 원하는 위치에 풀어준다. 바총이는 C드라이브에 풀었다. 3. Zookeeper를 실행하..

문제 설명문자열로 구성된 리스트 strings와, 정수 n이 주어졌을 때, 각 문자열의 인덱스 n번째 글자를 기준으로 오름차순 정렬하려 합니다. 예를 들어 strings가 [sun, bed, car]이고 n이 1이면 각 단어의 인덱스 1의 문자 u, e, a로 strings를 정렬합니다. 제한 조건strings는 길이 1 이상, 50이하인 배열입니다.strings의 원소는 소문자 알파벳으로 이루어져 있습니다.strings의 원소는 길이 1 이상, 100이하인 문자열입니다.모든 strings의 원소의 길이는 n보다 큽니다.인덱스 1의 문자가 같은 문자열이 여럿 일 경우, 사전순으로 앞선 문자열이 앞쪽에 위치합니다.입출력 예 입출력 예 설명입출력 예 1 sun, bed, car의 1번째 인덱스 값은 각각 u..

문제 설명 수평 직선에 탑 N대를 세웠습니다. 모든 탑의 꼭대기에는 신호를 송/수신하는 장치를 설치했습니다. 발사한 신호는 신호를 보낸 탑보다 높은 탑에서만 수신합니다. 또한, 한 번 수신된 신호는 다른 탑으로 송신되지 않습니다.예를 들어 높이가 6, 9, 5, 7, 4인 다섯 탑이 왼쪽으로 동시에 레이저 신호를 발사합니다. 그러면, 탑은 다음과 같이 신호를 주고받습니다. 높이가 4인 다섯 번째 탑에서 발사한 신호는 높이가 7인 네 번째 탑이 수신하고, 높이가 7인 네 번째 탑의 신호는 높이가 9인 두 번째 탑이, 높이가 5인 세 번째 탑의 신호도 높이가 9인 두 번째 탑이 수신합니다. 높이가 9인 두 번째 탑과 높이가 6인 첫 번째 탑이 보낸 레이저 신호는 어떤 탑에서도 수신할 수 없습니다. 맨 왼쪽부..