程序设置的是启动10个kafka线程,消息存入kafka以后消费时kafka-coordinator-heartbeat-thread出现Blocked,这个现象是正常的吗?
kafka-coordinator-heartbeat-thread | wxadapter State: BLOCKED tid: 114
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.disableWakeups() ConsumerNetworkClient.java:409
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.pollNoWakeup() ConsumerNetworkClient.java:264
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run() AbstractCoordinator.java:864
kafka-coordinator-heartbeat-thread | wxadapter State: BLOCKED tid: 114
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.disableWakeups() ConsumerNetworkClient.java:409
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.pollNoWakeup() ConsumerNetworkClient.java:264
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run() AbstractCoordinator.java:864
0 个回复