[jira] [Created] (KAFKA-8004) Consumer and producer works with expired delegation token

["Viktor Somogyi-Vass (JIRA)" <ji...@apache.org>]

Viktor Somogyi-Vass created KAFKA-8004:
------------------------------------------

             Summary: Consumer and producer works with expired delegation token
                 Key: KAFKA-8004
                 URL: https://issues.apache.org/jira/browse/KAFKA-8004
             Project: Kafka
          Issue Type: Improvement
          Components: consumer, producer 
    Affects Versions: 2.3.0
            Reporter: Viktor Somogyi-Vass


Noticed while testing Spark with [~gsomogyi] that Kafka won't break the connection after expiring the token.

Logs from the server:
{noformat}
2019-02-26 07:22:18,133 INFO kafka.server.DelegationTokenManager: [Token Manager on Broker 55]: Delegation token expired for token : <redacted> for owner :User:<redacted>
2019-02-26 07:22:18,139 INFO kafka.common.ZkNodeChangeNotificationListener: Processing notification(s) to /delegation_token/token_changes
{noformat}

ConsoleConsumer:
It can be seen that although it disconnects, it will be able to reconnect later and send a successful fetch request (the long "ssssss..." is sent from a similar ConsoleProducer).
{noformat}
[2019-02-26 07:29:07,104] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Connection with vsomogyi-kafka-secure6x-2.gce.cloudera.com/172.31.115.165 disconnected due to authentication exception (org.apache.kafka.common.network.Selector:577)
org.apache.kafka.common.network.DelayedResponseAuthenticationException: org.apache.kafka.common.errors.SaslAuthenticationException: Authentication failed due to invalid credentials with SASL mechanism SCRAM-SHA-512
Caused by: org.apache.kafka.common.errors.SaslAuthenticationException: Authentication failed due to invalid credentials with SASL mechanism SCRAM-SHA-512
[2019-02-26 07:29:07,104] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 56 disconnected. (org.apache.kafka.clients.NetworkClient:844)
[2019-02-26 07:29:07,104] ERROR [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Connection to node 56 (vsomogyi-kafka-secure6x-2.gce.cloudera.com/172.31.115.165:9093) failed authentication due to: Authentication failed due to invalid credentials with SASL mechanism SCRAM-SHA-512 (org.apache.kafka.clients.NetworkClient:698)
[2019-02-26 07:29:07,105] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:07,204] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:07,205] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Removing node vsomogyi-kafka-secure6x-3.gce.cloudera.com:9093 (id: 57 rack: null) from least loaded node selection: is-blacked-out: true, in-flight-requests: 0 (org.apache.kafka.clients.NetworkClient:649)
[2019-02-26 07:29:07,205] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Removing node vsomogyi-kafka-secure6x-2.gce.cloudera.com:9093 (id: 56 rack: null) from least loaded node selection: is-blacked-out: true, in-flight-requests: 0 (org.apache.kafka.clients.NetworkClient:649)
[2019-02-26 07:29:07,205] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Found least loaded node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.NetworkClient:655)
[2019-02-26 07:29:07,205] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending metadata request (type=MetadataRequest, topics=test1) to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.NetworkClient:1065)
[2019-02-26 07:29:07,205] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending METADATA {topics=[test1],allow_auto_topic_creation=true} with correlation id 2733 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:07,205] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:07,260] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2731, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:07,260] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:07,260] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:07,261] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for METADATA with correlation id 2733, received {throttle_time_ms=0,brokers=[{node_id=56,host=vsomogyi-kafka-secure6x-2.gce.cloudera.com,port=9093,rack=null},{node_id=57,host=vsomogyi-kafka-secure6x-3.gce.cloudera.com,port=9093,rack=null},{node_id=55,host=vsomogyi-kafka-secure6x-1.gce.cloudera.com,port=9093,rack=null}],cluster_id=NzuyFUZfTjWbgvpKeeCvlQ,controller_id=55,topic_metadata=[{error_code=0,topic=test1,is_internal=false,partition_metadata=[{error_code=0,partition=0,leader=55,leader_epoch=3,replicas=[55,57,56],isr=[55,56,57],offline_replicas=[]}]}]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:07,261] DEBUG Updated cluster metadata version 6 to Cluster(id = NzuyFUZfTjWbgvpKeeCvlQ, nodes = [vsomogyi-kafka-secure6x-2.gce.cloudera.com:9093 (id: 56 rack: null), vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null), vsomogyi-kafka-secure6x-3.gce.cloudera.com:9093 (id: 57 rack: null)], partitions = [Partition(topic = test1, partition = 0, leader = 55, replicas = [55,57,56], isr = [55,56,57], offlineReplicas = [])], controller = vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null)) (org.apache.kafka.clients.Metadata:290)
[2019-02-26 07:29:07,261] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:07,261] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2146) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:07,261] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:07,261] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2146,topics=[],forgotten_topics_data=[]} with correlation id 2734 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:07,262] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:07,762] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2734, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:07,763] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:07,763] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:07,763] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2147) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:07,763] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:07,763] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2147,topics=[],forgotten_topics_data=[]} with correlation id 2735 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:07,764] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:08,265] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2735, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:08,265] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:08,265] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:08,266] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2148) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:08,266] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:08,266] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2148,topics=[],forgotten_topics_data=[]} with correlation id 2736 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:08,266] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:08,767] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2736, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:08,767] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:08,768] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:08,768] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2149) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:08,768] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:08,768] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2149,topics=[],forgotten_topics_data=[]} with correlation id 2737 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:08,768] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:09,270] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2737, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:09,270] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:09,270] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:09,270] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2150) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:09,270] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:09,271] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2150,topics=[],forgotten_topics_data=[]} with correlation id 2738 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:09,271] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:09,772] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2738, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:09,772] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:09,772] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:09,772] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2151) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:09,772] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:09,772] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2151,topics=[],forgotten_topics_data=[]} with correlation id 2739 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:09,773] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:09,803] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:696)
[2019-02-26 07:29:09,803] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OffsetCommit request with {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:784)
[2019-02-26 07:29:09,804] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OFFSET_COMMIT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c,topics=[{topic=test1,partitions=[{partition=0,offset=15,leader_epoch=-1,metadata=}]}]} with correlation id 2740 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:09,804] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:09,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for OFFSET_COMMIT with correlation id 2740, received {throttle_time_ms=0,responses=[{topic=test1,partition_responses=[{partition=0,error_code=0}]}]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:09,809] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Committed offset 15 for partition test1-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:810)
[2019-02-26 07:29:09,809] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:710)
[2019-02-26 07:29:09,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:09,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:09,926] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending Heartbeat request to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:809)
[2019-02-26 07:29:09,926] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending HEARTBEAT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c} with correlation id 2741 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:09,926] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:09,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for HEARTBEAT with correlation id 2741, received {throttle_time_ms=0,error_code=0} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:09,928] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Received successful Heartbeat response (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:822)
[2019-02-26 07:29:09,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:09,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:10,274] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2739, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:10,274] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:10,275] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:10,275] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2152) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:10,275] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:10,275] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2152,topics=[],forgotten_topics_data=[]} with correlation id 2742 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:10,275] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:10,778] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2742, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:10,778] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:10,779] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:10,779] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2153) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:10,779] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:10,779] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2153,topics=[],forgotten_topics_data=[]} with correlation id 2743 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:10,779] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:11,281] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2743, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:11,281] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:11,282] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:11,282] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2154) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:11,282] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:11,282] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2154,topics=[],forgotten_topics_data=[]} with correlation id 2744 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:11,282] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:11,783] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2744, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:11,784] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:11,784] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:11,784] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2155) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:11,784] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:11,784] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2155,topics=[],forgotten_topics_data=[]} with correlation id 2745 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:11,785] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:12,285] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2745, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:12,286] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:12,286] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:12,286] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2156) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:12,286] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:12,286] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2156,topics=[],forgotten_topics_data=[]} with correlation id 2746 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:12,287] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:12,788] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2746, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:12,788] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:12,788] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:12,788] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2157) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:12,788] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:12,788] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2157,topics=[],forgotten_topics_data=[]} with correlation id 2747 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:12,789] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:12,926] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending Heartbeat request to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:809)
[2019-02-26 07:29:12,926] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending HEARTBEAT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c} with correlation id 2748 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:12,927] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:12,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for HEARTBEAT with correlation id 2748, received {throttle_time_ms=0,error_code=0} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:12,928] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Received successful Heartbeat response (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:822)
[2019-02-26 07:29:12,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:12,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:13,290] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2747, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:13,290] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:13,290] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:13,290] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2158) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:13,290] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:13,290] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2158,topics=[],forgotten_topics_data=[]} with correlation id 2749 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:13,291] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:13,792] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2749, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:13,792] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:13,792] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:13,792] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2159) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:13,792] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:13,792] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2159,topics=[],forgotten_topics_data=[]} with correlation id 2750 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:13,793] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:14,293] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2750, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:14,294] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:14,294] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:14,294] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2160) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:14,294] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:14,294] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2160,topics=[],forgotten_topics_data=[]} with correlation id 2751 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:14,295] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:14,796] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2751, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:14,796] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:14,796] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:14,796] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2161) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:14,797] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:14,797] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2161,topics=[],forgotten_topics_data=[]} with correlation id 2752 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:14,797] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:14,803] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:696)
[2019-02-26 07:29:14,803] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OffsetCommit request with {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:784)
[2019-02-26 07:29:14,804] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OFFSET_COMMIT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c,topics=[{topic=test1,partitions=[{partition=0,offset=15,leader_epoch=-1,metadata=}]}]} with correlation id 2753 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:14,805] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:14,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for OFFSET_COMMIT with correlation id 2753, received {throttle_time_ms=0,responses=[{topic=test1,partition_responses=[{partition=0,error_code=0}]}]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:14,809] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Committed offset 15 for partition test1-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:810)
[2019-02-26 07:29:14,809] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:710)
[2019-02-26 07:29:14,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:14,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:15,298] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2752, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:15,298] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:15,298] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:15,299] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2162) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:15,299] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:15,299] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2162,topics=[],forgotten_topics_data=[]} with correlation id 2754 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:15,299] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:15,800] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2754, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:15,800] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:15,800] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:15,800] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2163) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:15,800] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:15,800] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2163,topics=[],forgotten_topics_data=[]} with correlation id 2755 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:15,801] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:15,926] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending Heartbeat request to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:809)
[2019-02-26 07:29:15,926] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending HEARTBEAT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c} with correlation id 2756 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:15,927] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:15,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for HEARTBEAT with correlation id 2756, received {throttle_time_ms=0,error_code=0} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:15,928] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Received successful Heartbeat response (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:822)
[2019-02-26 07:29:15,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:15,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:16,301] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2755, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:16,302] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:16,302] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:16,302] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2164) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:16,302] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:16,302] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2164,topics=[],forgotten_topics_data=[]} with correlation id 2757 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:16,302] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:16,804] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2757, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:16,804] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:16,804] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:16,805] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2165) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:16,805] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:16,805] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2165,topics=[],forgotten_topics_data=[]} with correlation id 2758 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:16,805] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:17,306] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2758, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:17,306] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:17,306] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:17,307] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2166) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:17,307] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:17,307] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2166,topics=[],forgotten_topics_data=[]} with correlation id 2759 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:17,307] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:17,808] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2759, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:17,808] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:17,808] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:17,809] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2167) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:17,809] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:17,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2167,topics=[],forgotten_topics_data=[]} with correlation id 2760 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:17,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:18,310] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2760, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:18,310] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:18,311] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:18,311] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2168) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:18,311] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:18,311] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2168,topics=[],forgotten_topics_data=[]} with correlation id 2761 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:18,311] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:18,813] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2761, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:18,813] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:18,813] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:18,813] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2169) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:18,813] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:18,814] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2169,topics=[],forgotten_topics_data=[]} with correlation id 2762 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:18,814] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:18,926] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending Heartbeat request to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:809)
[2019-02-26 07:29:18,927] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending HEARTBEAT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c} with correlation id 2763 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:18,927] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:18,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for HEARTBEAT with correlation id 2763, received {throttle_time_ms=0,error_code=0} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:18,929] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Received successful Heartbeat response (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:822)
[2019-02-26 07:29:18,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:18,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:19,315] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2762, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:19,315] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:19,315] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:19,315] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2170) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:19,316] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:19,316] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2170,topics=[],forgotten_topics_data=[]} with correlation id 2764 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:19,316] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:19,804] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:696)
[2019-02-26 07:29:19,804] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OffsetCommit request with {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:784)
[2019-02-26 07:29:19,804] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OFFSET_COMMIT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c,topics=[{topic=test1,partitions=[{partition=0,offset=15,leader_epoch=-1,metadata=}]}]} with correlation id 2765 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:19,805] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:19,809] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for OFFSET_COMMIT with correlation id 2765, received {throttle_time_ms=0,responses=[{topic=test1,partition_responses=[{partition=0,error_code=0}]}]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:19,810] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Committed offset 15 for partition test1-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:810)
[2019-02-26 07:29:19,810] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:710)
[2019-02-26 07:29:19,810] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:19,810] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:19,817] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2764, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:19,817] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:19,817] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:19,817] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2171) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:19,817] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:19,817] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2171,topics=[],forgotten_topics_data=[]} with correlation id 2766 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:19,818] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:20,318] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2766, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:20,318] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:20,319] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:20,319] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2172) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:20,319] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:20,319] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2172,topics=[],forgotten_topics_data=[]} with correlation id 2767 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:20,319] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:20,820] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2767, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:20,820] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:20,821] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:20,821] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2173) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:20,821] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:20,821] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2173,topics=[],forgotten_topics_data=[]} with correlation id 2768 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:20,821] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:21,323] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2768, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:21,323] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:21,323] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:21,324] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2174) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:21,324] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:21,324] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2174,topics=[],forgotten_topics_data=[]} with correlation id 2769 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:21,324] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:21,825] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2769, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:21,825] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:21,825] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:21,825] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2175) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:21,825] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:21,826] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2175,topics=[],forgotten_topics_data=[]} with correlation id 2770 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:21,826] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:21,926] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending Heartbeat request to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:809)
[2019-02-26 07:29:21,927] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending HEARTBEAT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c} with correlation id 2771 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:21,927] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:21,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for HEARTBEAT with correlation id 2771, received {throttle_time_ms=0,error_code=0} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:21,929] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Received successful Heartbeat response (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:822)
[2019-02-26 07:29:21,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:21,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:22,328] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2770, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:22,329] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:22,329] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:22,329] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2176) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:22,329] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:22,329] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2176,topics=[],forgotten_topics_data=[]} with correlation id 2772 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:22,329] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:22,831] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2772, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:22,831] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:22,832] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:22,832] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2177) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:22,832] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:22,832] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2177,topics=[],forgotten_topics_data=[]} with correlation id 2773 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:22,832] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:23,334] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2773, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:23,334] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:23,334] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:23,334] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2178) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:23,334] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:23,334] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2178,topics=[],forgotten_topics_data=[]} with correlation id 2774 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:23,335] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:23,836] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2774, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:23,836] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:23,836] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:23,836] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2179) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:23,836] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:23,836] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2179,topics=[],forgotten_topics_data=[]} with correlation id 2775 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:23,837] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:24,338] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2775, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:24,338] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:24,339] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:24,339] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2180) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:24,339] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:24,339] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2180,topics=[],forgotten_topics_data=[]} with correlation id 2776 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:24,339] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:24,805] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:696)
[2019-02-26 07:29:24,806] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OffsetCommit request with {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:784)
[2019-02-26 07:29:24,806] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OFFSET_COMMIT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c,topics=[{topic=test1,partitions=[{partition=0,offset=15,leader_epoch=-1,metadata=}]}]} with correlation id 2777 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:24,806] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:24,810] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for OFFSET_COMMIT with correlation id 2777, received {throttle_time_ms=0,responses=[{topic=test1,partition_responses=[{partition=0,error_code=0}]}]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:24,811] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Committed offset 15 for partition test1-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:810)
[2019-02-26 07:29:24,811] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:710)
[2019-02-26 07:29:24,811] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:24,811] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:24,840] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2776, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:24,840] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:24,841] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:24,841] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2181) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:24,841] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:24,841] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2181,topics=[],forgotten_topics_data=[]} with correlation id 2778 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:24,841] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:24,927] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending Heartbeat request to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:809)
[2019-02-26 07:29:24,927] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending HEARTBEAT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c} with correlation id 2779 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:24,927] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:24,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for HEARTBEAT with correlation id 2779, received {throttle_time_ms=0,error_code=0} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:24,929] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Received successful Heartbeat response (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:822)
[2019-02-26 07:29:24,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:24,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:25,343] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2778, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:25,343] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:25,343] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:25,343] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2182) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:25,344] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:25,344] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2182,topics=[],forgotten_topics_data=[]} with correlation id 2780 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:25,344] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:25,845] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2780, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:25,845] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:25,845] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:25,845] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2183) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:25,845] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:25,845] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2183,topics=[],forgotten_topics_data=[]} with correlation id 2781 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:25,846] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:26,346] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2781, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:26,347] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:26,347] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:26,347] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2184) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:26,347] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:26,347] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2184,topics=[],forgotten_topics_data=[]} with correlation id 2782 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:26,347] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:26,848] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2782, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:26,849] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:26,849] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:26,849] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2185) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:26,849] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:26,849] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2185,topics=[],forgotten_topics_data=[]} with correlation id 2783 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:26,849] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:27,351] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2783, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:27,351] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:27,351] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:27,351] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2186) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:27,351] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:27,351] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2186,topics=[],forgotten_topics_data=[]} with correlation id 2784 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:27,352] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:27,852] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2784, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:27,853] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:27,853] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:27,853] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2187) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:27,853] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:27,853] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2187,topics=[],forgotten_topics_data=[]} with correlation id 2785 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:27,853] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:27,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:27,928] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending Heartbeat request to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:809)
[2019-02-26 07:29:27,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending HEARTBEAT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c} with correlation id 2786 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:27,928] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:27,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for HEARTBEAT with correlation id 2786, received {throttle_time_ms=0,error_code=0} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:27,929] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Received successful Heartbeat response (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:822)
[2019-02-26 07:29:27,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:27,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:28,355] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2785, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:28,355] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:28,355] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:28,355] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2188) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:28,356] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:28,356] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2188,topics=[],forgotten_topics_data=[]} with correlation id 2787 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:28,356] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:28,857] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2787, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:28,857] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:28,857] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:28,857] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2189) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:28,857] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:28,858] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2189,topics=[],forgotten_topics_data=[]} with correlation id 2788 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:28,858] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:29,358] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2788, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:29,359] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:29,359] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:29,359] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2190) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:29,359] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:29,359] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2190,topics=[],forgotten_topics_data=[]} with correlation id 2789 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:29,359] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:29,806] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:696)
[2019-02-26 07:29:29,807] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OffsetCommit request with {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:784)
[2019-02-26 07:29:29,807] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending OFFSET_COMMIT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c,topics=[{topic=test1,partitions=[{partition=0,offset=15,leader_epoch=-1,metadata=}]}]} with correlation id 2790 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:29,807] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:29,829] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for OFFSET_COMMIT with correlation id 2790, received {throttle_time_ms=0,responses=[{topic=test1,partition_responses=[{partition=0,error_code=0}]}]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:29,829] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Committed offset 15 for partition test1-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:810)
[2019-02-26 07:29:29,829] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed asynchronous auto-commit of offsets {test1-0=OffsetAndMetadata{offset=15, leaderEpoch=null, metadata=''}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:710)
[2019-02-26 07:29:29,829] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:29,829] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:29,860] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2789, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:29,860] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:29,861] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:29,861] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2191) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:29,861] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:29,861] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2191,topics=[],forgotten_topics_data=[]} with correlation id 2791 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:29,861] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:30,361] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2791, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:30,361] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:30,362] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:30,362] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2192) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:30,362] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:30,362] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2192,topics=[],forgotten_topics_data=[]} with correlation id 2792 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:30,362] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:30,863] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2792, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:30,863] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:30,864] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:30,864] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2193) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:30,864] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:30,864] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2193,topics=[],forgotten_topics_data=[]} with correlation id 2793 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:30,864] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:30,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:30,929] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending Heartbeat request to coordinator vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 2147483592 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:809)
[2019-02-26 07:29:30,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending HEARTBEAT {group_id=random_group_with_delegation_token,generation_id=5,member_id=consumer-1-ae7df3c8-2589-49b6-a006-08e90fea410c} with correlation id 2794 to node 2147483592 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:30,929] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:30,931] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 2147483592 for HEARTBEAT with correlation id 2794, received {throttle_time_ms=0,error_code=0} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:30,931] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Received successful Heartbeat response (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:822)
[2019-02-26 07:29:30,931] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:30,931] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:31,366] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2793, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:31,366] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:31,366] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:31,366] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2194) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:31,366] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:31,367] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2194,topics=[],forgotten_topics_data=[]} with correlation id 2795 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:31,367] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:31,867] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2795, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:31,868] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:31,868] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:31,868] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2195) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:31,868] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:31,868] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2195,topics=[],forgotten_topics_data=[]} with correlation id 2796 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:31,868] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:32,368] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2796, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:32,369] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(), implied=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:32,369] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 15 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:32,369] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2196) for node 55. Added (), altered (), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:32,369] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(test1-0)) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:32,369] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2196,topics=[],forgotten_topics_data=[]} with correlation id 2797 to node 55 (org.apache.kafka.clients.NetworkClient:501)
[2019-02-26 07:29:32,369] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Skipping fetch for partition test1-0 because there is an in-flight request to vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:880)
[2019-02-26 07:29:32,750] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Completed receive from node 55 for FETCH with correlation id 2797, received {throttle_time_ms=0,error_code=0,session_id=591678416,responses=[{topic=test1,partition_responses=[{partition_header={partition=0,error_code=0,high_watermark=16,last_stable_offset=16,log_start_offset=0,aborted_transactions=null},record_set=[(record=DefaultRecord(offset=15, timestamp=1551194971743, key=0 bytes, value=40 bytes))]}]}]} (org.apache.kafka.clients.NetworkClient:800)
[2019-02-26 07:29:32,750] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Node 55 sent an incremental fetch response for session 591678416 with response=(test1-0) (org.apache.kafka.clients.FetchSessionHandler:421)
[2019-02-26 07:29:32,750] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Fetch READ_UNCOMMITTED at offset 15 for partition test1-0 returned fetch data (error=NONE, highWaterMark=16, lastStableOffset = 16, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=108) (org.apache.kafka.clients.consumer.internals.Fetcher:244)
[2019-02-26 07:29:32,750] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Preparing to read 108 bytes of data for partition test1-0 with offset 15 (org.apache.kafka.clients.consumer.internals.Fetcher:934)
[2019-02-26 07:29:32,750] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Updating high watermark for partition test1-0 to 16 (org.apache.kafka.clients.consumer.internals.Fetcher:958)
[2019-02-26 07:29:32,751] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Updating log start offset for partition test1-0 to 0 (org.apache.kafka.clients.consumer.internals.Fetcher:963)
[2019-02-26 07:29:32,751] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Updating last stable offset for partition test1-0 to 16 (org.apache.kafka.clients.consumer.internals.Fetcher:968)
[2019-02-26 07:29:32,751] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Returning fetched records at offset 15 for assigned partition test1-0 and update position to 16 (org.apache.kafka.clients.consumer.internals.Fetcher:547)
[2019-02-26 07:29:32,751] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Added READ_UNCOMMITTED fetch request for partition test1-0 at offset 16 to node vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:898)
[2019-02-26 07:29:32,751] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Built incremental fetch (sessionId=591678416, epoch=2197) for node 55. Added (), altered (test1-0), removed () out of (test1-0) (org.apache.kafka.clients.FetchSessionHandler:250)
[2019-02-26 07:29:32,751] DEBUG [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(test1-0), toForget=(), implied=()) to broker vsomogyi-kafka-secure6x-1.gce.cloudera.com:9093 (id: 55 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:218)
[2019-02-26 07:29:32,751] TRACE [Consumer clientId=consumer-1, groupId=random_group_with_delegation_token] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,session_id=591678416,session_epoch=2197,topics=[{topic=test1,partitions=[{partition=0,current_leader_epoch=-1,fetch_offset=16,log_start_offset=-1,partition_max_bytes=1048576}]}],forgotten_topics_data=[]} with correlation id 2798 to node 55 (org.apache.kafka.clients.NetworkClient:501)
ssssssssssssssssssssssssssssssssssssssss
{noformat}

Once I restart the ConsoleConsumer, it won't authenticate as the token has expired. In this experiment I set the expiry time to 10min, max lifetime to 20min and expiry check interval to 5min.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)