카프카
-
[KAFKA] 카프카 producer configurationDB/Kafka 2022. 7. 20. 19:28
acks 란 acks는 acknowledgments의 약자로 사전에서 찾아 보면 "승인", 확인 프로듀서가 메시지를 보내고 그 메시지를 카프카가 잘 받았는지 확인을 할 것인지 또는 확인을 하지 않을 것인지를 결정하는 옵션 acks 옵션 OPTION 손실율 속도 DESCRIPTION acks = 0 상 상 프로듀서는 자신이 보낸 메시지에 대해 카프카로부터 확인을 기다리지 않는다. acks = 1 중 중 프로듀서는 자신이 보낸 메시지에 대해 카프카의 leader가 메시지를 받았는지 기다립니다. follower들은 확인하지 않습니다. leader가 확인응답을 보내고, follower에게 복제가 되기 전에 leader가 fail되면, 해당 메시지는 손실될 수 있다. acks = all(-1) 하 하 프로듀서는 ..
-
[docker] kafka docker 시작하기인프라/docker 2020. 11. 15. 23:34
local 에서 docker 를 이용햇 kafka 서버를 구축하자 docker search kafka 를 통해 검색해 보면 wurstmeister/kafka 가 스타가 제일 많다. https://hub.docker.com/r/wurstmeister/kafka -- 여기에서 kafka docker 관련 옵션 설명 확인가능하다. kafka in docker 구조 도커 카프카 네트워킹에 대한 설명 레퍼런스이다. github.com/wurstmeister/kafka-docker/wiki/Connectivity docker 로 kafka 를 올리면 다음과 같은 구조가 된다. multiple 카프카 브로커로 설정도 가능하다. 이런식으로 구성해주면 다음과 같이 9092 단일포트로 브로커가 구성된다. 단일 카프카 브로..
-
[SPRING] kafka Error registering AppInfo mbean - 스프링부트 카프카Spring/spring boot 및 기타 2020. 11. 3. 22:19
스프링 부트에서 카프카 클라이언트 라이브러리를 추가하면, 이런오류가 생긴다. Error registering AppInfo mbean 해당오류는 카프카 컨슈머 측에서만 발생한다. javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=clientid-0 at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898) at com.sun.jmx.in..