heartbeat.interval.ms 및 poll() 메소드 속성과 혼동 스럽습니다.Kafka10 heartbeat.interval.ms 속성
poll() 메소드를 호출 할 때 poll() 메소드가 하트 비트를 보내주기를 바랍니다. heartbeat.interval.ms가 1 초로 구성되어 있지만 poll() 메서드가 처리를 완료하는 데 2 초가 걸립니다. 2 초 후 또는 백그라운드 스레드를 통해 1 초마다 하트 비트를 보냅니 까?
heartbeat.interval.ms 및 poll() 메소드 속성과 혼동 스럽습니다.Kafka10 heartbeat.interval.ms 속성
poll() 메소드를 호출 할 때 poll() 메소드가 하트 비트를 보내주기를 바랍니다. heartbeat.interval.ms가 1 초로 구성되어 있지만 poll() 메서드가 처리를 완료하는 데 2 초가 걸립니다. 2 초 후 또는 백그라운드 스레드를 통해 1 초마다 하트 비트를 보냅니 까?
개인적으로 하트 비트 간격의 하한값은 heartbeat.interval.ms
입니다. 즉, 1 초로 설정하면 하트 비트 스레드는 하트 비트 요청을 보내기 위해 최소 1 초 동안 대기해야하지만 요청을 보내기 전에 스레드가 1.5 초 동안 대기 할 수 있습니다.
0.10.1부터는 poll
을 호출하는 사용자 스레드에서 하트 비트가 별도의 스레드로 이동하므로 더 이상 poll
개의 인터리브가 없습니다. 자세한 내용은 다음을 참조하십시오. KIP-62
0.10.1에 heartbeat.interval.ms가 있습니까? 나는 2 개의 다른 소품도 본다. session.timeout.ms, max.poll.interval.ms. 이 3과 혼동. – user1578872
참조 http://stackoverflow.com/questions/43991845/kafka10-1-heartbeat-interval-ms-session-timeout-ms-and-max-poll-interval-ms/43992308?noredirect=1 # comment75014108_43992308 또한 게시자가 게시했습니다. – amethystic