kafka
-
[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) 하 하 프로듀서는 ..
-
[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..