반응형

Kafka 4

[Kafka] Spring boot 에 Kafka와 Websocket을 이용한 심플 예제

오늘은 간단하게 Kafka와 Websocket을 이용하여 멀티서버에 대응할 수 있는 구조를 만들어 보려고한다. 심플하게 구동이 잘 되는지 용도이기때문에, 보안관련 Interceptor던, Kafka를 정밀하게 사용하는 코드는 없다...! 먼저 Zookeeper와 Kafka가 켜져있어야 app을 실행시킬때 오류가 나지 않는다... 궁금한것들은 하나씩 찾아보기로 하고... 우선 샘플 코드를 실행시키는데에 집중해보자..! 우선 websocket 서버를 간단하게 구축하고... 1). webSocketConfig websocket을 사용할때 필요한 설정들을 넣어주자..! @Configuration @EnableWebSocket public class WebSocketConfig implements WebSocke..

[Kafka] Windows에 Kafka 설치 및 간단한 예제

kafka download 및 간단한 topic 발행 및 consumer의 event consume을 Test해볼차례이다. Kafka url : https://kafka.apache.org/downloads Apache Kafka Apache Kafka: A Distributed Streaming Platform. kafka.apache.org kafka 버전은 관계없이 테스트해보기 위해서 받은거기때문에 상황에 맞게 버전선택을 하면 될것이다. 우선 2.8.1 버전을 받아서 원하는 위치에 설치해준다. 다운로드 후 zookeeper를 먼저 실행시켜준다. 위치는 kafka/bin/windows에 보면 있으니...! .bat file을 config 파일을 함께 구동시켜준다. ./zookeeper-server-s..

[Kafka] Kafka란? Kafka의 기본 개념

Kafka .. 요즘 개발자 공고를 보면 쉽게 볼 수 있는 기술이다. 그렇다면 Kafka가 무엇이고, 어디에 쓸수있을지 한번쯤은 생각해봐야된다!!. Kafka Document : https://kafka.apache.org/documentation/ 1). Kafka란? Pub/Sub 모델을 기반으로 한 Message Queue이다. 요즘 MSA (Micro Service Architecture)가 유행..? 처럼 자리 잡고있는데, 이때 많이 사용하고 있다. Kafka는 분산환경에 특화되어있는 특징을 가지고있다. Scalable하다. (클러스터 구성 가능하다) 2). Kafka에서 사용되는 구성요소 2-1). Event or Message Producer ( Publisher) 와 Consumer(Sub..

[Kafka] 설치시 오류 대응

Classpath is empty. Please build the project first e.g. by running 'gradlew jarAll' 위 에러의 원인은 아파치 카프카 binary 파일을 다운받고 실행시킨 것이 아니라, source 파일을 다운받고 실행시켰기 때문이다. Kafka를 다운받을 때는 kafka.apache.org/downloads 에서 binary 파일을 다운받아야한다. Kafka 홈페이지에서 Source download: kafka-2.8.1-src.tgz (asc, sha512) Binary downloads: Scala 2.12 - kafka_2.12-2.8.1.tgz (asc, sha512) Scala 2.13 - kafka_2.13-2.8.1.tgz (asc, sha5..

반응형