Почему мы неожиданно завершаем работу (kafka.server.ReplicaFetcherThread) - PullRequest
0 голосов
/ 17 января 2019

мы имеем версию 2.6.5 hadoop с 3 машинами kafka

брокерами кафки являются - 101, 102, 103

из server.log в / var / log / kafka, мы увидели сообщение о

Shutting down

Shutdown completed

это сообщения не потому, что мы останавливаем брокера kafka, и мы много раз видим это поведение

[2019-01-15 12:50:24,416] INFO Partition [part_hgl.gtp.state,76] on broker 101: Expanding ISR for partition [part_hgl.gtp.state,76] from 101,102 to 101,102,103 (kafka.cluster.Partition)
[2019-01-15 12:50:24,417] INFO Partition [part_hgl.gtp.state,67] on broker 101: Expanding ISR for partition [part_hgl.gtp.state,67] from 101,102 to 101,102,103 (kafka.cluster.Partition)
[2019-01-15 12:50:24,417] INFO [ReplicaFetcherThread-0-103], Shutting down (kafka.server.ReplicaFetcherThread)

[2019-01-15 12:50:24,418] INFO Partition [part_hgl.gtp.state,73] on broker 101: Expanding ISR for partition [part_hgl.gtp.state,73] from 101,102 to 101,102,103 (kafka.cluster.Partition)
[2019-01-15 12:50:24,419] INFO Partition [part_hgl.gtp.state,13] on broker 101: Expanding ISR for partition [part_hgl.gtp.state,13] from 101,102 to 101,102,103 (kafka.cluster.Partition)
[2019-01-15 12:50:24,419] INFO [ReplicaFetcherThread-0-103], Shutdown completed (kafka.server.ReplicaFetcherThread)
[2019-01-15 12:50:24,419] INFO [ReplicaFetcherThread-0-103], Stopped  (kafka.server.ReplicaFetcherThread)

как мы можем это объяснить?

почему брокер кафки (103) закрывается?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...