Created
February 9, 2017 18:50
-
-
Save neoeahit/3a0a5027bc3499b85cb888918faac2a3 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| DEBUG [2017-02-06 17:55:10,878] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator: Committed offset 2 for partition topic2-0 | |
| DEBUG [2017-02-06 17:55:10,878] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator: Committed offset 207100160 for partition topic1-0 | |
| TRACE [2017-02-06 17:55:10,878] org.apache.kafka.clients.consumer.internals.Fetcher: Returning fetched records at offset 207100160 for assigned partition topic1-0 and update position to 207100163 | |
| TRACE [2017-02-06 17:55:10,878] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:55:10,878] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:55:10,985] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:11,483] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:11,607] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| TRACE [2017-02-06 17:55:11,891] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator: Sending offset-commit request with {topic1-0=OffsetAndMetadata{offset=207100163, metadata=''}, topic2-0=OffsetAndMetadata{offset=2, metadata=''}} to Node(1972356116, 1.1.1.1, 9092) | |
| DEBUG [2017-02-06 17:55:14,483] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:15,216] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator: Committed offset 2 for partition topic2-0 | |
| DEBUG [2017-02-06 17:55:15,216] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator: Committed offset 207100163 for partition topic1-0 | |
| DEBUG [2017-02-06 17:55:15,589] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:17,483] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:17,618] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:20,484] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:20,606] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:23,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:23,774] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:26,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:27,322] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:29,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:29,608] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:32,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:32,612] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:35,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:35,605] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:38,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:38,606] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:41,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:41,606] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:44,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:44,606] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:47,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:47,612] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:50,486] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:50,618] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:50,923] org.apache.kafka.clients.NetworkClient: Disconnecting from node 175127531 due to request timeout. | |
| TRACE [2017-02-06 17:55:50,923] org.apache.kafka.clients.NetworkClient: Cancelled request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@5d9733af, request=RequestSend(header={api_key=1,api_version=1,correlation_id=219,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432510878, sendTimeMs=1486432510879) due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:55:50,923] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@5d9733af, request=RequestSend(header={api_key=1,api_version=1,correlation_id=219,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432510878, sendTimeMs=1486432510879) with correlation id 219 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:55:50,924] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:55:50,924] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:55:50,924] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:55:50,924] org.apache.kafka.clients.NetworkClient: Sending metadata request ClientRequest(expectResponse=true, callback=null, request=RequestSend(header={api_key=3,api_version=0,correlation_id=236,client_id=consumer-1}, body={topics=[]}), isInitiatedByNetworkClient, createdTimeMs=1486432550924, sendTimeMs=0) to node 175158673 | |
| DEBUG [2017-02-06 17:55:50,925] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@2b65a459, request=RequestSend(header={api_key=1,api_version=1,correlation_id=235,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432550924, sendTimeMs=0) with correlation id 235 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:55:50,925] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:55:50,925] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:55:50,925] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:55:51,025] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@5c88c9b2, request=RequestSend(header={api_key=1,api_version=1,correlation_id=237,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432550925, sendTimeMs=0) with correlation id 237 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:55:51,025] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:55:51,025] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:55:51,025] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:55:51,025] org.apache.kafka.clients.NetworkClient: Initiating connection to node 175127531 at 1.1.1.1:9092. | |
| DEBUG [2017-02-06 17:55:51,029] org.apache.kafka.clients.NetworkClient: Completed connection to node 175127531 | |
| DEBUG [2017-02-06 17:55:51,115] org.apache.kafka.clients.Metadata: Updated cluster metadata version 4 to Cluster(nodes = [Node(175158673, 1.1.1.6, 9092), Node(175127531, 1.1.1.1, 9092)], partitions = [Partition(topic = topic1, partition = 0, leader = 175127531, replicas = [175127531,175158673,], isr = [175127531,175158673,], Partition(topic = topic2, partition = 0, leader = 175127531, replicas = [175127531,175158673,], isr = [175127531,175158673,]]) | |
| DEBUG [2017-02-06 17:55:53,485] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:53,609] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:56,486] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:56,609] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:59,486] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:55:59,611] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:02,489] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:02,613] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:05,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:05,651] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:08,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:08,612] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:11,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:11,610] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:14,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:14,614] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:17,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:17,612] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:20,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:20,648] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:23,486] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:23,611] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:26,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:26,651] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:29,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:29,636] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:31,048] org.apache.kafka.clients.NetworkClient: Disconnecting from node 175127531 due to request timeout. | |
| TRACE [2017-02-06 17:56:31,048] org.apache.kafka.clients.NetworkClient: Cancelled request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@1dbc5088, request=RequestSend(header={api_key=1,api_version=1,correlation_id=238,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432551025, sendTimeMs=1486432551029) due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,048] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@1dbc5088, request=RequestSend(header={api_key=1,api_version=1,correlation_id=238,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432551025, sendTimeMs=1486432551029) with correlation id 238 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,049] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,049] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,049] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,049] org.apache.kafka.clients.NetworkClient: Sending metadata request ClientRequest(expectResponse=true, callback=null, request=RequestSend(header={api_key=3,api_version=0,correlation_id=253,client_id=consumer-1}, body={topics=[]}), isInitiatedByNetworkClient, createdTimeMs=1486432591049, sendTimeMs=0) to node 175158673 | |
| DEBUG [2017-02-06 17:56:31,049] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@7e3cfd4, request=RequestSend(header={api_key=1,api_version=1,correlation_id=252,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591049, sendTimeMs=0) with correlation id 252 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,049] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,049] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,049] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,070] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6120ec6a, request=RequestSend(header={api_key=1,api_version=1,correlation_id=254,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591049, sendTimeMs=0) with correlation id 254 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@116b3364, request=RequestSend(header={api_key=1,api_version=1,correlation_id=255,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591071, sendTimeMs=0) with correlation id 255 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6eac09d1, request=RequestSend(header={api_key=1,api_version=1,correlation_id=256,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591071, sendTimeMs=0) with correlation id 256 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,071] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,072] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@77a8f6bf, request=RequestSend(header={api_key=1,api_version=1,correlation_id=257,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591071, sendTimeMs=0) with correlation id 257 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,072] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,072] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,072] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,072] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@110d179c, request=RequestSend(header={api_key=1,api_version=1,correlation_id=258,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591072, sendTimeMs=0) with correlation id 258 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,072] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,072] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,073] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,073] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@5935f6ca, request=RequestSend(header={api_key=1,api_version=1,correlation_id=259,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591073, sendTimeMs=0) with correlation id 259 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,073] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,073] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,073] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,073] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@57d98ebc, request=RequestSend(header={api_key=1,api_version=1,correlation_id=260,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591073, sendTimeMs=0) with correlation id 260 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,073] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,074] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,074] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,074] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@677487f6, request=RequestSend(header={api_key=1,api_version=1,correlation_id=261,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591074, sendTimeMs=0) with correlation id 261 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,074] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,074] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,074] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,074] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6849ebc8, request=RequestSend(header={api_key=1,api_version=1,correlation_id=262,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591074, sendTimeMs=0) with correlation id 262 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,075] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,075] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,075] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,075] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@73fe2413, request=RequestSend(header={api_key=1,api_version=1,correlation_id=263,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591075, sendTimeMs=0) with correlation id 263 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,075] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,075] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,075] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,075] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@307656ad, request=RequestSend(header={api_key=1,api_version=1,correlation_id=264,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591075, sendTimeMs=0) with correlation id 264 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,076] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,076] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,076] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,076] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@4859c285, request=RequestSend(header={api_key=1,api_version=1,correlation_id=265,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591076, sendTimeMs=0) with correlation id 265 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,076] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,078] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,078] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,078] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6f6977ed, request=RequestSend(header={api_key=1,api_version=1,correlation_id=266,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591078, sendTimeMs=0) with correlation id 266 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,078] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,078] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,078] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,103] org.apache.kafka.clients.Metadata: Updated cluster metadata version 5 to Cluster(nodes = [Node(175158673, 1.1.1.6, 9092), Node(175127531, 1.1.1.1, 9092)], partitions = [Partition(topic = topic1, partition = 0, leader = 175127531, replicas = [175127531,175158673,], isr = [175127531,175158673,], Partition(topic = topic2, partition = 0, leader = 175127531, replicas = [175127531,175158673,], isr = [175127531,175158673,]]) | |
| DEBUG [2017-02-06 17:56:31,103] org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient: Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6d3518af, request=RequestSend(header={api_key=1,api_version=1,correlation_id=267,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,topics=[{topic=topic1,partitions=[{partition=0,fetch_offset=207100163,max_bytes=524288}]},{topic=topic2,partitions=[{partition=0,fetch_offset=2,max_bytes=524288}]}]}), createdTimeMs=1486432591078, sendTimeMs=0) with correlation id 267 due to node 175127531 being disconnected | |
| DEBUG [2017-02-06 17:56:31,104] org.apache.kafka.clients.consumer.internals.Fetcher: Fetch failed | |
| TRACE [2017-02-06 17:56:31,104] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic1-0 at offset 207100163 | |
| TRACE [2017-02-06 17:56:31,104] org.apache.kafka.clients.consumer.internals.Fetcher: Added fetch request for partition topic2-0 at offset 2 | |
| DEBUG [2017-02-06 17:56:31,104] org.apache.kafka.clients.NetworkClient: Initiating connection to node 175127531 at 1.1.1.1:9092. | |
| DEBUG [2017-02-06 17:56:31,108] org.apache.kafka.clients.NetworkClient: Completed connection to node 175127531 | |
| DEBUG [2017-02-06 17:56:32,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:32,614] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:35,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:35,612] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:38,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:38,613] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:41,487] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:41,617] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:44,488] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:44,630] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:47,488] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:47,613] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:50,489] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:50,622] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:53,535] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:53,613] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:56,534] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:56,637] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:59,533] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:56:59,614] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:57:02,534] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:57:02,614] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:57:05,534] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:57:05,614] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:57:08,613] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:57:08,635] org.apache.kafka.clients.consumer.internals.AbstractCoordinator: Received successful heartbeat response. | |
| DEBUG [2017-02-06 17:57:11,168] org.apache.kafka.clients.NetworkClient: Disconnecting from node 175127531 due to request timeout. | |
| TRACE [2017-02-06 17:57:11,168] org.apache.kafka.clients.NetworkClient: Cancelled request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@4dcd86de, request=RequestSend(heade |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment