목록kafka (4)
준호씨의 블로그
얼마 전 지급받은 M1맥북에서 개발환경을 세팅하면서 겪은 이슈들을 하나씩 적어보려고 합니다. Spring Boot 2.5.xx를 사용하는 프로젝트인데 서비스를 구동시키니 다음과 같은 에러가 발생하였습니다. 2022-08-09 19:32:09.007 ERROR 34738 --- [container-0-C-1] o.s.k.l.KafkaMessageListenerContainer : Error while stopping the container: org.xerial.snappy.SnappyError: [FAILED_TO_LOAD_NATIVE_LIBRARY] no native library is found for os.name=Mac and os.arch=aarch64 ... 문구를 보면 os.name=Mac..
org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.kafka.support.converter.ConversionException: Failed to convert from JSON; nested exception is com.fasterxml.jackson.databind.exc.InvalidFormatException: Cannot deserialize value of type `kr.pe.junho85.demo.model.TestType` from String "TEST": not one of the values accepted..
Spring프로젝트에서 간단하게 KafkaListener를 구현한 예제입니다. application.yaml에 토픽 이름을 설정해 두었습니다. kafka: topic: member: member-topic 설정에 있는 토픽명을 사용하기 위해 topics = "${kafka.topic.member}"를 입력했습니다. @KafkaListener(id = "myGroupId", topics = "${kafka.topic.member}") public void kafkaListener(MessageDto messageDto) { switch (messageDto.getType()) { case REGISTER: { memberService.register(messageDto); break; } case WITH..
분산 메시징 시스템으로 유명한 카프카의 역사와 이름이 대해 간단히 알아봅시다. Kafka는 LinkedIn에서 개발되었습니다. 2009년에 상용 버전이 처음 출시된 것 같고요. (출처: https://www.youtube.com/watch?v=3F4XwgCfQc8) 2011년에 오픈소스로 공개했습니다. 2012년 10월 23일 Apache Incubator에서 졸업했습니다. 2014년 11월 링크드인에서 카프카를 개발하던 개발자 몇몇이 Confluent라는 회사를 만들었습니다. Kafka에 집중하기 위해서요. Kafka라는 이름은 개발자 중 한 명인 Jay Kreps가 지었습니다. writing에 최적화되어서 작가의 이름을 따는 게 적합하다 생각했고 카프카 작가의 작품을 좋아했기 때문이라고 합니다. 오픈..