Skip to content

Instantly share code, notes, and snippets.

@dmitrig01
Created March 24, 2015 00:56
Show Gist options
  • Save dmitrig01/e58fb5aef70b0f7a193c to your computer and use it in GitHub Desktop.
Save dmitrig01/e58fb5aef70b0f7a193c to your computer and use it in GitHub Desktop.
2015-03-23 17:54:29,270 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:29,281 INFO kafka.utils.VerifiableProperties: Property auto.commit.interval.ms is overridden to 1000
2015-03-23 17:54:29,282 INFO kafka.utils.VerifiableProperties: Property group.id is overridden to test2
2015-03-23 17:54:29,282 INFO kafka.utils.VerifiableProperties: Property zookeeper.connect is overridden to 987.65.43.21
2015-03-23 17:54:29,282 INFO kafka.utils.VerifiableProperties: Property zookeeper.session.timeout.ms is overridden to 400
2015-03-23 17:54:29,282 INFO kafka.utils.VerifiableProperties: Property zookeeper.sync.time.ms is overridden to 200
2015-03-23 17:54:29,381 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], Connecting to zookeeper instance at 987.65.43.21
2015-03-23 17:54:29,389 INFO org.I0Itec.zkclient.ZkEventThread: Starting ZkClient event thread.
2015-03-23 17:54:29,640 INFO org.I0Itec.zkclient.ZkClient: zookeeper state changed (SyncConnected)
2015-03-23 17:54:29,658 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], starting auto committer every 1000 ms
2015-03-23 17:54:29,698 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], begin registering consumer test2_Archimedes-1427158469379-dffc35b3 in ZK
2015-03-23 17:54:29,756 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], end registering consumer test2_Archimedes-1427158469379-dffc35b3 in ZK
2015-03-23 17:54:29,759 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], starting watcher executor thread for consumer test2_Archimedes-1427158469379-dffc35b3
2015-03-23 17:54:29,871 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], begin rebalancing consumer test2_Archimedes-1427158469379-dffc35b3 try #0
2015-03-23 17:54:30,398 INFO kafka.consumer.ConsumerFetcherManager: [ConsumerFetcherManager-1427158469645] Stopping leader finder thread
2015-03-23 17:54:30,398 INFO kafka.consumer.ConsumerFetcherManager: [ConsumerFetcherManager-1427158469645] Stopping all fetchers
2015-03-23 17:54:30,399 INFO kafka.consumer.ConsumerFetcherManager: [ConsumerFetcherManager-1427158469645] All connections stopped
2015-03-23 17:54:30,400 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], Cleared all relevant queues for this fetcher
2015-03-23 17:54:30,401 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], Cleared the data chunks in all the consumer message iterators
2015-03-23 17:54:30,401 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], Committing all offsets after clearing the fetcher queues
2015-03-23 17:54:30,402 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], Releasing partition ownership
2015-03-23 17:54:30,403 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], Consumer test2_Archimedes-1427158469379-dffc35b3 rebalancing the following partitions: ArrayBuffer(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15) for topic session-open with consumers: List(test2_Archimedes-1427158469379-dffc35b3-0, test2_Archimedes-1427158469379-dffc35b3-1, test2_Archimedes-1427158469379-dffc35b3-2, test2_Archimedes-1427158469379-dffc35b3-3)
2015-03-23 17:54:30,405 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-2 attempting to claim partition 8
2015-03-23 17:54:30,462 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-2 attempting to claim partition 9
2015-03-23 17:54:30,496 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-2 attempting to claim partition 10
2015-03-23 17:54:30,534 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-2 attempting to claim partition 11
2015-03-23 17:54:30,560 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-3 attempting to claim partition 12
2015-03-23 17:54:30,604 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-3 attempting to claim partition 13
2015-03-23 17:54:30,654 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-3 attempting to claim partition 14
2015-03-23 17:54:30,687 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-3 attempting to claim partition 15
2015-03-23 17:54:30,734 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-0 attempting to claim partition 0
2015-03-23 17:54:30,765 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-0 attempting to claim partition 1
2015-03-23 17:54:30,812 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-0 attempting to claim partition 2
2015-03-23 17:54:30,848 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-0 attempting to claim partition 3
2015-03-23 17:54:30,872 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-1 attempting to claim partition 4
2015-03-23 17:54:30,907 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-1 attempting to claim partition 5
2015-03-23 17:54:30,936 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-1 attempting to claim partition 6
2015-03-23 17:54:30,963 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-1 attempting to claim partition 7
2015-03-23 17:54:31,061 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-3 successfully owned partition 12 for topic session-open
2015-03-23 17:54:31,093 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-2 successfully owned partition 9 for topic session-open
2015-03-23 17:54:31,120 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-3 successfully owned partition 15 for topic session-open
2015-03-23 17:54:31,150 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-3 successfully owned partition 13 for topic session-open
2015-03-23 17:54:31,179 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-2 successfully owned partition 8 for topic session-open
2015-03-23 17:54:31,240 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-0 successfully owned partition 0 for topic session-open
2015-03-23 17:54:31,284 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-1 successfully owned partition 6 for topic session-open
2015-03-23 17:54:31,309 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-3 successfully owned partition 14 for topic session-open
2015-03-23 17:54:31,336 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-0 successfully owned partition 3 for topic session-open
2015-03-23 17:54:31,370 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-1 successfully owned partition 7 for topic session-open
2015-03-23 17:54:31,398 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-0 successfully owned partition 1 for topic session-open
2015-03-23 17:54:31,427 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-0 successfully owned partition 2 for topic session-open
2015-03-23 17:54:31,454 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-2 successfully owned partition 10 for topic session-open
2015-03-23 17:54:31,490 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-2 successfully owned partition 11 for topic session-open
2015-03-23 17:54:31,563 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-1 successfully owned partition 4 for topic session-open
2015-03-23 17:54:31,581 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], test2_Archimedes-1427158469379-dffc35b3-1 successfully owned partition 5 for topic session-open
2015-03-23 17:54:31,582 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], Updating the cache
2015-03-23 17:54:31,586 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], Consumer test2_Archimedes-1427158469379-dffc35b3 selected partitions : session-open:0: fetched offset = -1: consumed offset = -1,session-open:1: fetched offset = -1: consumed offset = -1,session-open:2: fetched offset = -1: consumed offset = -1,session-open:3: fetched offset = -1: consumed offset = -1,session-open:4: fetched offset = -1: consumed offset = -1,session-open:5: fetched offset = -1: consumed offset = -1,session-open:6: fetched offset = -1: consumed offset = -1,session-open:7: fetched offset = -1: consumed offset = -1,session-open:8: fetched offset = -1: consumed offset = -1,session-open:9: fetched offset = -1: consumed offset = -1,session-open:10: fetched offset = -1: consumed offset = -1,session-open:11: fetched offset = -1: consumed offset = -1,session-open:12: fetched offset = -1: consumed offset = -1,session-open:13: fetched offset = -1: consumed offset = -1,session-open:14: fetched offset = -1: consumed offset = -1,session-open:15: fetched offset = -1: consumed offset = -1
2015-03-23 17:54:31,587 INFO kafka.consumer.ConsumerFetcherManager$LeaderFinderThread: [test2_Archimedes-1427158469379-dffc35b3-leader-finder-thread], Starting
2015-03-23 17:54:31,589 INFO kafka.consumer.ZookeeperConsumerConnector: [test2_Archimedes-1427158469379-dffc35b3], end rebalancing consumer test2_Archimedes-1427158469379-dffc35b3 try #0
2015-03-23 17:54:31,646 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:31,646 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:31,647 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:31,647 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:31,663 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 0 for 1 topic(s) Set(session-open)
2015-03-23 17:54:31,689 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:31,746 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:32,004 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:32,004 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:32,004 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:32,004 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:32,005 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 1 for 1 topic(s) Set(session-open)
2015-03-23 17:54:32,056 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:32,092 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:32,369 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:32,370 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:32,370 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:32,370 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:32,370 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 2 for 1 topic(s) Set(session-open)
2015-03-23 17:54:32,406 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:32,461 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:32,770 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:32,770 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:32,770 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:32,770 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:32,771 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 3 for 1 topic(s) Set(session-open)
2015-03-23 17:54:32,811 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:32,854 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:33,130 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:33,131 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:33,131 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:33,131 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:33,131 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 4 for 1 topic(s) Set(session-open)
2015-03-23 17:54:33,155 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:33,192 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:33,445 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:33,446 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:33,446 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:33,446 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:33,446 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 5 for 1 topic(s) Set(session-open)
2015-03-23 17:54:33,498 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:33,534 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:33,812 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:33,812 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:33,812 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:33,812 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:33,813 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 6 for 1 topic(s) Set(session-open)
2015-03-23 17:54:33,866 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:33,904 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:34,172 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:34,172 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:34,172 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:34,172 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:34,173 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 7 for 1 topic(s) Set(session-open)
2015-03-23 17:54:34,198 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:34,265 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:34,543 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:34,543 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:34,543 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:34,543 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:34,544 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 8 for 1 topic(s) Set(session-open)
2015-03-23 17:54:34,568 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:34,601 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:34,882 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:34,883 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:34,883 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:34,883 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:34,883 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 9 for 1 topic(s) Set(session-open)
2015-03-23 17:54:34,953 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:34,986 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:35,295 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:35,295 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:35,295 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:35,295 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:35,296 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 10 for 1 topic(s) Set(session-open)
2015-03-23 17:54:35,346 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:35,405 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:35,861 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:35,861 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:35,862 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:35,862 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:35,862 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 11 for 1 topic(s) Set(session-open)
2015-03-23 17:54:35,916 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:35,959 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:36,238 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:36,238 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:36,238 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:36,238 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:36,239 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 12 for 1 topic(s) Set(session-open)
2015-03-23 17:54:36,261 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:36,337 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:36,665 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:36,665 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:36,665 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:36,666 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:36,666 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 13 for 1 topic(s) Set(session-open)
2015-03-23 17:54:36,689 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:36,734 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:36,990 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:36,991 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:36,991 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:36,991 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:36,991 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 14 for 1 topic(s) Set(session-open)
2015-03-23 17:54:37,015 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:37,041 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:37,352 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:37,353 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:37,353 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:37,353 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:37,353 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 15 for 1 topic(s) Set(session-open)
2015-03-23 17:54:37,376 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:37,423 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:37,701 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:37,701 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:37,702 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:37,702 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:37,702 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 16 for 1 topic(s) Set(session-open)
2015-03-23 17:54:37,753 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:37,809 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:38,091 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:38,091 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:38,091 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:38,091 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:38,092 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 17 for 1 topic(s) Set(session-open)
2015-03-23 17:54:38,160 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:38,197 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:38,508 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:38,508 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:38,509 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:38,509 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:38,509 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 18 for 1 topic(s) Set(session-open)
2015-03-23 17:54:38,553 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
2015-03-23 17:54:38,641 INFO kafka.producer.SyncProducer: Disconnecting from 12.34.56.789:9092
2015-03-23 17:54:38,936 INFO kafka.utils.VerifiableProperties: Verifying properties
2015-03-23 17:54:38,936 INFO kafka.utils.VerifiableProperties: Property metadata.broker.list is overridden to 12.34.56.789:9092
2015-03-23 17:54:38,937 INFO kafka.utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
2015-03-23 17:54:38,937 INFO kafka.utils.VerifiableProperties: Property client.id is overridden to test2
2015-03-23 17:54:38,937 INFO kafka.client.ClientUtils$: Fetching metadata from broker id:1,host:12.34.56.789,port:9092 with correlation id 19 for 1 topic(s) Set(session-open)
2015-03-23 17:54:38,979 INFO kafka.producer.SyncProducer: Connected to 12.34.56.789:9092 for producing
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment