kafka-influxd_echo_encoder_test.log

gistfile1.txt

root@contrib-jessie:~# kafka_influxdb -c /root/kafka-influxdb.yaml -vvv
kafka_influxdb -c /root/kafka-influxdb.yaml -vvv
Reading config file /root/kafka-influxdb.yaml
INFO:root:Connecting to InfluxDB at influxdb:8086
INFO:root:Connecting to InfluxDB at influxdb:8086 (SSL: False, UDP: False)
INFO:root:Creating database metrics if not exists
INFO:root:Creating InfluxDB database if not exists: metrics
INFO:urllib3.connectionpool:Starting new HTTP connection (1): influxdb
INFO:urllib3.connectionpool:Starting new HTTP connection (2): influxdb
INFO:urllib3.connectionpool:Starting new HTTP connection (3): influxdb
INFO:root:('Connection aborted.', gaierror(-2, 'Name or service not known'))
INFO:root:Listening for messages on Kafka topic kafka...
INFO:root:Connecting to Kafka at localhost:9092...
DEBUG:kafka.metrics.metrics:Added sensor with name connections-closed
DEBUG:kafka.metrics.metrics:Added sensor with name connections-created
DEBUG:kafka.metrics.metrics:Added sensor with name select-time
DEBUG:kafka.metrics.metrics:Added sensor with name io-time
DEBUG:kafka.client:Attempting to bootstrap via node at localhost:9092
DEBUG:kafka.metrics.metrics:Added sensor with name bytes-sent-received
DEBUG:kafka.metrics.metrics:Added sensor with name bytes-sent
DEBUG:kafka.metrics.metrics:Added sensor with name bytes-received
DEBUG:kafka.metrics.metrics:Added sensor with name request-latency
DEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap.bytes-sent
DEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap.bytes-received
DEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap.latency
DEBUG:kafka.conn:<BrokerConnection host=localhost/localhost port=9092>: creating new socket
DEBUG:kafka.conn:<BrokerConnection host=localhost/::1 port=9092>: established TCP connection
DEBUG:kafka.client:Node bootstrap connected
DEBUG:kafka.conn:<BrokerConnection host=localhost/::1 port=9092> Request 1: MetadataRequest_v0(topics=[])
DEBUG:kafka.conn:<BrokerConnection host=localhost/::1 port=9092> Response 1: MetadataResponse_v0(brokers=[(node_id=0, host=u'192.168.0.4', port=9092)], topics=[(error_code=0, topic=u'my_topic', partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])]), (error_code=0, topic=u'__consumer_offsets', partitions=[(error_code=0, partition=23, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=41, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=32, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=17, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=8, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=35, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=44, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=26, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=11, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=29, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=38, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=47, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=20, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=2, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=5, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=14, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=46, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=40, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=49, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=13, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=4, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=31, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=22, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=16, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=7, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=43, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=25, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=34, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=10, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=37, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=1, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=19, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=28, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=45, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=27, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=36, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=18, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=9, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=21, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=48, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=12, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=3, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=30, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=39, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=15, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=42, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=33, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=6, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=24, leader=0, replicas=[0], isr=[0]), (error_code=0, partition=0, leader=0, replicas=[0], isr=[0])]), (error_code=0, topic=u'kafka', partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])]), (error_code=0, topic=u'TutorialTopic', partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])]), (error_code=0, topic=u'metrics', partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])])])
DEBUG:kafka.cluster:Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 5, groups: 0)
DEBUG:kafka.client:Initiating connection to node 0 at 192.168.0.4:9092
DEBUG:kafka.metrics.metrics:Added sensor with name node-0.bytes-sent
DEBUG:kafka.metrics.metrics:Added sensor with name node-0.bytes-received
DEBUG:kafka.metrics.metrics:Added sensor with name node-0.latency
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092>: creating new socket
DEBUG:kafka.client:Node 0 connected
INFO:kafka.conn:Broker version identifed as 0.10
INFO:kafka.conn:Set configuration api_version=(0, 10) to skip auto check_version requests on startup
DEBUG:kafka.metrics.metrics:Added sensor with name bytes-fetched
DEBUG:kafka.metrics.metrics:Added sensor with name records-fetched
DEBUG:kafka.metrics.metrics:Added sensor with name fetch-latency
DEBUG:kafka.metrics.metrics:Added sensor with name records-lag
DEBUG:kafka.metrics.metrics:Added sensor with name fetch-throttle-time
DEBUG:kafka.metrics.metrics:Added sensor with name heartbeat-latency
DEBUG:kafka.metrics.metrics:Added sensor with name join-latency
DEBUG:kafka.metrics.metrics:Added sensor with name sync-latency
DEBUG:kafka.metrics.metrics:Added sensor with name commit-latency
INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('kafka',)
DEBUG:kafka.coordinator:Sending group coordinator request for group kafka-influxdb to broker 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 3: GroupCoordinatorRequest_v0(consumer_group='kafka-influxdb')
DEBUG:kafka.client:Sending metadata request MetadataRequest_v1(topics=['kafka']) to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 4: MetadataRequest_v1(topics=['kafka'])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 3: GroupCoordinatorResponse_v0(error_code=0, coordinator_id=0, host=u'192.168.0.4', port=9092)
DEBUG:kafka.coordinator:Received group coordinator response GroupCoordinatorResponse_v0(error_code=0, coordinator_id=0, host=u'192.168.0.4', port=9092)
DEBUG:kafka.cluster:Updating coordinator for kafka-influxdb: GroupCoordinatorResponse_v0(error_code=0, coordinator_id=0, host=u'192.168.0.4', port=9092)
INFO:kafka.cluster:Group coordinator for kafka-influxdb is BrokerMetadata(nodeId=0, host=u'192.168.0.4', port=9092, rack=None)
INFO:kafka.coordinator:Discovered coordinator 0 for group kafka-influxdb
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 4: MetadataResponse_v1(brokers=[(node_id=0, host=u'192.168.0.4', port=9092, rack=None)], controller_id=0, topics=[(error_code=0, topic=u'kafka', is_internal=False, partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])])])
DEBUG:kafka.cluster:Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 1)
INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set([]) for group kafka-influxdb
INFO:kafka.coordinator:(Re-)joining group kafka-influxdb
DEBUG:kafka.coordinator:Sending JoinGroup (JoinGroupRequest_v0(group='kafka-influxdb', session_timeout=30000, member_id='', protocol_type='consumer', group_protocols=[(protocol_name='range', protocol_metadata='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x00'), (protocol_name='roundrobin', protocol_metadata='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x00')])) to coordinator 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 5: JoinGroupRequest_v0(group='kafka-influxdb', session_timeout=30000, member_id='', protocol_type='consumer', group_protocols=[(protocol_name='range', protocol_metadata='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x00'), (protocol_name='roundrobin', protocol_metadata='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x00')])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 5: JoinGroupResponse_v0(error_code=0, generation_id=1, group_protocol=u'range', leader_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', members=[(member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', member_metadata='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x00')])
DEBUG:kafka.coordinator:Received successful JoinGroup response for group kafka-influxdb: JoinGroupResponse_v0(error_code=0, generation_id=1, group_protocol=u'range', leader_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', members=[(member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', member_metadata='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x00')])
INFO:kafka.coordinator:Joined group 'kafka-influxdb' (generation 1) with member_id kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882
INFO:kafka.coordinator:Elected group leader -- performing partition assignments using range
DEBUG:kafka.coordinator.consumer:Performing assignment for group kafka-influxdb using strategy range with subscriptions {u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882': ConsumerProtocolMemberMetadata(version=0, subscription=[u'kafka'], user_data='')}
DEBUG:kafka.coordinator.consumer:Finished assignment for group kafka-influxdb: {u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882': ConsumerProtocolMemberAssignment(version=0, assignment=[(topic=u'kafka', partitions=[0])], user_data='')}
DEBUG:kafka.coordinator:Sending leader SyncGroup for group kafka-influxdb to coordinator 0: SyncGroupRequest_v0(group='kafka-influxdb', generation_id=1, member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', group_assignment=[(member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', member_metadata='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00\x00')])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 6: SyncGroupRequest_v0(group='kafka-influxdb', generation_id=1, member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', group_assignment=[(member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', member_metadata='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00\x00')])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 6: SyncGroupResponse_v0(error_code=0, member_assignment='\x00\x00\x00\x00\x00\x01\x00\x05kafka\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00\x00')
INFO:kafka.coordinator:Successfully joined group kafka-influxdb with generation 1
INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic=u'kafka', partition=0)]
INFO:kafka.coordinator.consumer:Setting newly assigned partitions set([TopicPartition(topic=u'kafka', partition=0)]) for group kafka-influxdb
DEBUG:kafka.coordinator.consumer:Group kafka-influxdb fetching committed offsets for partitions: set([TopicPartition(topic=u'kafka', partition=0)])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 7: OffsetFetchRequest_v1(consumer_group='kafka-influxdb', topics=[(topic=u'kafka', partitions=[0])])
DEBUG:kafka.coordinator:Heartbeat task unneeded now, retrying in 2.999117136
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 7: OffsetFetchResponse_v1(topics=[(topic=u'kafka', partitions=[(partition=0, offset=42, metadata=u'', error_code=0)])])
DEBUG:kafka.consumer.fetcher:Resetting offset for partition TopicPartition(topic=u'kafka', partition=0) to the committed offset 42
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 42
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 8: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=42, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 8: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=['(offset=42, message=9380)', '(offset=43, message=9394)', '(offset=44, message=9397)'])])])
DEBUG:kafka.consumer.fetcher:Adding fetched record for partition TopicPartition(topic=u'kafka', partition=0) with offset 42 to buffered record list
DEBUG:kafka.metrics.metrics:Added sensor with name topic.kafka.bytes-fetched
DEBUG:kafka.metrics.metrics:Added sensor with name topic.kafka.records-fetched
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 9: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.client:Sending metadata request MetadataRequest_v1(topics=['kafka']) to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 10: MetadataRequest_v1(topics=['kafka'])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 9: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 10: MetadataResponse_v1(brokers=[(node_id=0, host=u'192.168.0.4', port=9092, rack=None)], controller_id=0, topics=[(error_code=0, topic=u'kafka', is_internal=False, partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])])])
DEBUG:kafka.cluster:Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 1)
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 11: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 11: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 12: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 12: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 13: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 13: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 14: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 14: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 15: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.coordinator:Heartbeat: kafka-influxdb[1] kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 16: HeartbeatRequest_v0(group='kafka-influxdb', generation_id=1, member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882')
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 15: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 16: HeartbeatResponse_v0(error_code=0)
DEBUG:kafka.coordinator:Received successful heartbeat response for group kafka-influxdb
DEBUG:kafka.coordinator:Received successful heartbeat
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 17: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 17: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 18: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 18: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 19: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 19: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 20: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.coordinator.consumer:Sending offset-commit request with {TopicPartition(topic=u'kafka', partition=0): OffsetAndMetadata(offset=45, metadata='')} for group kafka-influxdb to 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 21: OffsetCommitRequest_v2(consumer_group='kafka-influxdb', consumer_group_generation_id=1, consumer_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882', retention_time=-1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, metadata='')])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 20: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 21: OffsetCommitResponse_v2(topics=[(topic=u'kafka', partitions=[(partition=0, error_code=0)])])
DEBUG:kafka.coordinator.consumer:Group kafka-influxdb committed offset OffsetAndMetadata(offset=45, metadata='') for partition TopicPartition(topic=u'kafka', partition=0)
DEBUG:kafka.coordinator.consumer:Successfully auto-committed offsets for group kafka-influxdb
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 22: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 22: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 23: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.coordinator:Heartbeat: kafka-influxdb[1] kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 24: HeartbeatRequest_v0(group='kafka-influxdb', generation_id=1, member_id=u'kafka-python-1.3.1-605ad982-fddc-4713-9641-8e3c32741882')
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 23: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 24: HeartbeatResponse_v0(error_code=0)
DEBUG:kafka.coordinator:Received successful heartbeat response for group kafka-influxdb
DEBUG:kafka.coordinator:Received successful heartbeat
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45
DEBUG:kafka.consumer.fetcher:Sending FetchRequest to node 0
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Request 25: FetchRequest_v2(replica_id=-1, max_wait_time=500, min_bytes=1, topics=[(topic=u'kafka', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
DEBUG:kafka.conn:<BrokerConnection host=192.168.0.4/192.168.0.4 port=9092> Response 25: FetchResponse_v2(throttle_time_ms=0, topics=[(topics=u'kafka', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
DEBUG:kafka.consumer.fetcher:Adding fetch request for partition TopicPartition(topic=u'kafka', partition=0) at offset 45