zhiwei created KAFKA-4910:
-----------------------------
Summary: kafka consumer not receiving messages
Key: KAFKA-4910
URL: https://issues.apache.org/jira/browse/KAFKA-4910
Project: Kafka
Issue Type: Bug
Components: consumer
Affects Versions: 0.10.0.0
Reporter: zhiwei
kafka consumer not receiving messages
consumer logļ¼
"2017-03-10 14:35:34,448" | INFO | [Thread-5-KafkaSpout] | Revoking previously
assigned partitions [MAFS_BPIS_ICSWIPE_IC-0] for group data_storm_hw_tianlu |
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator
(ConsumerCoordinator.java:291)
"2017-03-10 14:35:34,451" | INFO | [Thread-5-KafkaSpout] | (Re-)joining group
data_storm_hw_tianlu |
org.apache.kafka.clients.consumer.internals.AbstractCoordinator
(AbstractCoordinator.java:326)
"2017-03-10 14:35:34,456" | INFO | [Thread-5-KafkaSpout] | Successfully joined
group data_storm_hw_tianlu with generation 7 |
org.apache.kafka.clients.consumer.internals.AbstractCoordinator
(AbstractCoordinator.java:434)
"2017-03-10 14:35:34,456" | INFO | [Thread-5-KafkaSpout] | Setting newly
assigned partitions [MAFS_BPIS_ICSWIPE_IC-0] for group data_storm_hw_tianlu |
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator
(ConsumerCoordinator.java:230)
"2017-03-10 14:36:10,297" | INFO | [Thread-7-__system] | Getting metrics for
server on port 29104 | backtype.storm.messaging.netty.Server (Server.java:321)
"2017-03-10 14:36:10,298" | INFO | [Thread-7-__system] | Getting metrics for
client connection to Netty-Client-streaming96/10.55.45.96:29106 |
backtype.storm.messaging.netty.Client (Client.java:405)
"2017-03-10 14:37:10,297" | INFO | [Thread-7-__system] | Getting metrics for
server on port 29104 | backtype.storm.messaging.netty.Server (Server.java:321)
"2017-03-10 14:37:10,298" | INFO | [Thread-7-__system] | Getting metrics for
client connection to Netty-Client-streaming96/10.55.45.96:29106 |
backtype.storm.messaging.netty.Client (Client.java:405)
"2017-03-10 14:38:10,297" | INFO | [Thread-7-__system] | Getting metrics for
server on port 29104 | backtype.storm.messaging.netty.Server (Server.java:321)
"2017-03-10 14:38:10,297" | INFO | [Thread-7-__system] | Getting metrics for
client connection to Netty-Client-streaming96/10.55.45.96:29106 |
backtype.storm.messaging.netty.Client (Client.java:405)
"2017-03-10 14:39:10,297" | INFO | [Thread-7-__system] | Getting metrics for
server on port 29104 | backtype.storm.messaging.netty.Server (Server.java:321)
"2017-03-10 14:39:10,298" | INFO | [Thread-7-__system] | Getting metrics for
client connection to Netty-Client-streaming96/10.55.45.96:29106 |
backtype.storm.messaging.netty.Client (Client.java:405)
"2017-03-10 14:40:10,298" | INFO | [Thread-7-__system] | Getting metrics for
server on port 29104 | backtype.storm.messaging.netty.Server (Server.java:321)
"2017-03-10 14:40:10,298" | INFO | [Thread-7-__system] | Getting metrics for
client connection to Netty-Client-streaming96/10.55.45.96:29106 |
backtype.storm.messaging.netty.Client (Client.java:405)
"2017-03-10 14:40:34,454" | INFO | [Thread-5-KafkaSpout] | Revoking previously
assigned partitions [MAFS_BPIS_ICSWIPE_IC-0] for group data_storm_hw_tianlu |
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator
(ConsumerCoordinator.java:291)
"2017-03-10 14:40:34,457" | INFO | [Thread-5-KafkaSpout] | (Re-)joining group
data_storm_hw_tianlu |
org.apache.kafka.clients.consumer.internals.AbstractCoordinator
(AbstractCoordinator.java:326)
"2017-03-10 14:40:36,458" | INFO | [Thread-5-KafkaSpout] | Successfully joined
group data_storm_hw_tianlu with generation 8 |
org.apache.kafka.clients.consumer.internals.AbstractCoordinator
(AbstractCoordinator.java:434)
"2017-03-10 14:40:36,459" | INFO | [Thread-5-KafkaSpout] | Setting newly
assigned partitions [MAFS_BPIS_ICSWIPE_IC-0] for group data_storm_hw_tianlu |
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator
(ConsumerCoordinator.java:230)
"2017-03-10 14:41:10,297" | INFO | [Thread-7-__system] | Getting metrics for
server on port 29104 | backtype.storm.messaging.netty.Server (Server.java:321)
"2017-03-10 14:41:10,298" | INFO | [Thread-7-__system] | Getting metrics for
client connection to Netty-Client-streaming96/10.55.45.96:29106 |
backtype.storm.messaging.netty.Client (Client.java:405)
"2017-03-10 14:42:10,297" | INFO | [Thread-7-__system] | Getting metrics for
server on port 29104 | backtype.storm.messaging.netty.Server (Server.java:321)
"2017-03-10 14:42:10,298" | INFO | [Thread-7-__system] | Getting metrics for
client connection to Netty-Client-streaming96/10.55.45.96:29106 |
backtype.storm.messaging.netty.Client (Client.java:405)
"2017-03-10 14:43:10,297" | INFO | [Thread-7-__system] | Getting metrics for
server on port 29104 | backtype.storm.messaging.netty.Server (Server.java:321)
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
