0 [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [192.168.41.132:9090] check.crcs = true client.id = connections.max.idle.ms = 540000 enable.auto.commit = true exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = group-id-all heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = true isolation.level = read_committed key.deserializer = class org.apache.kafka.common.serialization.IntegerDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class com.example.transaction.producer.utils.serde.JsonDeserializer 0 [main] DEBUG org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-1, groupId=group-id-all] Initializing the Kafka consumer 142 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [192.168.41.132:9090 (id: -1 rack: null)], partitions = []) 161 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 392 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 410 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-created: 413 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name successful-authentication: 413 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name failed-authentication: 414 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 415 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 416 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 417 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name select-time: 418 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name io-time: 445 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 445 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name join-latency 445 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name sync-latency 454 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name commit-latency 460 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 461 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-fetched 461 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 462 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-lag 466 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 1.0.0 466 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : aaa7af6d4a11b29d 468 [main] DEBUG org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-1, groupId=group-id-all] Kafka consumer initialized 469 [main] DEBUG org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-1, groupId=group-id-all] Subscribed to topic(s): topic 469 [main] INFO com.example.transaction.producer.consumer.Consumer - *************** Starting Consumer ************* 470 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Sending GroupCoordinator request to broker 192.168.41.132:9090 (id: -1 rack: null) 645 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Initiating connection to node 192.168.41.132:9090 (id: -1 rack: null) 645 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 645 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 645 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 645 [main] DEBUG org.apache.kafka.common.network.Selector - [Consumer clientId=consumer-1, groupId=group-id-all] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 645 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Completed connection to node -1. Fetching API versions. 645 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Initiating API versions fetch from node -1. 661 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Recorded API versions for node -1: (Produce(0): 0 to 5 [usable: 5], Fetch(1): 0 to 6 [usable: 6], ListOffsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 5 [usable: 5], LeaderAndIsr(4): 0 to 1 [usable: 1], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 4 [usable: 4], ControlledShutdown(7): 0 to 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 [usable: 0], AlterConfigs(33): 0 [usable: 0], AlterReplicaLogDirs(34): 0 [usable: 0], DescribeLogDirs(35): 0 [usable: 0], SaslAuthenticate(36): 0 [usable: 0], CreatePartitions(37): 0 [usable: 0]) 661 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Sending metadata request (type=MetadataRequest, topics=topic) to node 192.168.41.132:9090 (id: -1 rack: null) 676 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 2 to Cluster(id = nYuiS88zQfmZyt4MrNbW6g, nodes = [192.168.41.132:9090 (id: 1001 rack: null)], partitions = [Partition(topic = topic, partition = 0, leader = 1001, replicas = [1001], isr = [1001], offlineReplicas = [])]) 676 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Received GroupCoordinator response ClientResponse(receivedTimeMs=1510235945901, latencyMs=42, disconnected=false, requestHeader=RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=1, clientId=consumer-1, correlationId=0), responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=NONE, node=192.168.41.132:9090 (id: 1001 rack: null))) 676 [main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Discovered coordinator 192.168.41.132:9090 (id: 2147482646 rack: null) 676 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Initiating connection to node 192.168.41.132:9090 (id: 2147482646 rack: null) 676 [main] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Sending synchronous auto-commit of offsets {} 676 [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Revoking previously assigned partitions [] 676 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Disabling heartbeat thread 676 [main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] (Re-)joining group 692 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Sending JoinGroup ((type: JoinGroupRequest, groupId=group-id-all, sessionTimeout=10000, rebalanceTimeout=300000, memberId=, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@442675e1)) to coordinator 192.168.41.132:9090 (id: 2147482646 rack: null) 692 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node-2147482646.bytes-sent 692 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node-2147482646.bytes-received 692 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node-2147482646.latency 692 [main] DEBUG org.apache.kafka.common.network.Selector - [Consumer clientId=consumer-1, groupId=group-id-all] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147482646 692 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Completed connection to node 2147482646. Fetching API versions. 692 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Initiating API versions fetch from node 2147482646. 692 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Recorded API versions for node 2147482646: (Produce(0): 0 to 5 [usable: 5], Fetch(1): 0 to 6 [usable: 6], ListOffsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 5 [usable: 5], LeaderAndIsr(4): 0 to 1 [usable: 1], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 4 [usable: 4], ControlledShutdown(7): 0 to 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 [usable: 0], AlterConfigs(33): 0 [usable: 0], AlterReplicaLogDirs(34): 0 [usable: 0], DescribeLogDirs(35): 0 [usable: 0], SaslAuthenticate(36): 0 [usable: 0], CreatePartitions(37): 0 [usable: 0]) 707 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Received successful JoinGroup response: org.apache.kafka.common.requests.JoinGroupResponse@64d7f7e0 707 [main] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Performing assignment using strategy range with subscriptions {consumer-1-6cdda241-fa56-4e48-8cd6-fb066e4c2699=Subscription(topics=[topic])} 707 [main] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Finished assignment for group: {consumer-1-6cdda241-fa56-4e48-8cd6-fb066e4c2699=Assignment(partitions=[topic-0])} 718 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Sending leader SyncGroup to coordinator 192.168.41.132:9090 (id: 2147482646 rack: null): (type=SyncGroupRequest, groupId=group-id-all, generationId=3, memberId=consumer-1-6cdda241-fa56-4e48-8cd6-fb066e4c2699, groupAssignment=consumer-1-6cdda241-fa56-4e48-8cd6-fb066e4c2699) 723 [kafka-coordinator-heartbeat-thread | group-id-all] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Heartbeat thread started 729 [main] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Successfully joined group with generation 3 729 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Enabling heartbeat thread 729 [main] INFO org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Setting newly assigned partitions [topic-0] 729 [main] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Fetching committed offsets for partitions: [topic-0] 737 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Resetting offset for partition topic-0 to the committed offset 0 738 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 739 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 740 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Initiating connection to node 192.168.41.132:9090 (id: 1001 rack: null) 742 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node-1001.bytes-sent 743 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node-1001.bytes-received 745 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node-1001.latency 745 [main] DEBUG org.apache.kafka.common.network.Selector - [Consumer clientId=consumer-1, groupId=group-id-all] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 1001 745 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Completed connection to node 1001. Fetching API versions. 745 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Initiating API versions fetch from node 1001. 745 [main] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=group-id-all] Recorded API versions for node 1001: (Produce(0): 0 to 5 [usable: 5], Fetch(1): 0 to 6 [usable: 6], ListOffsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 5 [usable: 5], LeaderAndIsr(4): 0 to 1 [usable: 1], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 4 [usable: 4], ControlledShutdown(7): 0 to 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 [usable: 0], AlterConfigs(33): 0 [usable: 0], AlterReplicaLogDirs(34): 0 [usable: 0], DescribeLogDirs(35): 0 [usable: 0], SaslAuthenticate(36): 0 [usable: 0], CreatePartitions(37): 0 [usable: 0]) 1253 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 1253 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name topic.topic.bytes-fetched 1253 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name topic.topic.records-fetched 1253 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name topic-0.records-lag 1253 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 1253 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 1781 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 1781 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 1781 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 2286 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 2286 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 2286 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 2791 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 2791 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 2791 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 3297 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 3297 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 3297 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 3741 [kafka-coordinator-heartbeat-thread | group-id-all] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Sending Heartbeat request to coordinator 192.168.41.132:9090 (id: 2147482646 rack: null) 3741 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Received successful Heartbeat response 12761 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Received successful Heartbeat response 13045 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 13045 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 13045 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 13562 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 13562 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 13562 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 14074 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 14074 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 14074 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 14592 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 14592 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 14592 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 15100 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 15100 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 15100 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 15604 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 15604 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 15604 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 15760 [main] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Sending asynchronous auto-commit of offsets {topic-0=OffsetAndMetadata{offset=0, metadata=''}} 15760 [main] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Committed offset 0 for partition topic-0 15760 [main] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Completed asynchronous auto-commit of offsets {topic-0=OffsetAndMetadata{offset=0, metadata=''}} 15776 [kafka-coordinator-heartbeat-thread | group-id-all] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Sending Heartbeat request to coordinator 192.168.41.132:9090 (id: 2147482646 rack: null) 15776 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Received successful Heartbeat response 16117 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 16117 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 16117 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 16620 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 16620 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 16620 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 17127 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 17127 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 17127 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 17636 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 17636 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 17636 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 18142 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 18142 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 18142 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 18650 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 18650 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 18650 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 18790 [kafka-coordinator-heartbeat-thread | group-id-all] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Sending Heartbeat request to coordinator 192.168.41.132:9090 (id: 2147482646 rack: null) 18790 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=group-id-all] Received successful Heartbeat response 19156 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 19156 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 19156 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null) 19672 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Fetch READ_COMMITTED at offset 0 for partition topic-0 returned fetch data (error=NONE, highWaterMark=2, lastStableOffset = 0, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=0) 19672 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Added READ_COMMITTED fetch request for partition topic-0 at offset 0 to node 192.168.41.132:9090 (id: 1001 rack: null) 19672 [main] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-1, groupId=group-id-all] Sending READ_COMMITTED fetch for partitions [topic-0] to broker 192.168.41.132:9090 (id: 1001 rack: null)