kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhiwei (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-4910) kafka consumer not receiving messages
Date Thu, 16 Mar 2017 14:10:42 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

zhiwei updated KAFKA-4910:
--------------------------
    Attachment:     (was: 128314.txt)

> 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
>         Attachments: 128314.jstack
>
>
> 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)

Mime
View raw message