Time: 04/15/2020 08:15:07, Level: INFO, Log: 2020-04-15 00:31:21 &amp#27;[32mINFO &amp#27;[m [TimeMeasuringSystem:94] Start time of operation TEST_EXECUTION is correctly stored
2020-04-15 00:31:21 &amp#27;[32mINFO &amp#27;[m [TestSeparator:27] ############################################################################
2020-04-15 00:31:21 &amp#27;[32mINFO &amp#27;[m [TestSeparator:28] io.strimzi.systemtest.kafka.ListenersST.testCustomCertLoadBalancerAndTlsRollingUpdate-STARTED
2020-04-15 00:31:21 &amp#27;[32mINFO &amp#27;[m [ResourceManager:89] Setting pointer to method resources
2020-04-15 00:31:21 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of Kafka my-cluster in namespace kafka-listeners-cluster-test
2020-04-15 00:31:21 &amp#27;[32mINFO &amp#27;[m [KafkaResource:213] Waiting for Kafka my-cluster in namespace kafka-listeners-cluster-test
2020-04-15 00:31:21 &amp#27;[32mINFO &amp#27;[m [KafkaResource:215] Waiting for Zookeeper pods
2020-04-15 00:32:00 &amp#27;[32mINFO &amp#27;[m [KafkaResource:217] Zookeeper pods are ready
2020-04-15 00:32:00 &amp#27;[32mINFO &amp#27;[m [KafkaResource:219] Waiting for Kafka pods
2020-04-15 00:38:58 &amp#27;[32mINFO &amp#27;[m [KafkaResource:221] Kafka pods are ready
2020-04-15 00:38:58 &amp#27;[32mINFO &amp#27;[m [KafkaResource:225] Waiting for Entity Operator pods
2020-04-15 00:39:08 &amp#27;[32mINFO &amp#27;[m [KafkaResource:227] Entity Operator pods are ready
2020-04-15 00:39:08 &amp#27;[32mINFO &amp#27;[m [KafkaUserResource:64] Created KafkaUser alice
2020-04-15 00:39:08 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of KafkaUser alice in namespace kafka-listeners-cluster-test
2020-04-15 00:39:08 &amp#27;[32mINFO &amp#27;[m [KafkaUserResource:81] Waiting for Kafka User alice
2020-04-15 00:39:08 &amp#27;[32mINFO &amp#27;[m [KafkaUserUtils:24] Waiting for Kafka user creation alice
2020-04-15 00:39:08 &amp#27;[32mINFO &amp#27;[m [SecretUtils:40] Waiting for Kafka user secret alice
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [SecretUtils:44] Kafka user secret alice created
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [KafkaUserUtils:35] Kafka user alice created
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [KafkaUserResource:83] Kafka User alice is ready
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [ListenersST:536] Check if KafkaStatus certificates from external listeners are the same as secret certificates
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [ListenersST:538] Check if KafkaStatus certificates from internal TLS listener are the same as secret certificates
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [BasicExternalKafkaClient:101] Going to use the following CA certificate: my-cluster-cluster-ca-cert
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [Producer:36] Creating instance of Vert.x for the client io.strimzi.systemtest.kafkaclients.externalClients.Producer
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [Producer:38] Producer is starting with following properties: {ssl.keystore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties15383720100046100914.keystore, bootstrap.servers=172.29.74.29:9094, key.serializer=org.apache.kafka.common.serialization.StringSerializer, ssl.truststore.type=PKCS12, security.protocol=SSL, ssl.keystore.type=PKCS12, value.serializer=org.apache.kafka.common.serialization.StringSerializer, ssl.truststore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties12118106937514856359.truststore, ssl.keystore.password=foo, sasl.mechanism=, ssl.truststore.password=UmgkOP1AQA1K, client.id=alice-producer, ssl.endpoint.identification.algorithm=}
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [ProducerConfig:347] ProducerConfig values: 
	acks = 1
	batch.size = 16384
	bootstrap.servers = [172.29.74.29:9094]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id = alice-producer
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 5
	max.request.size = 1048576
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = 
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties15383720100046100914.keystore
	ssl.keystore.password = [hidden]
	ssl.keystore.type = PKCS12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties12118106937514856359.truststore
	ssl.truststore.password = [hidden]
	ssl.truststore.type = PKCS12
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer

2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:117] Kafka version: 2.4.0
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:118] Kafka commitId: 77a89fcf8d7fa018
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:119] Kafka startTimeMs: 1586911149679
2020-04-15 00:39:09 &amp#27;[33mWARN &amp#27;[m [NetworkClient:1063] [Producer clientId=alice-producer] Error while fetching metadata with correlation id 1 : {test-topic-1217502653=LEADER_NOT_AVAILABLE}
2020-04-15 00:39:09 &amp#27;[32mINFO &amp#27;[m [Metadata:261] [Producer clientId=alice-producer] Cluster ID: FiXUEvIGTB6OchGaSyJltg
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [Producer:79] Producer produced 100 messages
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [Producer:57] Closing Vert.x instance for the client io.strimzi.systemtest.kafkaclients.externalClients.Producer
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [KafkaProducer:1183] [Producer clientId=alice-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [BasicExternalKafkaClient:182] Going to use the following CA certificate: my-cluster-cluster-ca-cert
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [Consumer:34] Consumer is starting with following properties: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=my-consumer-group-622895667, ssl.keystore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties2834029108036409213.keystore, bootstrap.servers=172.29.74.29:9094, ssl.truststore.type=PKCS12, security.protocol=SSL, ssl.keystore.type=PKCS12, ssl.truststore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties5944095257894434324.truststore, ssl.keystore.password=foo, sasl.mechanism=, ssl.truststore.password=UmgkOP1AQA1K, auto.offset.reset=earliest, client.id=alice-consumer, ssl.endpoint.identification.algorithm=}
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [ConsumerConfig:347] ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [172.29.74.29:9094]
	check.crcs = true
	client.dns.lookup = default
	client.id = alice-consumer
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = true
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = my-consumer-group-622895667
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = 
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties2834029108036409213.keystore
	ssl.keystore.password = [hidden]
	ssl.keystore.type = PKCS12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties5944095257894434324.truststore
	ssl.truststore.password = [hidden]
	ssl.truststore.type = PKCS12
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:117] Kafka version: 2.4.0
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:118] Kafka commitId: 77a89fcf8d7fa018
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:119] Kafka startTimeMs: 1586911150454
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [KafkaConsumer:969] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Subscribed to topic(s): test-topic-1217502653
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [Metadata:261] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Cluster ID: FiXUEvIGTB6OchGaSyJltg
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:756] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Discovered group coordinator 172.29.82.224:9094 (id: 2147483645 rack: null)
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:533] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] (Re-)joining group
2020-04-15 00:39:10 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:533] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] (Re-)joining group
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:585] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Finished assignment for group at generation 1: {alice-consumer-6e22703e-7678-47f1-bdf3-f91d6987cb12=org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Assignment@778bea99}
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:484] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Successfully joined group with generation 1
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:267] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Adding newly assigned partitions: test-topic-1217502653-0
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:1241] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Found no committed offset for partition test-topic-1217502653-0
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [SubscriptionState:385] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Resetting offset for partition test-topic-1217502653-0 to offset 0.
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [Consumer:55] Consumer consumed 100 messages
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [Consumer:68] Closing Vert.x instance for the client io.strimzi.systemtest.kafkaclients.externalClients.Consumer
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:286] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Revoke previously assigned partitions test-topic-1217502653-0
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:916] [Consumer clientId=alice-consumer, groupId=my-consumer-group-622895667] Member alice-consumer-6e22703e-7678-47f1-bdf3-f91d6987cb12 sending LeaveGroup request to coordinator 172.29.82.224:9094 (id: 2147483645 rack: null) due to the consumer is being closed
2020-04-15 00:39:13 &amp#27;[32mINFO &amp#27;[m [StatefulSetUtils:101] Waiting for StatefulSet my-cluster-kafka rolling update
2020-04-15 00:44:34 &amp#27;[32mINFO &amp#27;[m [StatefulSetUtils:111] StatefulSet my-cluster-kafka rolling update finished
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [ListenersST:590] Check if KafkaStatus certificates are the same as secret certificates
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [ListenersST:592] Check if KafkaStatus certificates from internal TLS listener are the same as secret certificates
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [BasicExternalKafkaClient:101] Going to use the following CA certificate: custom-certificate-server-1
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [Producer:36] Creating instance of Vert.x for the client io.strimzi.systemtest.kafkaclients.externalClients.Producer
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [Producer:38] Producer is starting with following properties: {ssl.keystore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties9347531673118726671.keystore, bootstrap.servers=172.29.74.29:9094, key.serializer=org.apache.kafka.common.serialization.StringSerializer, ssl.truststore.type=PKCS12, security.protocol=SSL, ssl.keystore.type=PKCS12, value.serializer=org.apache.kafka.common.serialization.StringSerializer, ssl.truststore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties13436942318847574428.truststore, ssl.keystore.password=foo, sasl.mechanism=, ssl.truststore.password=foo, client.id=alice-producer, ssl.endpoint.identification.algorithm=}
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [ProducerConfig:347] ProducerConfig values: 
	acks = 1
	batch.size = 16384
	bootstrap.servers = [172.29.74.29:9094]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id = alice-producer
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 5
	max.request.size = 1048576
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = 
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties9347531673118726671.keystore
	ssl.keystore.password = [hidden]
	ssl.keystore.type = PKCS12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties13436942318847574428.truststore
	ssl.truststore.password = [hidden]
	ssl.truststore.type = PKCS12
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer

2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:117] Kafka version: 2.4.0
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:118] Kafka commitId: 77a89fcf8d7fa018
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:119] Kafka startTimeMs: 1586911638566
2020-04-15 00:47:18 &amp#27;[32mINFO &amp#27;[m [Metadata:261] [Producer clientId=alice-producer] Cluster ID: FiXUEvIGTB6OchGaSyJltg
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [Producer:79] Producer produced 100 messages
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [Producer:57] Closing Vert.x instance for the client io.strimzi.systemtest.kafkaclients.externalClients.Producer
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [BasicExternalKafkaClient:182] Going to use the following CA certificate: custom-certificate-server-1
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [KafkaProducer:1183] [Producer clientId=alice-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [Consumer:34] Consumer is starting with following properties: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=my-consumer-group-2086643474, ssl.keystore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties13493779147623285183.keystore, bootstrap.servers=172.29.74.29:9094, ssl.truststore.type=PKCS12, security.protocol=SSL, ssl.keystore.type=PKCS12, ssl.truststore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties10053697075743953684.truststore, ssl.keystore.password=foo, sasl.mechanism=, ssl.truststore.password=foo, auto.offset.reset=earliest, client.id=alice-consumer, ssl.endpoint.identification.algorithm=}
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [ConsumerConfig:347] ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [172.29.74.29:9094]
	check.crcs = true
	client.dns.lookup = default
	client.id = alice-consumer
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = true
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = my-consumer-group-2086643474
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = 
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties13493779147623285183.keystore
	ssl.keystore.password = [hidden]
	ssl.keystore.type = PKCS12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties10053697075743953684.truststore
	ssl.truststore.password = [hidden]
	ssl.truststore.type = PKCS12
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:117] Kafka version: 2.4.0
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:118] Kafka commitId: 77a89fcf8d7fa018
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:119] Kafka startTimeMs: 1586911639257
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [KafkaConsumer:969] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Subscribed to topic(s): test-topic-1217502653
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [Metadata:261] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Cluster ID: FiXUEvIGTB6OchGaSyJltg
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:756] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Discovered group coordinator 172.29.47.237:9094 (id: 2147483646 rack: null)
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:533] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] (Re-)joining group
2020-04-15 00:47:19 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:533] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] (Re-)joining group
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:585] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Finished assignment for group at generation 1: {alice-consumer-6abc51f8-b080-486b-adf3-830ff53a4b0f=org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Assignment@54c842c2}
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:484] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Successfully joined group with generation 1
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:267] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Adding newly assigned partitions: test-topic-1217502653-0
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:1241] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Found no committed offset for partition test-topic-1217502653-0
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [SubscriptionState:385] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Resetting offset for partition test-topic-1217502653-0 to offset 0.
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [Consumer:55] Consumer consumed 100 messages
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [Consumer:68] Closing Vert.x instance for the client io.strimzi.systemtest.kafkaclients.externalClients.Consumer
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of Deployment my-cluster-kafka-clients in namespace (not set)
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:422] Waiting for deployment my-cluster-kafka-clients
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:286] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Revoke previously assigned partitions test-topic-1217502653-0
2020-04-15 00:47:22 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:916] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Member alice-consumer-6abc51f8-b080-486b-adf3-830ff53a4b0f sending LeaveGroup request to coordinator 172.29.47.237:9094 (id: 2147483646 rack: null) due to the consumer is being closed
2020-04-15 00:47:35 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:424] Deployment my-cluster-kafka-clients is ready
2020-04-15 00:47:35 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:113] Starting verifiableClient tls producer with following configuration VerifiableClient{allowedArguments=[TOPIC, BROKER_LIST, MAX_MESSAGES, THROUGHPUT, ACKS, PRODUCER_CONFIG, MESSAGE_CREATE_TIME, VALUE_PREFIX, REPEATING_KEYS, USER], lock=java.lang.Object@448cdb47, messages=[], arguments=[USER=alice, --broker-list, my-cluster-kafka-bootstrap:9093, --topic, test-topic-1217502653, --max-messages, 100], executable='/opt/kafka/producer.sh', executor=null, clientType=CLI_KAFKA_VERIFIABLE_PRODUCER, podName='my-cluster-kafka-clients-79bbb6849c-jk4n4', podNamespace='kafka-listeners-cluster-test', bootstrapServer='my-cluster-kafka-bootstrap:9093', topicName='test-topic-1217502653', maxMessages=100, kafkaUsername='alice', consumerGroupName='null', consumerInstanceId='null', clientArgumentMap=io.strimzi.systemtest.kafkaclients.internalClients.ClientArgumentMap@4628a02b}
2020-04-15 00:47:35 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:114] Sending 100 messages to my-cluster-kafka-bootstrap:9093#test-topic-1217502653
2020-04-15 00:47:38 &amp#27;[32mINFO &amp#27;[m [VerifiableClient:194] VerifiableClient CLI_KAFKA_VERIFIABLE_PRODUCER Return code - 0
2020-04-15 00:47:38 &amp#27;[32mINFO &amp#27;[m [VerifiableClient:196] VerifiableClient CLI_KAFKA_VERIFIABLE_PRODUCER stdout : /tmp/alice.properties
Starting Producer with configuration:
acks=all
security.protocol=SSL
ssl.truststore.location=/tmp/alice-truststore.p12
ssl.truststore.type=pkcs12
ssl.keystore.location=/tmp/alice-keystore.p12
ssl.keystore.type=pkcs12
ssl.endpoint.identification.algorithm=
ssl.keystore.password=aZ7D3TCiTQ4nLJF-q-6xtTxEKryQaby3
ssl.truststore.password=aZ7D3TCiTQ4nLJF-q-6xtTxEKryQaby3
[2020-04-15 00:47:37,668] INFO ProducerConfig values: 
	acks = all
	batch.size = 16384
	bootstrap.servers = [my-cluster-kafka-bootstrap:9093]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id = 
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 5
	max.request.size = 1048576
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 0
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/alice-keystore.p12
	ssl.keystore.password = [hidden]
	ssl.keystore.type = pkcs12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/alice-truststore.p12
	ssl.truststore.password = [hidden]
	ssl.truststore.type = pkcs12
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer
 (ProducerConfig:347)
[2020-04-15 00:47:37,698] DEBUG Added sensor with name bufferpool-wait-time (Metrics:416)
[2020-04-15 00:47:37,706] DEBUG Added sensor with name buffer-exhausted-records (Metrics:416)
[2020-04-15 00:47:37,721] DEBUG Added sensor with name errors (Metrics:416)
[2020-04-15 00:47:37,983] DEBUG Created SSL context with keystore SecurityStore(path=/tmp/alice-keystore.p12, modificationTime=Wed Apr 15 00:47:36 UTC 2020), truststore SecurityStore(path=/tmp/alice-truststore.p12, modificationTime=Wed Apr 15 00:47:36 UTC 2020), provider SunJSSE. (SslEngineBuilder:159)
[2020-04-15 00:47:37,989] DEBUG Added sensor with name produce-throttle-time (Metrics:416)
[2020-04-15 00:47:38,006] DEBUG Added sensor with name connections-closed: (Metrics:416)
[2020-04-15 00:47:38,007] DEBUG Added sensor with name connections-created: (Metrics:416)
[2020-04-15 00:47:38,008] DEBUG Added sensor with name successful-authentication: (Metrics:416)
[2020-04-15 00:47:38,009] DEBUG Added sensor with name successful-reauthentication: (Metrics:416)
[2020-04-15 00:47:38,009] DEBUG Added sensor with name successful-authentication-no-reauth: (Metrics:416)
[2020-04-15 00:47:38,009] DEBUG Added sensor with name failed-authentication: (Metrics:416)
[2020-04-15 00:47:38,010] DEBUG Added sensor with name failed-reauthentication: (Metrics:416)
[2020-04-15 00:47:38,010] DEBUG Added sensor with name reauthentication-latency: (Metrics:416)
[2020-04-15 00:47:38,011] DEBUG Added sensor with name bytes-sent-received: (Metrics:416)
[2020-04-15 00:47:38,011] DEBUG Added sensor with name bytes-sent: (Metrics:416)
[2020-04-15 00:47:38,015] DEBUG Added sensor with name bytes-received: (Metrics:416)
[2020-04-15 00:47:38,016] DEBUG Added sensor with name select-time: (Metrics:416)
[2020-04-15 00:47:38,017] DEBUG Added sensor with name io-time: (Metrics:416)
[2020-04-15 00:47:38,029] DEBUG Added sensor with name batch-size (Metrics:416)
[2020-04-15 00:47:38,029] DEBUG Added sensor with name compression-rate (Metrics:416)
[2020-04-15 00:47:38,030] DEBUG Added sensor with name queue-time (Metrics:416)
[2020-04-15 00:47:38,030] DEBUG Added sensor with name request-time (Metrics:416)
[2020-04-15 00:47:38,030] DEBUG Added sensor with name records-per-request (Metrics:416)
[2020-04-15 00:47:38,031] DEBUG Added sensor with name record-retries (Metrics:416)
[2020-04-15 00:47:38,031] DEBUG Added sensor with name record-size (Metrics:416)
[2020-04-15 00:47:38,033] DEBUG Added sensor with name batch-split-rate (Metrics:416)
[2020-04-15 00:47:38,036] DEBUG [Producer clientId=producer-1] Starting Kafka producer I/O thread. (Sender:239)
[2020-04-15 00:47:38,036] INFO Kafka version: 2.4.0 (AppInfoParser:117)
[2020-04-15 00:47:38,037] INFO Kafka commitId: 77a89fcf8d7fa018 (AppInfoParser:118)
[2020-04-15 00:47:38,037] INFO Kafka startTimeMs: 1586911658034 (AppInfoParser:119)
[2020-04-15 00:47:38,037] DEBUG [Producer clientId=producer-1] Initialize connection to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) for sending metadata request (NetworkClient:1125)
[2020-04-15 00:47:38,039] DEBUG [Producer clientId=producer-1] Kafka producer started (KafkaProducer:427)
[2020-04-15 00:47:38,050] DEBUG [Producer clientId=producer-1] Initiating connection to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) using address my-cluster-kafka-bootstrap/172.30.52.17 (NetworkClient:956)
[2020-04-15 00:47:38,068] DEBUG Added sensor with name node--1.bytes-sent (Metrics:416)
[2020-04-15 00:47:38,069] DEBUG Added sensor with name node--1.bytes-received (Metrics:416)
[2020-04-15 00:47:38,070] DEBUG Added sensor with name node--1.latency (Metrics:416)
[2020-04-15 00:47:38,070] DEBUG [Producer clientId=producer-1] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 (Selector:535)
[2020-04-15 00:47:38,259] DEBUG [Producer clientId=producer-1] Completed connection to node -1. Fetching API versions. (NetworkClient:914)
{"timestamp":1586911658235,"name":"startup_complete"}
[2020-04-15 00:47:38,345] DEBUG [SslTransportLayer channelId=-1 key=sun.nio.ch.SelectionKeyImpl@11f7519c] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:47:38,346] DEBUG [Producer clientId=producer-1] Successfully authenticated with my-cluster-kafka-bootstrap/172.30.52.17 (Selector:564)
[2020-04-15 00:47:38,346] DEBUG [Producer clientId=producer-1] Initiating API versions fetch from node -1. (NetworkClient:928)
[2020-04-15 00:47:38,502] DEBUG [Producer clientId=producer-1] Recorded API versions for node -1: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:47:38,503] DEBUG [Producer clientId=producer-1] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='test-topic-1217502653')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) (NetworkClient:1109)
[2020-04-15 00:47:38,535] DEBUG [Producer clientId=producer-1] Updating last seen epoch from null to 2 for partition test-topic-1217502653-0 (Metadata:178)
[2020-04-15 00:47:38,539] INFO [Producer clientId=producer-1] Cluster ID: FiXUEvIGTB6OchGaSyJltg (Metadata:261)
[2020-04-15 00:47:38,539] DEBUG [Producer clientId=producer-1] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='FiXUEvIGTB6OchGaSyJltg', nodes=[my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 0 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null)], partitions=[PartitionInfoAndEpoch{partitionInfo=Partition(topic = test-topic-1217502653, partition = 0, leader = 2, replicas = [2], isr = [2], offlineReplicas = []), epoch=2}], controller=my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 0 rack: null)} (Metadata:265)
[2020-04-15 00:47:38,568] DEBUG [Producer clientId=producer-1] Initiating connection to node my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) using address my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.16 (NetworkClient:956)
[2020-04-15 00:47:38,578] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (KafkaProducer:1183)
[2020-04-15 00:47:38,579] DEBUG Added sensor with name node-2.bytes-sent (Metrics:416)
[2020-04-15 00:47:38,580] DEBUG Added sensor with name node-2.bytes-received (Metrics:416)
[2020-04-15 00:47:38,581] DEBUG Added sensor with name node-2.latency (Metrics:416)
[2020-04-15 00:47:38,581] DEBUG [Producer clientId=producer-1] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 (Selector:535)
[2020-04-15 00:47:38,583] DEBUG [Producer clientId=producer-1] Completed connection to node 2. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:47:38,583] DEBUG [Producer clientId=producer-1] Beginning shutdown of Kafka producer I/O thread, sending remaining records. (Sender:250)
[2020-04-15 00:47:38,603] DEBUG [SslTransportLayer channelId=2 key=sun.nio.ch.SelectionKeyImpl@9b05de8] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:47:38,603] DEBUG [Producer clientId=producer-1] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.16 (Selector:564)
[2020-04-15 00:47:38,603] DEBUG [Producer clientId=producer-1] Initiating API versions fetch from node 2. (NetworkClient:928)
[2020-04-15 00:47:38,607] DEBUG [Producer clientId=producer-1] Recorded API versions for node 2: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:47:38,612] DEBUG Added sensor with name topic.test-topic-1217502653.records-per-batch (Metrics:416)
[2020-04-15 00:47:38,613] DEBUG Added sensor with name topic.test-topic-1217502653.bytes (Metrics:416)
[2020-04-15 00:47:38,614] DEBUG Added sensor with name topic.test-topic-1217502653.compression-rate (Metrics:416)
[2020-04-15 00:47:38,614] DEBUG Added sensor with name topic.test-topic-1217502653.record-retries (Metrics:416)
[2020-04-15 00:47:38,614] DEBUG Added sensor with name topic.test-topic-1217502653.record-errors (Metrics:416)
{"timestamp":1586911658632,"name":"producer_send_success","key":null,"value":"0","topic":"test-topic-1217502653","partition":0,"offset":200}
{"timestamp":1586911658635,"name":"producer_send_success","key":null,"value":"1","topic":"test-topic-1217502653","partition":0,"offset":201}
{"timestamp":1586911658635,"name":"producer_send_success","key":null,"value":"2","topic":"test-topic-1217502653","partition":0,"offset":202}
{"timestamp":1586911658636,"name":"producer_send_success","key":null,"value":"3","topic":"test-topic-1217502653","partition":0,"offset":203}
{"timestamp":1586911658636,"name":"producer_send_success","key":null,"value":"4","topic":"test-topic-1217502653","partition":0,"offset":204}
{"timestamp":1586911658636,"name":"producer_send_success","key":null,"value":"5","topic":"test-topic-1217502653","partition":0,"offset":205}
{"timestamp":1586911658636,"name":"producer_send_success","key":null,"value":"6","topic":"test-topic-1217502653","partition":0,"offset":206}
{"timestamp":1586911658636,"name":"producer_send_success","key":null,"value":"7","topic":"test-topic-1217502653","partition":0,"offset":207}
{"timestamp":1586911658636,"name":"producer_send_success","key":null,"value":"8","topic":"test-topic-1217502653","partition":0,"offset":208}
{"timestamp":1586911658636,"name":"producer_send_success","key":null,"value":"9","topic":"test-topic-1217502653","partition":0,"offset":209}
{"timestamp":1586911658637,"name":"producer_send_success","key":null,"value":"10","topic":"test-topic-1217502653","partition":0,"offset":210}
{"timestamp":1586911658637,"name":"producer_send_success","key":null,"value":"11","topic":"test-topic-1217502653","partition":0,"offset":211}
{"timestamp":1586911658637,"name":"producer_send_success","key":null,"value":"12","topic":"test-topic-1217502653","partition":0,"offset":212}
{"timestamp":1586911658637,"name":"producer_send_success","key":null,"value":"13","topic":"test-topic-1217502653","partition":0,"offset":213}
{"timestamp":1586911658637,"name":"producer_send_success","key":null,"value":"14","topic":"test-topic-1217502653","partition":0,"offset":214}
{"timestamp":1586911658638,"name":"producer_send_success","key":null,"value":"15","topic":"test-topic-1217502653","partition":0,"offset":215}
{"timestamp":1586911658640,"name":"producer_send_success","key":null,"value":"16","topic":"test-topic-1217502653","partition":0,"offset":216}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"17","topic":"test-topic-1217502653","partition":0,"offset":217}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"18","topic":"test-topic-1217502653","partition":0,"offset":218}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"19","topic":"test-topic-1217502653","partition":0,"offset":219}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"20","topic":"test-topic-1217502653","partition":0,"offset":220}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"21","topic":"test-topic-1217502653","partition":0,"offset":221}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"22","topic":"test-topic-1217502653","partition":0,"offset":222}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"23","topic":"test-topic-1217502653","partition":0,"offset":223}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"24","topic":"test-topic-1217502653","partition":0,"offset":224}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"25","topic":"test-topic-1217502653","partition":0,"offset":225}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"26","topic":"test-topic-1217502653","partition":0,"offset":226}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"27","topic":"test-topic-1217502653","partition":0,"offset":227}
{"timestamp":1586911658641,"name":"producer_send_success","key":null,"value":"28","topic":"test-topic-1217502653","partition":0,"offset":228}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"29","topic":"test-topic-1217502653","partition":0,"offset":229}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"30","topic":"test-topic-1217502653","partition":0,"offset":230}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"31","topic":"test-topic-1217502653","partition":0,"offset":231}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"32","topic":"test-topic-1217502653","partition":0,"offset":232}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"33","topic":"test-topic-1217502653","partition":0,"offset":233}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"34","topic":"test-topic-1217502653","partition":0,"offset":234}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"35","topic":"test-topic-1217502653","partition":0,"offset":235}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"36","topic":"test-topic-1217502653","partition":0,"offset":236}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"37","topic":"test-topic-1217502653","partition":0,"offset":237}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"38","topic":"test-topic-1217502653","partition":0,"offset":238}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"39","topic":"test-topic-1217502653","partition":0,"offset":239}
{"timestamp":1586911658642,"name":"producer_send_success","key":null,"value":"40","topic":"test-topic-1217502653","partition":0,"offset":240}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"41","topic":"test-topic-1217502653","partition":0,"offset":241}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"42","topic":"test-topic-1217502653","partition":0,"offset":242}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"43","topic":"test-topic-1217502653","partition":0,"offset":243}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"44","topic":"test-topic-1217502653","partition":0,"offset":244}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"45","topic":"test-topic-1217502653","partition":0,"offset":245}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"46","topic":"test-topic-1217502653","partition":0,"offset":246}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"47","topic":"test-topic-1217502653","partition":0,"offset":247}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"48","topic":"test-topic-1217502653","partition":0,"offset":248}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"49","topic":"test-topic-1217502653","partition":0,"offset":249}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"50","topic":"test-topic-1217502653","partition":0,"offset":250}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"51","topic":"test-topic-1217502653","partition":0,"offset":251}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"52","topic":"test-topic-1217502653","partition":0,"offset":252}
{"timestamp":1586911658643,"name":"producer_send_success","key":null,"value":"53","topic":"test-topic-1217502653","partition":0,"offset":253}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"54","topic":"test-topic-1217502653","partition":0,"offset":254}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"55","topic":"test-topic-1217502653","partition":0,"offset":255}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"56","topic":"test-topic-1217502653","partition":0,"offset":256}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"57","topic":"test-topic-1217502653","partition":0,"offset":257}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"58","topic":"test-topic-1217502653","partition":0,"offset":258}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"59","topic":"test-topic-1217502653","partition":0,"offset":259}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"60","topic":"test-topic-1217502653","partition":0,"offset":260}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"61","topic":"test-topic-1217502653","partition":0,"offset":261}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"62","topic":"test-topic-1217502653","partition":0,"offset":262}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"63","topic":"test-topic-1217502653","partition":0,"offset":263}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"64","topic":"test-topic-1217502653","partition":0,"offset":264}
{"timestamp":1586911658644,"name":"producer_send_success","key":null,"value":"65","topic":"test-topic-1217502653","partition":0,"offset":265}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"66","topic":"test-topic-1217502653","partition":0,"offset":266}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"67","topic":"test-topic-1217502653","partition":0,"offset":267}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"68","topic":"test-topic-1217502653","partition":0,"offset":268}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"69","topic":"test-topic-1217502653","partition":0,"offset":269}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"70","topic":"test-topic-1217502653","partition":0,"offset":270}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"71","topic":"test-topic-1217502653","partition":0,"offset":271}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"72","topic":"test-topic-1217502653","partition":0,"offset":272}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"73","topic":"test-topic-1217502653","partition":0,"offset":273}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"74","topic":"test-topic-1217502653","partition":0,"offset":274}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"75","topic":"test-topic-1217502653","partition":0,"offset":275}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"76","topic":"test-topic-1217502653","partition":0,"offset":276}
{"timestamp":1586911658645,"name":"producer_send_success","key":null,"value":"77","topic":"test-topic-1217502653","partition":0,"offset":277}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"78","topic":"test-topic-1217502653","partition":0,"offset":278}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"79","topic":"test-topic-1217502653","partition":0,"offset":279}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"80","topic":"test-topic-1217502653","partition":0,"offset":280}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"81","topic":"test-topic-1217502653","partition":0,"offset":281}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"82","topic":"test-topic-1217502653","partition":0,"offset":282}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"83","topic":"test-topic-1217502653","partition":0,"offset":283}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"84","topic":"test-topic-1217502653","partition":0,"offset":284}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"85","topic":"test-topic-1217502653","partition":0,"offset":285}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"86","topic":"test-topic-1217502653","partition":0,"offset":286}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"87","topic":"test-topic-1217502653","partition":0,"offset":287}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"88","topic":"test-topic-1217502653","partition":0,"offset":288}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"89","topic":"test-topic-1217502653","partition":0,"offset":289}
{"timestamp":1586911658646,"name":"producer_send_success","key":null,"value":"90","topic":"test-topic-1217502653","partition":0,"offset":290}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"91","topic":"test-topic-1217502653","partition":0,"offset":291}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"92","topic":"test-topic-1217502653","partition":0,"offset":292}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"93","topic":"test-topic-1217502653","partition":0,"offset":293}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"94","topic":"test-topic-1217502653","partition":0,"offset":294}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"95","topic":"test-topic-1217502653","partition":0,"offset":295}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"96","topic":"test-topic-1217502653","partition":0,"offset":296}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"97","topic":"test-topic-1217502653","partition":0,"offset":297}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"98","topic":"test-topic-1217502653","partition":0,"offset":298}
{"timestamp":1586911658647,"name":"producer_send_success","key":null,"value":"99","topic":"test-topic-1217502653","partition":0,"offset":299}
[2020-04-15 00:47:38,651] DEBUG Removed sensor with name connections-closed: (Metrics:449)
[2020-04-15 00:47:38,651] DEBUG Removed sensor with name connections-created: (Metrics:449)
[2020-04-15 00:47:38,652] DEBUG Removed sensor with name successful-authentication: (Metrics:449)
[2020-04-15 00:47:38,652] DEBUG Removed sensor with name successful-reauthentication: (Metrics:449)
[2020-04-15 00:47:38,652] DEBUG Removed sensor with name successful-authentication-no-reauth: (Metrics:449)
[2020-04-15 00:47:38,653] DEBUG Removed sensor with name failed-authentication: (Metrics:449)
[2020-04-15 00:47:38,653] DEBUG Removed sensor with name failed-reauthentication: (Metrics:449)
[2020-04-15 00:47:38,653] DEBUG Removed sensor with name reauthentication-latency: (Metrics:449)
[2020-04-15 00:47:38,654] DEBUG Removed sensor with name bytes-sent-received: (Metrics:449)
[2020-04-15 00:47:38,655] DEBUG Removed sensor with name bytes-sent: (Metrics:449)
[2020-04-15 00:47:38,655] DEBUG Removed sensor with name bytes-received: (Metrics:449)
[2020-04-15 00:47:38,656] DEBUG Removed sensor with name select-time: (Metrics:449)
[2020-04-15 00:47:38,656] DEBUG Removed sensor with name io-time: (Metrics:449)
[2020-04-15 00:47:38,657] DEBUG Removed sensor with name node--1.bytes-sent (Metrics:449)
[2020-04-15 00:47:38,657] DEBUG Removed sensor with name node--1.bytes-received (Metrics:449)
[2020-04-15 00:47:38,658] DEBUG Removed sensor with name node--1.latency (Metrics:449)
[2020-04-15 00:47:38,658] DEBUG Removed sensor with name node-2.bytes-sent (Metrics:449)
[2020-04-15 00:47:38,658] DEBUG Removed sensor with name node-2.bytes-received (Metrics:449)
[2020-04-15 00:47:38,659] DEBUG Removed sensor with name node-2.latency (Metrics:449)
[2020-04-15 00:47:38,659] DEBUG [Producer clientId=producer-1] Shutdown of Kafka producer I/O thread has completed. (Sender:292)
[2020-04-15 00:47:38,660] DEBUG [Producer clientId=producer-1] Kafka producer has been closed (KafkaProducer:1235)
{"timestamp":1586911658660,"name":"shutdown_complete"}
{"timestamp":1586911658662,"name":"tool_data","sent":100,"acked":100,"target_throughput":-1,"avg_throughput":233.10023310023308}

2020-04-15 00:47:38 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:117] Producer finished correctly: true
2020-04-15 00:47:38 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:121] Producer produced 100 messages
2020-04-15 00:47:38 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:181] Starting verifiableClient tls consumer with following configuration VerifiableClient{allowedArguments=[BROKER_LIST, TOPIC, GROUP_ID, MAX_MESSAGES, SESSION_TIMEOUT, VERBOSE, ENABLE_AUTOCOMMIT, RESET_POLICY, ASSIGMENT_STRATEGY, CONSUMER_CONFIG, USER, GROUP_INSTANCE_ID], lock=java.lang.Object@2b01c689, messages=[], arguments=[--group-instance-id, instance1178942979, USER=alice, --broker-list, my-cluster-kafka-bootstrap:9093, --group-id, consumer-group-certs-81, --topic, test-topic-1217502653, --max-messages, 300], executable='/opt/kafka/consumer.sh', executor=null, clientType=CLI_KAFKA_VERIFIABLE_CONSUMER, podName='my-cluster-kafka-clients-79bbb6849c-jk4n4', podNamespace='kafka-listeners-cluster-test', bootstrapServer='my-cluster-kafka-bootstrap:9093', topicName='test-topic-1217502653', maxMessages=300, kafkaUsername='alice', consumerGroupName='consumer-group-certs-81', consumerInstanceId='instance1178942979', clientArgumentMap=io.strimzi.systemtest.kafkaclients.internalClients.ClientArgumentMap@51424203}
2020-04-15 00:47:38 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:182] Wait for receive 300 messages from my-cluster-kafka-bootstrap:9093#test-topic-1217502653
2020-04-15 00:47:45 &amp#27;[32mINFO &amp#27;[m [VerifiableClient:194] VerifiableClient CLI_KAFKA_VERIFIABLE_CONSUMER Return code - 0
2020-04-15 00:47:45 &amp#27;[32mINFO &amp#27;[m [VerifiableClient:196] VerifiableClient CLI_KAFKA_VERIFIABLE_CONSUMER stdout : /tmp/alice.properties
Starting Consumer with configuration:
=auto.offset.reset=earliest
security.protocol=SSL
ssl.truststore.location=/tmp/alice-truststore.p12
ssl.truststore.type=pkcs12
ssl.keystore.location=/tmp/alice-keystore.p12
ssl.keystore.type=pkcs12
ssl.endpoint.identification.algorithm=
ssl.keystore.password=Gjcu7a6UQ8jCHLmnDy0pKyysut-D-qKC
ssl.truststore.password=Gjcu7a6UQ8jCHLmnDy0pKyysut-D-qKC
[2020-04-15 00:47:40,993] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [my-cluster-kafka-bootstrap:9093]
	check.crcs = true
	client.dns.lookup = default
	client.id = 
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = consumer-group-certs-81
	group.instance.id = instance1178942979
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 30000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/alice-keystore.p12
	ssl.keystore.password = [hidden]
	ssl.keystore.type = pkcs12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/alice-truststore.p12
	ssl.truststore.password = [hidden]
	ssl.truststore.type = pkcs12
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
 (ConsumerConfig:347)
[2020-04-15 00:47:41,023] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Initializing the Kafka consumer (KafkaConsumer:699)
[2020-04-15 00:47:41,305] DEBUG Created SSL context with keystore SecurityStore(path=/tmp/alice-keystore.p12, modificationTime=Wed Apr 15 00:47:39 UTC 2020), truststore SecurityStore(path=/tmp/alice-truststore.p12, modificationTime=Wed Apr 15 00:47:39 UTC 2020), provider SunJSSE. (SslEngineBuilder:159)
[2020-04-15 00:47:41,317] DEBUG Added sensor with name fetch-throttle-time (Metrics:416)
[2020-04-15 00:47:41,329] DEBUG Added sensor with name connections-closed: (Metrics:416)
[2020-04-15 00:47:41,334] DEBUG Added sensor with name connections-created: (Metrics:416)
[2020-04-15 00:47:41,334] DEBUG Added sensor with name successful-authentication: (Metrics:416)
[2020-04-15 00:47:41,335] DEBUG Added sensor with name successful-reauthentication: (Metrics:416)
[2020-04-15 00:47:41,336] DEBUG Added sensor with name successful-authentication-no-reauth: (Metrics:416)
[2020-04-15 00:47:41,336] DEBUG Added sensor with name failed-authentication: (Metrics:416)
[2020-04-15 00:47:41,337] DEBUG Added sensor with name failed-reauthentication: (Metrics:416)
[2020-04-15 00:47:41,338] DEBUG Added sensor with name reauthentication-latency: (Metrics:416)
[2020-04-15 00:47:41,338] DEBUG Added sensor with name bytes-sent-received: (Metrics:416)
[2020-04-15 00:47:41,339] DEBUG Added sensor with name bytes-sent: (Metrics:416)
[2020-04-15 00:47:41,341] DEBUG Added sensor with name bytes-received: (Metrics:416)
[2020-04-15 00:47:41,342] DEBUG Added sensor with name select-time: (Metrics:416)
[2020-04-15 00:47:41,344] DEBUG Added sensor with name io-time: (Metrics:416)
[2020-04-15 00:47:41,366] DEBUG Added sensor with name heartbeat-latency (Metrics:416)
[2020-04-15 00:47:41,367] DEBUG Added sensor with name join-latency (Metrics:416)
[2020-04-15 00:47:41,367] DEBUG Added sensor with name sync-latency (Metrics:416)
[2020-04-15 00:47:41,368] DEBUG Added sensor with name rebalance-latency (Metrics:416)
[2020-04-15 00:47:41,368] DEBUG Added sensor with name failed-rebalance (Metrics:416)
[2020-04-15 00:47:41,371] DEBUG Added sensor with name commit-latency (Metrics:416)
[2020-04-15 00:47:41,371] DEBUG Added sensor with name partition-revoked-latency (Metrics:416)
[2020-04-15 00:47:41,371] DEBUG Added sensor with name partition-assigned-latency (Metrics:416)
[2020-04-15 00:47:41,372] DEBUG Added sensor with name partition-lost-latency (Metrics:416)
[2020-04-15 00:47:41,374] DEBUG Added sensor with name bytes-fetched (Metrics:416)
[2020-04-15 00:47:41,375] DEBUG Added sensor with name records-fetched (Metrics:416)
[2020-04-15 00:47:41,375] DEBUG Added sensor with name fetch-latency (Metrics:416)
[2020-04-15 00:47:41,376] DEBUG Added sensor with name records-lag (Metrics:416)
[2020-04-15 00:47:41,376] DEBUG Added sensor with name records-lead (Metrics:416)
[2020-04-15 00:47:41,378] DEBUG Added sensor with name time-between-poll (Metrics:416)
[2020-04-15 00:47:41,379] DEBUG Added sensor with name poll-idle-ratio-avg (Metrics:416)
[2020-04-15 00:47:41,379] WARN The configuration '' was supplied but isn't a known config. (ConsumerConfig:355)
[2020-04-15 00:47:41,380] INFO Kafka version: 2.4.0 (AppInfoParser:117)
[2020-04-15 00:47:41,381] INFO Kafka commitId: 77a89fcf8d7fa018 (AppInfoParser:118)
[2020-04-15 00:47:41,381] INFO Kafka startTimeMs: 1586911661379 (AppInfoParser:119)
[2020-04-15 00:47:41,382] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Kafka consumer initialized (KafkaConsumer:815)
{"timestamp":1586911661518,"name":"startup_complete"}
[2020-04-15 00:47:41,562] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Subscribed to topic(s): test-topic-1217502653 (KafkaConsumer:969)
[2020-04-15 00:47:41,564] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Sending FindCoordinator request to broker my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) (AbstractCoordinator:727)
[2020-04-15 00:47:41,709] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Initiating connection to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) using address my-cluster-kafka-bootstrap/172.30.52.17 (NetworkClient:956)
[2020-04-15 00:47:41,730] DEBUG Added sensor with name node--1.bytes-sent (Metrics:416)
[2020-04-15 00:47:41,731] DEBUG Added sensor with name node--1.bytes-received (Metrics:416)
[2020-04-15 00:47:41,732] DEBUG Added sensor with name node--1.latency (Metrics:416)
[2020-04-15 00:47:41,732] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 (Selector:535)
[2020-04-15 00:47:41,748] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Completed connection to node -1. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:47:41,845] DEBUG [SslTransportLayer channelId=-1 key=sun.nio.ch.SelectionKeyImpl@140c9f39] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:47:41,845] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Successfully authenticated with my-cluster-kafka-bootstrap/172.30.52.17 (Selector:564)
[2020-04-15 00:47:41,846] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Initiating API versions fetch from node -1. (NetworkClient:928)
[2020-04-15 00:47:42,025] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Recorded API versions for node -1: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:47:42,026] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='test-topic-1217502653')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) (NetworkClient:1109)
[2020-04-15 00:47:42,046] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Updating last seen epoch from null to 2 for partition test-topic-1217502653-0 (Metadata:178)
[2020-04-15 00:47:42,050] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Cluster ID: FiXUEvIGTB6OchGaSyJltg (Metadata:261)
[2020-04-15 00:47:42,051] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='FiXUEvIGTB6OchGaSyJltg', nodes=[my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 0 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null)], partitions=[PartitionInfoAndEpoch{partitionInfo=Partition(topic = test-topic-1217502653, partition = 0, leader = 2, replicas = [2], isr = [2], offlineReplicas = []), epoch=2}], controller=my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 0 rack: null)} (Metadata:265)
[2020-04-15 00:47:42,053] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Received FindCoordinator response ClientResponse(receivedTimeMs=1586911662052, latencyMs=347, disconnected=false, requestHeader=RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=3, clientId=consumer-consumer-group-certs-81-instance1178942979, correlationId=0), responseBody=FindCoordinatorResponseData(throttleTimeMs=0, errorCode=0, errorMessage='NONE', nodeId=0, host='my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc', port=9093)) (AbstractCoordinator:741)
[2020-04-15 00:47:42,053] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Discovered group coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2147483647 rack: null) (AbstractCoordinator:756)
[2020-04-15 00:47:42,055] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Initiating connection to node my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2147483647 rack: null) using address my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.17 (NetworkClient:956)
[2020-04-15 00:47:42,067] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Executing onJoinPrepare with generation -1 and memberId  (ConsumerCoordinator:633)
[2020-04-15 00:47:42,067] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Disabling heartbeat thread (AbstractCoordinator:1169)
[2020-04-15 00:47:42,067] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] (Re-)joining group (AbstractCoordinator:533)
[2020-04-15 00:47:42,068] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Heartbeat thread started (AbstractCoordinator:1192)
[2020-04-15 00:47:42,068] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Joining group with current subscription: [test-topic-1217502653] (ConsumerCoordinator:206)
[2020-04-15 00:47:42,071] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Sending JoinGroup (JoinGroupRequestData(groupId='consumer-group-certs-81', sessionTimeoutMs=30000, rebalanceTimeoutMs=300000, memberId='', groupInstanceId='instance1178942979', protocolType='consumer', protocols=[JoinGroupRequestProtocol(name='range', metadata=[0, 1, 0, 0, 0, 1, 0, 21, 116, 101, 115, 116, 45, 116, 111, 112, 105, 99, 45, 49, 50, 49, 55, 53, 48, 50, 54, 53, 51, -1, -1, -1, -1, 0, 0, 0, 0])])) to coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2147483647 rack: null) (AbstractCoordinator:545)
[2020-04-15 00:47:42,072] DEBUG Added sensor with name node-2147483647.bytes-sent (Metrics:416)
[2020-04-15 00:47:42,073] DEBUG Added sensor with name node-2147483647.bytes-received (Metrics:416)
[2020-04-15 00:47:42,073] DEBUG Added sensor with name node-2147483647.latency (Metrics:416)
[2020-04-15 00:47:42,074] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147483647 (Selector:535)
[2020-04-15 00:47:42,076] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Completed connection to node 2147483647. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:47:42,097] DEBUG [SslTransportLayer channelId=2147483647 key=sun.nio.ch.SelectionKeyImpl@5276d6ee] SSL handshake completed successfully with peerHost 'my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:47:42,097] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Successfully authenticated with my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.17 (Selector:564)
[2020-04-15 00:47:42,097] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Initiating API versions fetch from node 2147483647. (NetworkClient:928)
[2020-04-15 00:47:42,101] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Recorded API versions for node 2147483647: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:47:45,139] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Received successful JoinGroup response: JoinGroupResponseData(throttleTimeMs=0, errorCode=0, generationId=1, protocolName='range', leader='instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4', memberId='instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4', members=[JoinGroupResponseMember(memberId='instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4', groupInstanceId='instance1178942979', metadata=[0, 1, 0, 0, 0, 1, 0, 21, 116, 101, 115, 116, 45, 116, 111, 112, 105, 99, 45, 49, 50, 49, 55, 53, 48, 50, 54, 53, 51, -1, -1, -1, -1, 0, 0, 0, 0])]) (AbstractCoordinator:560)
[2020-04-15 00:47:45,139] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Performing assignment using strategy range with subscriptions {instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4=org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Subscription@38145825} (ConsumerCoordinator:546)
[2020-04-15 00:47:45,142] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Finished assignment for group at generation 1: {instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4=org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Assignment@1df8da7a} (ConsumerCoordinator:585)
[2020-04-15 00:47:45,142] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Sending leader SyncGroup to coordinator my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2147483647 rack: null) at generation Generation{generationId=1, memberId='instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4', protocol='range'}: SyncGroupRequestData(groupId='consumer-group-certs-81', generationId=1, memberId='instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4', groupInstanceId='instance1178942979', assignments=[SyncGroupRequestAssignment(memberId='instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4', assignment=[0, 1, 0, 0, 0, 1, 0, 21, 116, 101, 115, 116, 45, 116, 111, 112, 105, 99, 45, 49, 50, 49, 55, 53, 48, 50, 54, 53, 51, 0, 0, 0, 1, 0, 0, 0, 0, -1, -1, -1, -1])]) (AbstractCoordinator:670)
[2020-04-15 00:47:45,263] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Successfully joined group with generation 1 (AbstractCoordinator:484)
[2020-04-15 00:47:45,264] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Enabling heartbeat thread (AbstractCoordinator:1160)
[2020-04-15 00:47:45,264] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Executing onJoinComplete with generation 1 and memberId instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4 (ConsumerCoordinator:328)
[2020-04-15 00:47:45,269] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Adding newly assigned partitions: test-topic-1217502653-0 (ConsumerCoordinator:267)
{"timestamp":1586911665269,"name":"partitions_assigned","partitions":[{"topic":"test-topic-1217502653","partition":0}]}
[2020-04-15 00:47:45,306] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Fetching committed offsets for partitions: [test-topic-1217502653-0] (ConsumerCoordinator:1182)
[2020-04-15 00:47:45,321] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Found no committed offset for partition test-topic-1217502653-0 (ConsumerCoordinator:1241)
[2020-04-15 00:47:45,327] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Sending ListOffsetRequest (type=ListOffsetRequest, replicaId=-1, partitionTimestamps={test-topic-1217502653-0={timestamp: -2, maxNumOffsets: 1, currentLeaderEpoch: Optional[2]}}, isolationLevel=READ_UNCOMMITTED) to broker my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) (Fetcher:946)
[2020-04-15 00:47:45,334] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Initiating connection to node my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) using address my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.16 (NetworkClient:956)
[2020-04-15 00:47:45,337] DEBUG Added sensor with name node-2.bytes-sent (Metrics:416)
[2020-04-15 00:47:45,338] DEBUG Added sensor with name node-2.bytes-received (Metrics:416)
[2020-04-15 00:47:45,339] DEBUG Added sensor with name node-2.latency (Metrics:416)
[2020-04-15 00:47:45,340] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 (Selector:535)
[2020-04-15 00:47:45,344] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Completed connection to node 2. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:47:45,374] DEBUG [SslTransportLayer channelId=2 key=sun.nio.ch.SelectionKeyImpl@4149c063] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:47:45,374] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.16 (Selector:564)
[2020-04-15 00:47:45,374] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Initiating API versions fetch from node 2. (NetworkClient:928)
[2020-04-15 00:47:45,382] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Recorded API versions for node 2: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:47:45,390] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Handling ListOffsetResponse response for test-topic-1217502653-0. Fetched offset 0, timestamp -1 (Fetcher:1002)
[2020-04-15 00:47:45,394] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Not replacing existing epoch 2 with new epoch 0 for partition test-topic-1217502653-0 (Metadata:185)
[2020-04-15 00:47:45,395] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Resetting offset for partition test-topic-1217502653-0 to offset 0. (SubscriptionState:385)
[2020-04-15 00:47:45,399] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Added READ_UNCOMMITTED fetch request for partition test-topic-1217502653-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null), epoch=2}} to node my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) (Fetcher:1138)
[2020-04-15 00:47:45,400] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Built full fetch (sessionId=INVALID, epoch=INITIAL) for node 2 with 1 partition(s). (FetchSessionHandler:200)
[2020-04-15 00:47:45,401] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Sending READ_UNCOMMITTED FullFetchRequest(test-topic-1217502653-0) to broker my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) (Fetcher:259)
[2020-04-15 00:47:45,424] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Node 2 sent a full fetch response that created a new incremental fetch session 1118269887 with 1 response partition(s) (FetchSessionHandler:407)
[2020-04-15 00:47:45,425] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Fetch READ_UNCOMMITTED at offset 0 for partition test-topic-1217502653-0 returned fetch data (error=NONE, highWaterMark=300, lastStableOffset = 300, logStartOffset = 0, preferredReadReplica = absent, abortedTransactions = null, recordsSizeInBytes=22167) (Fetcher:308)
[2020-04-15 00:47:45,460] DEBUG Added sensor with name topic.test-topic-1217502653.bytes-fetched (Metrics:416)
[2020-04-15 00:47:45,461] DEBUG Added sensor with name topic.test-topic-1217502653.records-fetched (Metrics:416)
[2020-04-15 00:47:45,462] DEBUG Added sensor with name test-topic-1217502653-0.records-lag (Metrics:416)
[2020-04-15 00:47:45,463] DEBUG Added sensor with name test-topic-1217502653-0.records-lead (Metrics:416)
[2020-04-15 00:47:45,464] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Added READ_UNCOMMITTED fetch request for partition test-topic-1217502653-0 at position FetchPosition{offset=300, offsetEpoch=Optional[2], currentLeader=LeaderAndEpoch{leader=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null), epoch=2}} to node my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) (Fetcher:1138)
[2020-04-15 00:47:45,464] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Built incremental fetch (sessionId=1118269887, epoch=1) for node 2. Added 0 partition(s), altered 1 partition(s), removed 0 partition(s) out of 1 partition(s) (FetchSessionHandler:253)
[2020-04-15 00:47:45,465] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(test-topic-1217502653-0), toForget=(), implied=()) to broker my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) (Fetcher:259)
{"timestamp":1586911665468,"name":"records_consumed","count":300,"partitions":[{"topic":"test-topic-1217502653","partition":0,"count":300,"minOffset":0,"maxOffset":299}]}
[2020-04-15 00:47:45,509] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Committed offset 300 for partition test-topic-1217502653-0 (ConsumerCoordinator:1103)
{"timestamp":1586911665510,"name":"offsets_committed","offsets":[{"topic":"test-topic-1217502653","partition":0,"offset":300}],"success":true}
[2020-04-15 00:47:45,515] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Heartbeat thread has closed (AbstractCoordinator:1287)
[2020-04-15 00:47:45,516] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Executing onLeavePrepare with generation Generation{generationId=1, memberId='instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4', protocol='range'} and memberId instance1178942979-22ff1d53-4efe-4e48-b4fd-5495122885d4 (ConsumerCoordinator:699)
[2020-04-15 00:47:45,516] INFO [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Revoke previously assigned partitions test-topic-1217502653-0 (ConsumerCoordinator:286)
{"timestamp":1586911665517,"name":"partitions_revoked","partitions":[{"topic":"test-topic-1217502653","partition":0}]}
[2020-04-15 00:47:45,518] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Resetting generation due to consumer pro-actively leaving the group (AbstractCoordinator:860)
[2020-04-15 00:47:45,520] DEBUG Removed sensor with name connections-closed: (Metrics:449)
[2020-04-15 00:47:45,520] DEBUG Removed sensor with name connections-created: (Metrics:449)
[2020-04-15 00:47:45,520] DEBUG Removed sensor with name successful-authentication: (Metrics:449)
[2020-04-15 00:47:45,521] DEBUG Removed sensor with name successful-reauthentication: (Metrics:449)
[2020-04-15 00:47:45,521] DEBUG Removed sensor with name successful-authentication-no-reauth: (Metrics:449)
[2020-04-15 00:47:45,521] DEBUG Removed sensor with name failed-authentication: (Metrics:449)
[2020-04-15 00:47:45,521] DEBUG Removed sensor with name failed-reauthentication: (Metrics:449)
[2020-04-15 00:47:45,522] DEBUG Removed sensor with name reauthentication-latency: (Metrics:449)
[2020-04-15 00:47:45,522] DEBUG Removed sensor with name bytes-sent-received: (Metrics:449)
[2020-04-15 00:47:45,522] DEBUG Removed sensor with name bytes-sent: (Metrics:449)
[2020-04-15 00:47:45,523] DEBUG Removed sensor with name bytes-received: (Metrics:449)
[2020-04-15 00:47:45,523] DEBUG Removed sensor with name select-time: (Metrics:449)
[2020-04-15 00:47:45,523] DEBUG Removed sensor with name io-time: (Metrics:449)
[2020-04-15 00:47:45,524] DEBUG Removed sensor with name node--1.bytes-sent (Metrics:449)
[2020-04-15 00:47:45,524] DEBUG Removed sensor with name node--1.bytes-received (Metrics:449)
[2020-04-15 00:47:45,526] DEBUG Removed sensor with name node--1.latency (Metrics:449)
[2020-04-15 00:47:45,527] DEBUG Removed sensor with name node-2147483647.bytes-sent (Metrics:449)
[2020-04-15 00:47:45,527] DEBUG Removed sensor with name node-2147483647.bytes-received (Metrics:449)
[2020-04-15 00:47:45,527] DEBUG Removed sensor with name node-2147483647.latency (Metrics:449)
[2020-04-15 00:47:45,527] DEBUG Removed sensor with name node-2.bytes-sent (Metrics:449)
[2020-04-15 00:47:45,528] DEBUG Removed sensor with name node-2.bytes-received (Metrics:449)
[2020-04-15 00:47:45,528] DEBUG Removed sensor with name node-2.latency (Metrics:449)
[2020-04-15 00:47:45,528] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Kafka consumer has been closed (KafkaConsumer:2306)
{"timestamp":1586911665529,"name":"shutdown_complete"}
[2020-04-15 00:47:45,531] DEBUG [Consumer instanceId=instance1178942979, clientId=consumer-consumer-group-certs-81-instance1178942979, groupId=consumer-group-certs-81] Received user wakeup (ConsumerNetworkClient:186)
0

2020-04-15 00:47:45 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:185] Consumer finished correctly: true
2020-04-15 00:47:45 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:188] Consumer consumed 300 messages
2020-04-15 00:47:46 &amp#27;[32mINFO &amp#27;[m [StatefulSetUtils:101] Waiting for StatefulSet my-cluster-kafka rolling update
2020-04-15 00:52:46 &amp#27;[32mINFO &amp#27;[m [StatefulSetUtils:111] StatefulSet my-cluster-kafka rolling update finished
2020-04-15 00:55:22 &amp#27;[32mINFO &amp#27;[m [ListenersST:649] Check if KafkaStatus certificates are the same as secret certificates
2020-04-15 00:55:22 &amp#27;[32mINFO &amp#27;[m [ListenersST:651] Check if KafkaStatus certificates from internal TLS listener are the same as secret certificates
2020-04-15 00:55:22 &amp#27;[32mINFO &amp#27;[m [BasicExternalKafkaClient:101] Going to use the following CA certificate: custom-certificate-server-1
2020-04-15 00:55:22 &amp#27;[32mINFO &amp#27;[m [Producer:36] Creating instance of Vert.x for the client io.strimzi.systemtest.kafkaclients.externalClients.Producer
2020-04-15 00:55:22 &amp#27;[32mINFO &amp#27;[m [Producer:38] Producer is starting with following properties: {ssl.keystore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties3434629702568232282.keystore, bootstrap.servers=172.29.74.29:9094, key.serializer=org.apache.kafka.common.serialization.StringSerializer, ssl.truststore.type=PKCS12, security.protocol=SSL, ssl.keystore.type=PKCS12, value.serializer=org.apache.kafka.common.serialization.StringSerializer, ssl.truststore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties13271087940977074777.truststore, ssl.keystore.password=foo, sasl.mechanism=, ssl.truststore.password=foo, client.id=alice-producer, ssl.endpoint.identification.algorithm=}
2020-04-15 00:55:22 &amp#27;[32mINFO &amp#27;[m [ProducerConfig:347] ProducerConfig values: 
	acks = 1
	batch.size = 16384
	bootstrap.servers = [172.29.74.29:9094]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id = alice-producer
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 5
	max.request.size = 1048576
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = 
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties3434629702568232282.keystore
	ssl.keystore.password = [hidden]
	ssl.keystore.type = PKCS12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties13271087940977074777.truststore
	ssl.truststore.password = [hidden]
	ssl.truststore.type = PKCS12
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer

2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:117] Kafka version: 2.4.0
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:118] Kafka commitId: 77a89fcf8d7fa018
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:119] Kafka startTimeMs: 1586912123001
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [Metadata:261] [Producer clientId=alice-producer] Cluster ID: FiXUEvIGTB6OchGaSyJltg
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [Producer:79] Producer produced 100 messages
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [Producer:57] Closing Vert.x instance for the client io.strimzi.systemtest.kafkaclients.externalClients.Producer
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [BasicExternalKafkaClient:182] Going to use the following CA certificate: custom-certificate-server-1
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [KafkaProducer:1183] [Producer clientId=alice-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [Consumer:34] Consumer is starting with following properties: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=my-consumer-group-2086643474, ssl.keystore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties7497439029674795253.keystore, bootstrap.servers=172.29.74.29:9094, ssl.truststore.type=PKCS12, security.protocol=SSL, ssl.keystore.type=PKCS12, ssl.truststore.location=/tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties14247131652490264078.truststore, ssl.keystore.password=foo, sasl.mechanism=, ssl.truststore.password=foo, auto.offset.reset=earliest, client.id=alice-consumer, ssl.endpoint.identification.algorithm=}
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [ConsumerConfig:347] ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [172.29.74.29:9094]
	check.crcs = true
	client.dns.lookup = default
	client.id = alice-consumer
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = true
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = my-consumer-group-2086643474
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = 
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties7497439029674795253.keystore
	ssl.keystore.password = [hidden]
	ssl.keystore.type = PKCS12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/io.strimzi.systemtest.kafkaclients.KafkaClientProperties14247131652490264078.truststore
	ssl.truststore.password = [hidden]
	ssl.truststore.type = PKCS12
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer

2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:117] Kafka version: 2.4.0
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:118] Kafka commitId: 77a89fcf8d7fa018
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AppInfoParser:119] Kafka startTimeMs: 1586912123643
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [KafkaConsumer:969] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Subscribed to topic(s): test-topic-1217502653
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [Metadata:261] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Cluster ID: FiXUEvIGTB6OchGaSyJltg
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:756] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Discovered group coordinator 172.29.82.224:9094 (id: 2147483645 rack: null)
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:533] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] (Re-)joining group
2020-04-15 00:55:23 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:533] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] (Re-)joining group
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:585] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Finished assignment for group at generation 3: {alice-consumer-cf4b7018-e112-471a-8374-9d28e7a809da=org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Assignment@62f9d55a}
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:484] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Successfully joined group with generation 3
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:267] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Adding newly assigned partitions: test-topic-1217502653-0
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:762] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Setting offset for partition test-topic-1217502653-0 to the committed offset FetchPosition{offset=200, offsetEpoch=Optional[2], currentLeader=LeaderAndEpoch{leader=172.29.82.224:9094 (id: 2 rack: null), epoch=4}}
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [Consumer:55] Consumer consumed 100 messages
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [Consumer:68] Closing Vert.x instance for the client io.strimzi.systemtest.kafkaclients.externalClients.Consumer
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:113] Starting verifiableClient tls producer with following configuration VerifiableClient{allowedArguments=[TOPIC, BROKER_LIST, MAX_MESSAGES, THROUGHPUT, ACKS, PRODUCER_CONFIG, MESSAGE_CREATE_TIME, VALUE_PREFIX, REPEATING_KEYS, USER], lock=java.lang.Object@6fe04f2a, messages=[], arguments=[USER=alice, --broker-list, my-cluster-kafka-bootstrap:9093, --topic, test-topic-1217502653, --max-messages, 300], executable='/opt/kafka/producer.sh', executor=null, clientType=CLI_KAFKA_VERIFIABLE_PRODUCER, podName='my-cluster-kafka-clients-79bbb6849c-jk4n4', podNamespace='kafka-listeners-cluster-test', bootstrapServer='my-cluster-kafka-bootstrap:9093', topicName='test-topic-1217502653', maxMessages=300, kafkaUsername='alice', consumerGroupName='null', consumerInstanceId='null', clientArgumentMap=io.strimzi.systemtest.kafkaclients.internalClients.ClientArgumentMap@1f758e4f}
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:114] Sending 300 messages to my-cluster-kafka-bootstrap:9093#test-topic-1217502653
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [ConsumerCoordinator:286] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Revoke previously assigned partitions test-topic-1217502653-0
2020-04-15 00:55:26 &amp#27;[32mINFO &amp#27;[m [AbstractCoordinator:916] [Consumer clientId=alice-consumer, groupId=my-consumer-group-2086643474] Member alice-consumer-cf4b7018-e112-471a-8374-9d28e7a809da sending LeaveGroup request to coordinator 172.29.82.224:9094 (id: 2147483645 rack: null) due to the consumer is being closed
2020-04-15 00:55:30 &amp#27;[32mINFO &amp#27;[m [VerifiableClient:194] VerifiableClient CLI_KAFKA_VERIFIABLE_PRODUCER Return code - 0
2020-04-15 00:55:30 &amp#27;[32mINFO &amp#27;[m [VerifiableClient:196] VerifiableClient CLI_KAFKA_VERIFIABLE_PRODUCER stdout : /tmp/alice.properties
Starting Producer with configuration:
acks=all
security.protocol=SSL
ssl.truststore.location=/tmp/alice-truststore.p12
ssl.truststore.type=pkcs12
ssl.keystore.location=/tmp/alice-keystore.p12
ssl.keystore.type=pkcs12
ssl.endpoint.identification.algorithm=
ssl.keystore.password=BJ8Fa3RULlWMhUw1f3J3ldX3mQThZaXg
ssl.truststore.password=BJ8Fa3RULlWMhUw1f3J3ldX3mQThZaXg
[2020-04-15 00:55:28,971] INFO ProducerConfig values: 
	acks = all
	batch.size = 16384
	bootstrap.servers = [my-cluster-kafka-bootstrap:9093]
	buffer.memory = 33554432
	client.dns.lookup = default
	client.id = 
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = false
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 0
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 5
	max.request.size = 1048576
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 0
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/alice-keystore.p12
	ssl.keystore.password = [hidden]
	ssl.keystore.type = pkcs12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/alice-truststore.p12
	ssl.truststore.password = [hidden]
	ssl.truststore.type = pkcs12
	transaction.timeout.ms = 60000
	transactional.id = null
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer
 (ProducerConfig:347)
[2020-04-15 00:55:28,998] DEBUG Added sensor with name bufferpool-wait-time (Metrics:416)
[2020-04-15 00:55:29,003] DEBUG Added sensor with name buffer-exhausted-records (Metrics:416)
[2020-04-15 00:55:29,010] DEBUG Added sensor with name errors (Metrics:416)
[2020-04-15 00:55:29,272] DEBUG Created SSL context with keystore SecurityStore(path=/tmp/alice-keystore.p12, modificationTime=Wed Apr 15 00:55:27 UTC 2020), truststore SecurityStore(path=/tmp/alice-truststore.p12, modificationTime=Wed Apr 15 00:55:27 UTC 2020), provider SunJSSE. (SslEngineBuilder:159)
[2020-04-15 00:55:29,278] DEBUG Added sensor with name produce-throttle-time (Metrics:416)
[2020-04-15 00:55:29,293] DEBUG Added sensor with name connections-closed: (Metrics:416)
[2020-04-15 00:55:29,293] DEBUG Added sensor with name connections-created: (Metrics:416)
[2020-04-15 00:55:29,294] DEBUG Added sensor with name successful-authentication: (Metrics:416)
[2020-04-15 00:55:29,294] DEBUG Added sensor with name successful-reauthentication: (Metrics:416)
[2020-04-15 00:55:29,296] DEBUG Added sensor with name successful-authentication-no-reauth: (Metrics:416)
[2020-04-15 00:55:29,296] DEBUG Added sensor with name failed-authentication: (Metrics:416)
[2020-04-15 00:55:29,297] DEBUG Added sensor with name failed-reauthentication: (Metrics:416)
[2020-04-15 00:55:29,297] DEBUG Added sensor with name reauthentication-latency: (Metrics:416)
[2020-04-15 00:55:29,298] DEBUG Added sensor with name bytes-sent-received: (Metrics:416)
[2020-04-15 00:55:29,299] DEBUG Added sensor with name bytes-sent: (Metrics:416)
[2020-04-15 00:55:29,301] DEBUG Added sensor with name bytes-received: (Metrics:416)
[2020-04-15 00:55:29,301] DEBUG Added sensor with name select-time: (Metrics:416)
[2020-04-15 00:55:29,302] DEBUG Added sensor with name io-time: (Metrics:416)
[2020-04-15 00:55:29,310] DEBUG Added sensor with name batch-size (Metrics:416)
[2020-04-15 00:55:29,310] DEBUG Added sensor with name compression-rate (Metrics:416)
[2020-04-15 00:55:29,311] DEBUG Added sensor with name queue-time (Metrics:416)
[2020-04-15 00:55:29,311] DEBUG Added sensor with name request-time (Metrics:416)
[2020-04-15 00:55:29,312] DEBUG Added sensor with name records-per-request (Metrics:416)
[2020-04-15 00:55:29,312] DEBUG Added sensor with name record-retries (Metrics:416)
[2020-04-15 00:55:29,313] DEBUG Added sensor with name record-size (Metrics:416)
[2020-04-15 00:55:29,315] DEBUG Added sensor with name batch-split-rate (Metrics:416)
[2020-04-15 00:55:29,318] INFO Kafka version: 2.4.0 (AppInfoParser:117)
[2020-04-15 00:55:29,318] INFO Kafka commitId: 77a89fcf8d7fa018 (AppInfoParser:118)
[2020-04-15 00:55:29,318] INFO Kafka startTimeMs: 1586912129317 (AppInfoParser:119)
[2020-04-15 00:55:29,320] DEBUG [Producer clientId=producer-1] Kafka producer started (KafkaProducer:427)
[2020-04-15 00:55:29,327] DEBUG [Producer clientId=producer-1] Starting Kafka producer I/O thread. (Sender:239)
[2020-04-15 00:55:29,328] DEBUG [Producer clientId=producer-1] Initialize connection to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) for sending metadata request (NetworkClient:1125)
[2020-04-15 00:55:29,329] DEBUG [Producer clientId=producer-1] Initiating connection to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) using address my-cluster-kafka-bootstrap/172.30.52.17 (NetworkClient:956)
[2020-04-15 00:55:29,359] DEBUG Added sensor with name node--1.bytes-sent (Metrics:416)
[2020-04-15 00:55:29,360] DEBUG Added sensor with name node--1.bytes-received (Metrics:416)
[2020-04-15 00:55:29,361] DEBUG Added sensor with name node--1.latency (Metrics:416)
[2020-04-15 00:55:29,362] DEBUG [Producer clientId=producer-1] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 (Selector:535)
{"timestamp":1586912129529,"name":"startup_complete"}
[2020-04-15 00:55:29,604] DEBUG [Producer clientId=producer-1] Completed connection to node -1. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:55:29,676] DEBUG [SslTransportLayer channelId=-1 key=sun.nio.ch.SelectionKeyImpl@1b142942] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:55:29,676] DEBUG [Producer clientId=producer-1] Successfully authenticated with my-cluster-kafka-bootstrap/172.30.52.17 (Selector:564)
[2020-04-15 00:55:29,677] DEBUG [Producer clientId=producer-1] Initiating API versions fetch from node -1. (NetworkClient:928)
[2020-04-15 00:55:29,846] DEBUG [Producer clientId=producer-1] Recorded API versions for node -1: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:55:29,848] DEBUG [Producer clientId=producer-1] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='test-topic-1217502653')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) (NetworkClient:1109)
[2020-04-15 00:55:29,884] DEBUG [Producer clientId=producer-1] Updating last seen epoch from null to 4 for partition test-topic-1217502653-0 (Metadata:178)
[2020-04-15 00:55:29,888] INFO [Producer clientId=producer-1] Cluster ID: FiXUEvIGTB6OchGaSyJltg (Metadata:261)
[2020-04-15 00:55:29,888] DEBUG [Producer clientId=producer-1] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='FiXUEvIGTB6OchGaSyJltg', nodes=[my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 0 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null)], partitions=[PartitionInfoAndEpoch{partitionInfo=Partition(topic = test-topic-1217502653, partition = 0, leader = 2, replicas = [2], isr = [2], offlineReplicas = []), epoch=4}], controller=my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 1 rack: null)} (Metadata:265)
[2020-04-15 00:55:29,914] DEBUG [Producer clientId=producer-1] Initiating connection to node my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) using address my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.16 (NetworkClient:956)
[2020-04-15 00:55:29,931] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (KafkaProducer:1183)
[2020-04-15 00:55:29,935] DEBUG Added sensor with name node-2.bytes-sent (Metrics:416)
[2020-04-15 00:55:29,936] DEBUG Added sensor with name node-2.bytes-received (Metrics:416)
[2020-04-15 00:55:29,936] DEBUG Added sensor with name node-2.latency (Metrics:416)
[2020-04-15 00:55:29,937] DEBUG [Producer clientId=producer-1] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 (Selector:535)
[2020-04-15 00:55:29,939] DEBUG [Producer clientId=producer-1] Completed connection to node 2. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:55:29,939] DEBUG [Producer clientId=producer-1] Beginning shutdown of Kafka producer I/O thread, sending remaining records. (Sender:250)
[2020-04-15 00:55:29,965] DEBUG [SslTransportLayer channelId=2 key=sun.nio.ch.SelectionKeyImpl@1b9542d1] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:55:29,965] DEBUG [Producer clientId=producer-1] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.16 (Selector:564)
[2020-04-15 00:55:29,966] DEBUG [Producer clientId=producer-1] Initiating API versions fetch from node 2. (NetworkClient:928)
[2020-04-15 00:55:29,969] DEBUG [Producer clientId=producer-1] Recorded API versions for node 2: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:55:29,973] DEBUG Added sensor with name topic.test-topic-1217502653.records-per-batch (Metrics:416)
[2020-04-15 00:55:29,974] DEBUG Added sensor with name topic.test-topic-1217502653.bytes (Metrics:416)
[2020-04-15 00:55:29,974] DEBUG Added sensor with name topic.test-topic-1217502653.compression-rate (Metrics:416)
[2020-04-15 00:55:29,974] DEBUG Added sensor with name topic.test-topic-1217502653.record-retries (Metrics:416)
[2020-04-15 00:55:29,975] DEBUG Added sensor with name topic.test-topic-1217502653.record-errors (Metrics:416)
{"timestamp":1586912129993,"name":"producer_send_success","key":null,"value":"0","topic":"test-topic-1217502653","partition":0,"offset":400}
{"timestamp":1586912129995,"name":"producer_send_success","key":null,"value":"1","topic":"test-topic-1217502653","partition":0,"offset":401}
{"timestamp":1586912129995,"name":"producer_send_success","key":null,"value":"2","topic":"test-topic-1217502653","partition":0,"offset":402}
{"timestamp":1586912129995,"name":"producer_send_success","key":null,"value":"3","topic":"test-topic-1217502653","partition":0,"offset":403}
{"timestamp":1586912129995,"name":"producer_send_success","key":null,"value":"4","topic":"test-topic-1217502653","partition":0,"offset":404}
{"timestamp":1586912129995,"name":"producer_send_success","key":null,"value":"5","topic":"test-topic-1217502653","partition":0,"offset":405}
{"timestamp":1586912129995,"name":"producer_send_success","key":null,"value":"6","topic":"test-topic-1217502653","partition":0,"offset":406}
{"timestamp":1586912129995,"name":"producer_send_success","key":null,"value":"7","topic":"test-topic-1217502653","partition":0,"offset":407}
{"timestamp":1586912129995,"name":"producer_send_success","key":null,"value":"8","topic":"test-topic-1217502653","partition":0,"offset":408}
{"timestamp":1586912129996,"name":"producer_send_success","key":null,"value":"9","topic":"test-topic-1217502653","partition":0,"offset":409}
{"timestamp":1586912129996,"name":"producer_send_success","key":null,"value":"10","topic":"test-topic-1217502653","partition":0,"offset":410}
{"timestamp":1586912129996,"name":"producer_send_success","key":null,"value":"11","topic":"test-topic-1217502653","partition":0,"offset":411}
{"timestamp":1586912129996,"name":"producer_send_success","key":null,"value":"12","topic":"test-topic-1217502653","partition":0,"offset":412}
{"timestamp":1586912129996,"name":"producer_send_success","key":null,"value":"13","topic":"test-topic-1217502653","partition":0,"offset":413}
{"timestamp":1586912129996,"name":"producer_send_success","key":null,"value":"14","topic":"test-topic-1217502653","partition":0,"offset":414}
{"timestamp":1586912129997,"name":"producer_send_success","key":null,"value":"15","topic":"test-topic-1217502653","partition":0,"offset":415}
{"timestamp":1586912129998,"name":"producer_send_success","key":null,"value":"16","topic":"test-topic-1217502653","partition":0,"offset":416}
{"timestamp":1586912129998,"name":"producer_send_success","key":null,"value":"17","topic":"test-topic-1217502653","partition":0,"offset":417}
{"timestamp":1586912129998,"name":"producer_send_success","key":null,"value":"18","topic":"test-topic-1217502653","partition":0,"offset":418}
{"timestamp":1586912129998,"name":"producer_send_success","key":null,"value":"19","topic":"test-topic-1217502653","partition":0,"offset":419}
{"timestamp":1586912129999,"name":"producer_send_success","key":null,"value":"20","topic":"test-topic-1217502653","partition":0,"offset":420}
{"timestamp":1586912129999,"name":"producer_send_success","key":null,"value":"21","topic":"test-topic-1217502653","partition":0,"offset":421}
{"timestamp":1586912129999,"name":"producer_send_success","key":null,"value":"22","topic":"test-topic-1217502653","partition":0,"offset":422}
{"timestamp":1586912129999,"name":"producer_send_success","key":null,"value":"23","topic":"test-topic-1217502653","partition":0,"offset":423}
{"timestamp":1586912129999,"name":"producer_send_success","key":null,"value":"24","topic":"test-topic-1217502653","partition":0,"offset":424}
{"timestamp":1586912129999,"name":"producer_send_success","key":null,"value":"25","topic":"test-topic-1217502653","partition":0,"offset":425}
{"timestamp":1586912129999,"name":"producer_send_success","key":null,"value":"26","topic":"test-topic-1217502653","partition":0,"offset":426}
{"timestamp":1586912130000,"name":"producer_send_success","key":null,"value":"27","topic":"test-topic-1217502653","partition":0,"offset":427}
{"timestamp":1586912130000,"name":"producer_send_success","key":null,"value":"28","topic":"test-topic-1217502653","partition":0,"offset":428}
{"timestamp":1586912130000,"name":"producer_send_success","key":null,"value":"29","topic":"test-topic-1217502653","partition":0,"offset":429}
{"timestamp":1586912130000,"name":"producer_send_success","key":null,"value":"30","topic":"test-topic-1217502653","partition":0,"offset":430}
{"timestamp":1586912130000,"name":"producer_send_success","key":null,"value":"31","topic":"test-topic-1217502653","partition":0,"offset":431}
{"timestamp":1586912130000,"name":"producer_send_success","key":null,"value":"32","topic":"test-topic-1217502653","partition":0,"offset":432}
{"timestamp":1586912130000,"name":"producer_send_success","key":null,"value":"33","topic":"test-topic-1217502653","partition":0,"offset":433}
{"timestamp":1586912130001,"name":"producer_send_success","key":null,"value":"34","topic":"test-topic-1217502653","partition":0,"offset":434}
{"timestamp":1586912130001,"name":"producer_send_success","key":null,"value":"35","topic":"test-topic-1217502653","partition":0,"offset":435}
{"timestamp":1586912130001,"name":"producer_send_success","key":null,"value":"36","topic":"test-topic-1217502653","partition":0,"offset":436}
{"timestamp":1586912130001,"name":"producer_send_success","key":null,"value":"37","topic":"test-topic-1217502653","partition":0,"offset":437}
{"timestamp":1586912130001,"name":"producer_send_success","key":null,"value":"38","topic":"test-topic-1217502653","partition":0,"offset":438}
{"timestamp":1586912130001,"name":"producer_send_success","key":null,"value":"39","topic":"test-topic-1217502653","partition":0,"offset":439}
{"timestamp":1586912130001,"name":"producer_send_success","key":null,"value":"40","topic":"test-topic-1217502653","partition":0,"offset":440}
{"timestamp":1586912130002,"name":"producer_send_success","key":null,"value":"41","topic":"test-topic-1217502653","partition":0,"offset":441}
{"timestamp":1586912130002,"name":"producer_send_success","key":null,"value":"42","topic":"test-topic-1217502653","partition":0,"offset":442}
{"timestamp":1586912130002,"name":"producer_send_success","key":null,"value":"43","topic":"test-topic-1217502653","partition":0,"offset":443}
{"timestamp":1586912130002,"name":"producer_send_success","key":null,"value":"44","topic":"test-topic-1217502653","partition":0,"offset":444}
{"timestamp":1586912130002,"name":"producer_send_success","key":null,"value":"45","topic":"test-topic-1217502653","partition":0,"offset":445}
{"timestamp":1586912130002,"name":"producer_send_success","key":null,"value":"46","topic":"test-topic-1217502653","partition":0,"offset":446}
{"timestamp":1586912130002,"name":"producer_send_success","key":null,"value":"47","topic":"test-topic-1217502653","partition":0,"offset":447}
{"timestamp":1586912130003,"name":"producer_send_success","key":null,"value":"48","topic":"test-topic-1217502653","partition":0,"offset":448}
{"timestamp":1586912130003,"name":"producer_send_success","key":null,"value":"49","topic":"test-topic-1217502653","partition":0,"offset":449}
{"timestamp":1586912130003,"name":"producer_send_success","key":null,"value":"50","topic":"test-topic-1217502653","partition":0,"offset":450}
{"timestamp":1586912130003,"name":"producer_send_success","key":null,"value":"51","topic":"test-topic-1217502653","partition":0,"offset":451}
{"timestamp":1586912130003,"name":"producer_send_success","key":null,"value":"52","topic":"test-topic-1217502653","partition":0,"offset":452}
{"timestamp":1586912130003,"name":"producer_send_success","key":null,"value":"53","topic":"test-topic-1217502653","partition":0,"offset":453}
{"timestamp":1586912130003,"name":"producer_send_success","key":null,"value":"54","topic":"test-topic-1217502653","partition":0,"offset":454}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"55","topic":"test-topic-1217502653","partition":0,"offset":455}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"56","topic":"test-topic-1217502653","partition":0,"offset":456}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"57","topic":"test-topic-1217502653","partition":0,"offset":457}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"58","topic":"test-topic-1217502653","partition":0,"offset":458}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"59","topic":"test-topic-1217502653","partition":0,"offset":459}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"60","topic":"test-topic-1217502653","partition":0,"offset":460}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"61","topic":"test-topic-1217502653","partition":0,"offset":461}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"62","topic":"test-topic-1217502653","partition":0,"offset":462}
{"timestamp":1586912130004,"name":"producer_send_success","key":null,"value":"63","topic":"test-topic-1217502653","partition":0,"offset":463}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"64","topic":"test-topic-1217502653","partition":0,"offset":464}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"65","topic":"test-topic-1217502653","partition":0,"offset":465}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"66","topic":"test-topic-1217502653","partition":0,"offset":466}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"67","topic":"test-topic-1217502653","partition":0,"offset":467}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"68","topic":"test-topic-1217502653","partition":0,"offset":468}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"69","topic":"test-topic-1217502653","partition":0,"offset":469}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"70","topic":"test-topic-1217502653","partition":0,"offset":470}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"71","topic":"test-topic-1217502653","partition":0,"offset":471}
{"timestamp":1586912130005,"name":"producer_send_success","key":null,"value":"72","topic":"test-topic-1217502653","partition":0,"offset":472}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"73","topic":"test-topic-1217502653","partition":0,"offset":473}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"74","topic":"test-topic-1217502653","partition":0,"offset":474}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"75","topic":"test-topic-1217502653","partition":0,"offset":475}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"76","topic":"test-topic-1217502653","partition":0,"offset":476}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"77","topic":"test-topic-1217502653","partition":0,"offset":477}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"78","topic":"test-topic-1217502653","partition":0,"offset":478}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"79","topic":"test-topic-1217502653","partition":0,"offset":479}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"80","topic":"test-topic-1217502653","partition":0,"offset":480}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"81","topic":"test-topic-1217502653","partition":0,"offset":481}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"82","topic":"test-topic-1217502653","partition":0,"offset":482}
{"timestamp":1586912130006,"name":"producer_send_success","key":null,"value":"83","topic":"test-topic-1217502653","partition":0,"offset":483}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"84","topic":"test-topic-1217502653","partition":0,"offset":484}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"85","topic":"test-topic-1217502653","partition":0,"offset":485}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"86","topic":"test-topic-1217502653","partition":0,"offset":486}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"87","topic":"test-topic-1217502653","partition":0,"offset":487}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"88","topic":"test-topic-1217502653","partition":0,"offset":488}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"89","topic":"test-topic-1217502653","partition":0,"offset":489}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"90","topic":"test-topic-1217502653","partition":0,"offset":490}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"91","topic":"test-topic-1217502653","partition":0,"offset":491}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"92","topic":"test-topic-1217502653","partition":0,"offset":492}
{"timestamp":1586912130007,"name":"producer_send_success","key":null,"value":"93","topic":"test-topic-1217502653","partition":0,"offset":493}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"94","topic":"test-topic-1217502653","partition":0,"offset":494}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"95","topic":"test-topic-1217502653","partition":0,"offset":495}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"96","topic":"test-topic-1217502653","partition":0,"offset":496}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"97","topic":"test-topic-1217502653","partition":0,"offset":497}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"98","topic":"test-topic-1217502653","partition":0,"offset":498}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"99","topic":"test-topic-1217502653","partition":0,"offset":499}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"100","topic":"test-topic-1217502653","partition":0,"offset":500}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"101","topic":"test-topic-1217502653","partition":0,"offset":501}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"102","topic":"test-topic-1217502653","partition":0,"offset":502}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"103","topic":"test-topic-1217502653","partition":0,"offset":503}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"104","topic":"test-topic-1217502653","partition":0,"offset":504}
{"timestamp":1586912130008,"name":"producer_send_success","key":null,"value":"105","topic":"test-topic-1217502653","partition":0,"offset":505}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"106","topic":"test-topic-1217502653","partition":0,"offset":506}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"107","topic":"test-topic-1217502653","partition":0,"offset":507}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"108","topic":"test-topic-1217502653","partition":0,"offset":508}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"109","topic":"test-topic-1217502653","partition":0,"offset":509}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"110","topic":"test-topic-1217502653","partition":0,"offset":510}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"111","topic":"test-topic-1217502653","partition":0,"offset":511}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"112","topic":"test-topic-1217502653","partition":0,"offset":512}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"113","topic":"test-topic-1217502653","partition":0,"offset":513}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"114","topic":"test-topic-1217502653","partition":0,"offset":514}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"115","topic":"test-topic-1217502653","partition":0,"offset":515}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"116","topic":"test-topic-1217502653","partition":0,"offset":516}
{"timestamp":1586912130009,"name":"producer_send_success","key":null,"value":"117","topic":"test-topic-1217502653","partition":0,"offset":517}
{"timestamp":1586912130010,"name":"producer_send_success","key":null,"value":"118","topic":"test-topic-1217502653","partition":0,"offset":518}
{"timestamp":1586912130010,"name":"producer_send_success","key":null,"value":"119","topic":"test-topic-1217502653","partition":0,"offset":519}
{"timestamp":1586912130010,"name":"producer_send_success","key":null,"value":"120","topic":"test-topic-1217502653","partition":0,"offset":520}
{"timestamp":1586912130010,"name":"producer_send_success","key":null,"value":"121","topic":"test-topic-1217502653","partition":0,"offset":521}
{"timestamp":1586912130010,"name":"producer_send_success","key":null,"value":"122","topic":"test-topic-1217502653","partition":0,"offset":522}
{"timestamp":1586912130010,"name":"producer_send_success","key":null,"value":"123","topic":"test-topic-1217502653","partition":0,"offset":523}
{"timestamp":1586912130010,"name":"producer_send_success","key":null,"value":"124","topic":"test-topic-1217502653","partition":0,"offset":524}
{"timestamp":1586912130010,"name":"producer_send_success","key":null,"value":"125","topic":"test-topic-1217502653","partition":0,"offset":525}
{"timestamp":1586912130011,"name":"producer_send_success","key":null,"value":"126","topic":"test-topic-1217502653","partition":0,"offset":526}
{"timestamp":1586912130011,"name":"producer_send_success","key":null,"value":"127","topic":"test-topic-1217502653","partition":0,"offset":527}
{"timestamp":1586912130011,"name":"producer_send_success","key":null,"value":"128","topic":"test-topic-1217502653","partition":0,"offset":528}
{"timestamp":1586912130011,"name":"producer_send_success","key":null,"value":"129","topic":"test-topic-1217502653","partition":0,"offset":529}
{"timestamp":1586912130011,"name":"producer_send_success","key":null,"value":"130","topic":"test-topic-1217502653","partition":0,"offset":530}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"131","topic":"test-topic-1217502653","partition":0,"offset":531}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"132","topic":"test-topic-1217502653","partition":0,"offset":532}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"133","topic":"test-topic-1217502653","partition":0,"offset":533}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"134","topic":"test-topic-1217502653","partition":0,"offset":534}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"135","topic":"test-topic-1217502653","partition":0,"offset":535}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"136","topic":"test-topic-1217502653","partition":0,"offset":536}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"137","topic":"test-topic-1217502653","partition":0,"offset":537}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"138","topic":"test-topic-1217502653","partition":0,"offset":538}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"139","topic":"test-topic-1217502653","partition":0,"offset":539}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"140","topic":"test-topic-1217502653","partition":0,"offset":540}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"141","topic":"test-topic-1217502653","partition":0,"offset":541}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"142","topic":"test-topic-1217502653","partition":0,"offset":542}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"143","topic":"test-topic-1217502653","partition":0,"offset":543}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"144","topic":"test-topic-1217502653","partition":0,"offset":544}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"145","topic":"test-topic-1217502653","partition":0,"offset":545}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"146","topic":"test-topic-1217502653","partition":0,"offset":546}
{"timestamp":1586912130012,"name":"producer_send_success","key":null,"value":"147","topic":"test-topic-1217502653","partition":0,"offset":547}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"148","topic":"test-topic-1217502653","partition":0,"offset":548}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"149","topic":"test-topic-1217502653","partition":0,"offset":549}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"150","topic":"test-topic-1217502653","partition":0,"offset":550}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"151","topic":"test-topic-1217502653","partition":0,"offset":551}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"152","topic":"test-topic-1217502653","partition":0,"offset":552}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"153","topic":"test-topic-1217502653","partition":0,"offset":553}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"154","topic":"test-topic-1217502653","partition":0,"offset":554}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"155","topic":"test-topic-1217502653","partition":0,"offset":555}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"156","topic":"test-topic-1217502653","partition":0,"offset":556}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"157","topic":"test-topic-1217502653","partition":0,"offset":557}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"158","topic":"test-topic-1217502653","partition":0,"offset":558}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"159","topic":"test-topic-1217502653","partition":0,"offset":559}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"160","topic":"test-topic-1217502653","partition":0,"offset":560}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"161","topic":"test-topic-1217502653","partition":0,"offset":561}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"162","topic":"test-topic-1217502653","partition":0,"offset":562}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"163","topic":"test-topic-1217502653","partition":0,"offset":563}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"164","topic":"test-topic-1217502653","partition":0,"offset":564}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"165","topic":"test-topic-1217502653","partition":0,"offset":565}
{"timestamp":1586912130013,"name":"producer_send_success","key":null,"value":"166","topic":"test-topic-1217502653","partition":0,"offset":566}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"167","topic":"test-topic-1217502653","partition":0,"offset":567}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"168","topic":"test-topic-1217502653","partition":0,"offset":568}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"169","topic":"test-topic-1217502653","partition":0,"offset":569}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"170","topic":"test-topic-1217502653","partition":0,"offset":570}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"171","topic":"test-topic-1217502653","partition":0,"offset":571}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"172","topic":"test-topic-1217502653","partition":0,"offset":572}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"173","topic":"test-topic-1217502653","partition":0,"offset":573}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"174","topic":"test-topic-1217502653","partition":0,"offset":574}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"175","topic":"test-topic-1217502653","partition":0,"offset":575}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"176","topic":"test-topic-1217502653","partition":0,"offset":576}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"177","topic":"test-topic-1217502653","partition":0,"offset":577}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"178","topic":"test-topic-1217502653","partition":0,"offset":578}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"179","topic":"test-topic-1217502653","partition":0,"offset":579}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"180","topic":"test-topic-1217502653","partition":0,"offset":580}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"181","topic":"test-topic-1217502653","partition":0,"offset":581}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"182","topic":"test-topic-1217502653","partition":0,"offset":582}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"183","topic":"test-topic-1217502653","partition":0,"offset":583}
{"timestamp":1586912130014,"name":"producer_send_success","key":null,"value":"184","topic":"test-topic-1217502653","partition":0,"offset":584}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"185","topic":"test-topic-1217502653","partition":0,"offset":585}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"186","topic":"test-topic-1217502653","partition":0,"offset":586}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"187","topic":"test-topic-1217502653","partition":0,"offset":587}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"188","topic":"test-topic-1217502653","partition":0,"offset":588}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"189","topic":"test-topic-1217502653","partition":0,"offset":589}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"190","topic":"test-topic-1217502653","partition":0,"offset":590}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"191","topic":"test-topic-1217502653","partition":0,"offset":591}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"192","topic":"test-topic-1217502653","partition":0,"offset":592}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"193","topic":"test-topic-1217502653","partition":0,"offset":593}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"194","topic":"test-topic-1217502653","partition":0,"offset":594}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"195","topic":"test-topic-1217502653","partition":0,"offset":595}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"196","topic":"test-topic-1217502653","partition":0,"offset":596}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"197","topic":"test-topic-1217502653","partition":0,"offset":597}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"198","topic":"test-topic-1217502653","partition":0,"offset":598}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"199","topic":"test-topic-1217502653","partition":0,"offset":599}
{"timestamp":1586912130015,"name":"producer_send_success","key":null,"value":"200","topic":"test-topic-1217502653","partition":0,"offset":600}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"201","topic":"test-topic-1217502653","partition":0,"offset":601}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"202","topic":"test-topic-1217502653","partition":0,"offset":602}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"203","topic":"test-topic-1217502653","partition":0,"offset":603}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"204","topic":"test-topic-1217502653","partition":0,"offset":604}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"205","topic":"test-topic-1217502653","partition":0,"offset":605}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"206","topic":"test-topic-1217502653","partition":0,"offset":606}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"207","topic":"test-topic-1217502653","partition":0,"offset":607}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"208","topic":"test-topic-1217502653","partition":0,"offset":608}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"209","topic":"test-topic-1217502653","partition":0,"offset":609}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"210","topic":"test-topic-1217502653","partition":0,"offset":610}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"211","topic":"test-topic-1217502653","partition":0,"offset":611}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"212","topic":"test-topic-1217502653","partition":0,"offset":612}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"213","topic":"test-topic-1217502653","partition":0,"offset":613}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"214","topic":"test-topic-1217502653","partition":0,"offset":614}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"215","topic":"test-topic-1217502653","partition":0,"offset":615}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"216","topic":"test-topic-1217502653","partition":0,"offset":616}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"217","topic":"test-topic-1217502653","partition":0,"offset":617}
{"timestamp":1586912130016,"name":"producer_send_success","key":null,"value":"218","topic":"test-topic-1217502653","partition":0,"offset":618}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"219","topic":"test-topic-1217502653","partition":0,"offset":619}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"220","topic":"test-topic-1217502653","partition":0,"offset":620}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"221","topic":"test-topic-1217502653","partition":0,"offset":621}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"222","topic":"test-topic-1217502653","partition":0,"offset":622}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"223","topic":"test-topic-1217502653","partition":0,"offset":623}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"224","topic":"test-topic-1217502653","partition":0,"offset":624}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"225","topic":"test-topic-1217502653","partition":0,"offset":625}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"226","topic":"test-topic-1217502653","partition":0,"offset":626}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"227","topic":"test-topic-1217502653","partition":0,"offset":627}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"228","topic":"test-topic-1217502653","partition":0,"offset":628}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"229","topic":"test-topic-1217502653","partition":0,"offset":629}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"230","topic":"test-topic-1217502653","partition":0,"offset":630}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"231","topic":"test-topic-1217502653","partition":0,"offset":631}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"232","topic":"test-topic-1217502653","partition":0,"offset":632}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"233","topic":"test-topic-1217502653","partition":0,"offset":633}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"234","topic":"test-topic-1217502653","partition":0,"offset":634}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"235","topic":"test-topic-1217502653","partition":0,"offset":635}
{"timestamp":1586912130017,"name":"producer_send_success","key":null,"value":"236","topic":"test-topic-1217502653","partition":0,"offset":636}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"237","topic":"test-topic-1217502653","partition":0,"offset":637}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"238","topic":"test-topic-1217502653","partition":0,"offset":638}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"239","topic":"test-topic-1217502653","partition":0,"offset":639}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"240","topic":"test-topic-1217502653","partition":0,"offset":640}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"241","topic":"test-topic-1217502653","partition":0,"offset":641}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"242","topic":"test-topic-1217502653","partition":0,"offset":642}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"243","topic":"test-topic-1217502653","partition":0,"offset":643}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"244","topic":"test-topic-1217502653","partition":0,"offset":644}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"245","topic":"test-topic-1217502653","partition":0,"offset":645}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"246","topic":"test-topic-1217502653","partition":0,"offset":646}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"247","topic":"test-topic-1217502653","partition":0,"offset":647}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"248","topic":"test-topic-1217502653","partition":0,"offset":648}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"249","topic":"test-topic-1217502653","partition":0,"offset":649}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"250","topic":"test-topic-1217502653","partition":0,"offset":650}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"251","topic":"test-topic-1217502653","partition":0,"offset":651}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"252","topic":"test-topic-1217502653","partition":0,"offset":652}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"253","topic":"test-topic-1217502653","partition":0,"offset":653}
{"timestamp":1586912130018,"name":"producer_send_success","key":null,"value":"254","topic":"test-topic-1217502653","partition":0,"offset":654}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"255","topic":"test-topic-1217502653","partition":0,"offset":655}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"256","topic":"test-topic-1217502653","partition":0,"offset":656}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"257","topic":"test-topic-1217502653","partition":0,"offset":657}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"258","topic":"test-topic-1217502653","partition":0,"offset":658}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"259","topic":"test-topic-1217502653","partition":0,"offset":659}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"260","topic":"test-topic-1217502653","partition":0,"offset":660}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"261","topic":"test-topic-1217502653","partition":0,"offset":661}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"262","topic":"test-topic-1217502653","partition":0,"offset":662}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"263","topic":"test-topic-1217502653","partition":0,"offset":663}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"264","topic":"test-topic-1217502653","partition":0,"offset":664}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"265","topic":"test-topic-1217502653","partition":0,"offset":665}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"266","topic":"test-topic-1217502653","partition":0,"offset":666}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"267","topic":"test-topic-1217502653","partition":0,"offset":667}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"268","topic":"test-topic-1217502653","partition":0,"offset":668}
{"timestamp":1586912130019,"name":"producer_send_success","key":null,"value":"269","topic":"test-topic-1217502653","partition":0,"offset":669}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"270","topic":"test-topic-1217502653","partition":0,"offset":670}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"271","topic":"test-topic-1217502653","partition":0,"offset":671}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"272","topic":"test-topic-1217502653","partition":0,"offset":672}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"273","topic":"test-topic-1217502653","partition":0,"offset":673}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"274","topic":"test-topic-1217502653","partition":0,"offset":674}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"275","topic":"test-topic-1217502653","partition":0,"offset":675}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"276","topic":"test-topic-1217502653","partition":0,"offset":676}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"277","topic":"test-topic-1217502653","partition":0,"offset":677}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"278","topic":"test-topic-1217502653","partition":0,"offset":678}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"279","topic":"test-topic-1217502653","partition":0,"offset":679}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"280","topic":"test-topic-1217502653","partition":0,"offset":680}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"281","topic":"test-topic-1217502653","partition":0,"offset":681}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"282","topic":"test-topic-1217502653","partition":0,"offset":682}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"283","topic":"test-topic-1217502653","partition":0,"offset":683}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"284","topic":"test-topic-1217502653","partition":0,"offset":684}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"285","topic":"test-topic-1217502653","partition":0,"offset":685}
{"timestamp":1586912130020,"name":"producer_send_success","key":null,"value":"286","topic":"test-topic-1217502653","partition":0,"offset":686}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"287","topic":"test-topic-1217502653","partition":0,"offset":687}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"288","topic":"test-topic-1217502653","partition":0,"offset":688}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"289","topic":"test-topic-1217502653","partition":0,"offset":689}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"290","topic":"test-topic-1217502653","partition":0,"offset":690}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"291","topic":"test-topic-1217502653","partition":0,"offset":691}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"292","topic":"test-topic-1217502653","partition":0,"offset":692}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"293","topic":"test-topic-1217502653","partition":0,"offset":693}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"294","topic":"test-topic-1217502653","partition":0,"offset":694}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"295","topic":"test-topic-1217502653","partition":0,"offset":695}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"296","topic":"test-topic-1217502653","partition":0,"offset":696}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"297","topic":"test-topic-1217502653","partition":0,"offset":697}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"298","topic":"test-topic-1217502653","partition":0,"offset":698}
{"timestamp":1586912130021,"name":"producer_send_success","key":null,"value":"299","topic":"test-topic-1217502653","partition":0,"offset":699}
[2020-04-15 00:55:30,023] DEBUG Removed sensor with name connections-closed: (Metrics:449)
[2020-04-15 00:55:30,024] DEBUG Removed sensor with name connections-created: (Metrics:449)
[2020-04-15 00:55:30,024] DEBUG Removed sensor with name successful-authentication: (Metrics:449)
[2020-04-15 00:55:30,024] DEBUG Removed sensor with name successful-reauthentication: (Metrics:449)
[2020-04-15 00:55:30,024] DEBUG Removed sensor with name successful-authentication-no-reauth: (Metrics:449)
[2020-04-15 00:55:30,025] DEBUG Removed sensor with name failed-authentication: (Metrics:449)
[2020-04-15 00:55:30,025] DEBUG Removed sensor with name failed-reauthentication: (Metrics:449)
[2020-04-15 00:55:30,025] DEBUG Removed sensor with name reauthentication-latency: (Metrics:449)
[2020-04-15 00:55:30,025] DEBUG Removed sensor with name bytes-sent-received: (Metrics:449)
[2020-04-15 00:55:30,026] DEBUG Removed sensor with name bytes-sent: (Metrics:449)
[2020-04-15 00:55:30,026] DEBUG Removed sensor with name bytes-received: (Metrics:449)
[2020-04-15 00:55:30,027] DEBUG Removed sensor with name select-time: (Metrics:449)
[2020-04-15 00:55:30,027] DEBUG Removed sensor with name io-time: (Metrics:449)
[2020-04-15 00:55:30,027] DEBUG Removed sensor with name node--1.bytes-sent (Metrics:449)
[2020-04-15 00:55:30,028] DEBUG Removed sensor with name node--1.bytes-received (Metrics:449)
[2020-04-15 00:55:30,028] DEBUG Removed sensor with name node--1.latency (Metrics:449)
[2020-04-15 00:55:30,028] DEBUG Removed sensor with name node-2.bytes-sent (Metrics:449)
[2020-04-15 00:55:30,028] DEBUG Removed sensor with name node-2.bytes-received (Metrics:449)
[2020-04-15 00:55:30,029] DEBUG Removed sensor with name node-2.latency (Metrics:449)
[2020-04-15 00:55:30,029] DEBUG [Producer clientId=producer-1] Shutdown of Kafka producer I/O thread has completed. (Sender:292)
[2020-04-15 00:55:30,031] DEBUG [Producer clientId=producer-1] Kafka producer has been closed (KafkaProducer:1235)
{"timestamp":1586912130031,"name":"shutdown_complete"}
{"timestamp":1586912130032,"name":"tool_data","sent":300,"acked":300,"target_throughput":-1,"avg_throughput":592.8853754940711}

2020-04-15 00:55:30 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:117] Producer finished correctly: true
2020-04-15 00:55:30 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:121] Producer produced 300 messages
2020-04-15 00:55:30 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:181] Starting verifiableClient tls consumer with following configuration VerifiableClient{allowedArguments=[BROKER_LIST, TOPIC, GROUP_ID, MAX_MESSAGES, SESSION_TIMEOUT, VERBOSE, ENABLE_AUTOCOMMIT, RESET_POLICY, ASSIGMENT_STRATEGY, CONSUMER_CONFIG, USER, GROUP_INSTANCE_ID], lock=java.lang.Object@733534f9, messages=[], arguments=[--group-instance-id, instance1892788014, USER=alice, --broker-list, my-cluster-kafka-bootstrap:9093, --group-id, consumer-group-certs-71, --topic, test-topic-1217502653, --max-messages, 300], executable='/opt/kafka/consumer.sh', executor=null, clientType=CLI_KAFKA_VERIFIABLE_CONSUMER, podName='my-cluster-kafka-clients-79bbb6849c-jk4n4', podNamespace='kafka-listeners-cluster-test', bootstrapServer='my-cluster-kafka-bootstrap:9093', topicName='test-topic-1217502653', maxMessages=300, kafkaUsername='alice', consumerGroupName='consumer-group-certs-71', consumerInstanceId='instance1892788014', clientArgumentMap=io.strimzi.systemtest.kafkaclients.internalClients.ClientArgumentMap@661e279d}
2020-04-15 00:55:30 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:182] Wait for receive 300 messages from my-cluster-kafka-bootstrap:9093#test-topic-1217502653
2020-04-15 00:55:37 &amp#27;[32mINFO &amp#27;[m [VerifiableClient:194] VerifiableClient CLI_KAFKA_VERIFIABLE_CONSUMER Return code - 0
2020-04-15 00:55:37 &amp#27;[32mINFO &amp#27;[m [VerifiableClient:196] VerifiableClient CLI_KAFKA_VERIFIABLE_CONSUMER stdout : /tmp/alice.properties
Starting Consumer with configuration:
=auto.offset.reset=earliest
security.protocol=SSL
ssl.truststore.location=/tmp/alice-truststore.p12
ssl.truststore.type=pkcs12
ssl.keystore.location=/tmp/alice-keystore.p12
ssl.keystore.type=pkcs12
ssl.endpoint.identification.algorithm=
ssl.keystore.password=bIF3spHpgXefpbPkjSoSbl2X9wnJ0uFQ
ssl.truststore.password=bIF3spHpgXefpbPkjSoSbl2X9wnJ0uFQ
[2020-04-15 00:55:32,311] INFO ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = earliest
	bootstrap.servers = [my-cluster-kafka-bootstrap:9093]
	check.crcs = true
	client.dns.lookup = default
	client.id = 
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = consumer-group-certs-71
	group.instance.id = instance1892788014
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	isolation.level = read_uncommitted
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 300000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = SSL
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 30000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.endpoint.identification.algorithm = 
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = /tmp/alice-keystore.p12
	ssl.keystore.password = [hidden]
	ssl.keystore.type = pkcs12
	ssl.protocol = TLS
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = /tmp/alice-truststore.p12
	ssl.truststore.password = [hidden]
	ssl.truststore.type = pkcs12
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
 (ConsumerConfig:347)
[2020-04-15 00:55:32,335] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Initializing the Kafka consumer (KafkaConsumer:699)
[2020-04-15 00:55:32,583] DEBUG Created SSL context with keystore SecurityStore(path=/tmp/alice-keystore.p12, modificationTime=Wed Apr 15 00:55:31 UTC 2020), truststore SecurityStore(path=/tmp/alice-truststore.p12, modificationTime=Wed Apr 15 00:55:31 UTC 2020), provider SunJSSE. (SslEngineBuilder:159)
[2020-04-15 00:55:32,590] DEBUG Added sensor with name fetch-throttle-time (Metrics:416)
[2020-04-15 00:55:32,601] DEBUG Added sensor with name connections-closed: (Metrics:416)
[2020-04-15 00:55:32,604] DEBUG Added sensor with name connections-created: (Metrics:416)
[2020-04-15 00:55:32,605] DEBUG Added sensor with name successful-authentication: (Metrics:416)
[2020-04-15 00:55:32,605] DEBUG Added sensor with name successful-reauthentication: (Metrics:416)
[2020-04-15 00:55:32,606] DEBUG Added sensor with name successful-authentication-no-reauth: (Metrics:416)
[2020-04-15 00:55:32,606] DEBUG Added sensor with name failed-authentication: (Metrics:416)
[2020-04-15 00:55:32,607] DEBUG Added sensor with name failed-reauthentication: (Metrics:416)
[2020-04-15 00:55:32,607] DEBUG Added sensor with name reauthentication-latency: (Metrics:416)
[2020-04-15 00:55:32,607] DEBUG Added sensor with name bytes-sent-received: (Metrics:416)
[2020-04-15 00:55:32,608] DEBUG Added sensor with name bytes-sent: (Metrics:416)
[2020-04-15 00:55:32,609] DEBUG Added sensor with name bytes-received: (Metrics:416)
[2020-04-15 00:55:32,611] DEBUG Added sensor with name select-time: (Metrics:416)
[2020-04-15 00:55:32,613] DEBUG Added sensor with name io-time: (Metrics:416)
[2020-04-15 00:55:32,630] DEBUG Added sensor with name heartbeat-latency (Metrics:416)
[2020-04-15 00:55:32,631] DEBUG Added sensor with name join-latency (Metrics:416)
[2020-04-15 00:55:32,632] DEBUG Added sensor with name sync-latency (Metrics:416)
[2020-04-15 00:55:32,632] DEBUG Added sensor with name rebalance-latency (Metrics:416)
[2020-04-15 00:55:32,633] DEBUG Added sensor with name failed-rebalance (Metrics:416)
[2020-04-15 00:55:32,636] DEBUG Added sensor with name commit-latency (Metrics:416)
[2020-04-15 00:55:32,636] DEBUG Added sensor with name partition-revoked-latency (Metrics:416)
[2020-04-15 00:55:32,636] DEBUG Added sensor with name partition-assigned-latency (Metrics:416)
[2020-04-15 00:55:32,637] DEBUG Added sensor with name partition-lost-latency (Metrics:416)
[2020-04-15 00:55:32,639] DEBUG Added sensor with name bytes-fetched (Metrics:416)
[2020-04-15 00:55:32,640] DEBUG Added sensor with name records-fetched (Metrics:416)
[2020-04-15 00:55:32,640] DEBUG Added sensor with name fetch-latency (Metrics:416)
[2020-04-15 00:55:32,641] DEBUG Added sensor with name records-lag (Metrics:416)
[2020-04-15 00:55:32,641] DEBUG Added sensor with name records-lead (Metrics:416)
[2020-04-15 00:55:32,644] DEBUG Added sensor with name time-between-poll (Metrics:416)
[2020-04-15 00:55:32,644] DEBUG Added sensor with name poll-idle-ratio-avg (Metrics:416)
[2020-04-15 00:55:32,645] WARN The configuration '' was supplied but isn't a known config. (ConsumerConfig:355)
[2020-04-15 00:55:32,646] INFO Kafka version: 2.4.0 (AppInfoParser:117)
[2020-04-15 00:55:32,646] INFO Kafka commitId: 77a89fcf8d7fa018 (AppInfoParser:118)
[2020-04-15 00:55:32,646] INFO Kafka startTimeMs: 1586912132645 (AppInfoParser:119)
[2020-04-15 00:55:32,648] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Kafka consumer initialized (KafkaConsumer:815)
{"timestamp":1586912132793,"name":"startup_complete"}
[2020-04-15 00:55:32,843] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Subscribed to topic(s): test-topic-1217502653 (KafkaConsumer:969)
[2020-04-15 00:55:32,845] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Sending FindCoordinator request to broker my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) (AbstractCoordinator:727)
[2020-04-15 00:55:33,000] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Initiating connection to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) using address my-cluster-kafka-bootstrap/172.30.52.17 (NetworkClient:956)
[2020-04-15 00:55:33,019] DEBUG Added sensor with name node--1.bytes-sent (Metrics:416)
[2020-04-15 00:55:33,020] DEBUG Added sensor with name node--1.bytes-received (Metrics:416)
[2020-04-15 00:55:33,021] DEBUG Added sensor with name node--1.latency (Metrics:416)
[2020-04-15 00:55:33,022] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 (Selector:535)
[2020-04-15 00:55:33,033] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Completed connection to node -1. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:55:33,126] DEBUG [SslTransportLayer channelId=-1 key=sun.nio.ch.SelectionKeyImpl@140c9f39] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:55:33,126] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Successfully authenticated with my-cluster-kafka-bootstrap/172.30.52.17 (Selector:564)
[2020-04-15 00:55:33,127] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Initiating API versions fetch from node -1. (NetworkClient:928)
[2020-04-15 00:55:33,286] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Recorded API versions for node -1: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:55:33,289] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='test-topic-1217502653')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node my-cluster-kafka-bootstrap:9093 (id: -1 rack: null) (NetworkClient:1109)
[2020-04-15 00:55:33,314] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Updating last seen epoch from null to 4 for partition test-topic-1217502653-0 (Metadata:178)
[2020-04-15 00:55:33,319] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Cluster ID: FiXUEvIGTB6OchGaSyJltg (Metadata:261)
[2020-04-15 00:55:33,319] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='FiXUEvIGTB6OchGaSyJltg', nodes=[my-cluster-kafka-0.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 0 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null)], partitions=[PartitionInfoAndEpoch{partitionInfo=Partition(topic = test-topic-1217502653, partition = 0, leader = 2, replicas = [2], isr = [2], offlineReplicas = []), epoch=4}], controller=my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 1 rack: null)} (Metadata:265)
[2020-04-15 00:55:33,321] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Received FindCoordinator response ClientResponse(receivedTimeMs=1586912133320, latencyMs=323, disconnected=false, requestHeader=RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=3, clientId=consumer-consumer-group-certs-71-instance1892788014, correlationId=0), responseBody=FindCoordinatorResponseData(throttleTimeMs=0, errorCode=0, errorMessage='NONE', nodeId=1, host='my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc', port=9093)) (AbstractCoordinator:741)
[2020-04-15 00:55:33,321] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Discovered group coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2147483646 rack: null) (AbstractCoordinator:756)
[2020-04-15 00:55:33,323] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Initiating connection to node my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2147483646 rack: null) using address my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.15 (NetworkClient:956)
[2020-04-15 00:55:33,333] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Executing onJoinPrepare with generation -1 and memberId  (ConsumerCoordinator:633)
[2020-04-15 00:55:33,334] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Disabling heartbeat thread (AbstractCoordinator:1169)
[2020-04-15 00:55:33,334] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Heartbeat thread started (AbstractCoordinator:1192)
[2020-04-15 00:55:33,334] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] (Re-)joining group (AbstractCoordinator:533)
[2020-04-15 00:55:33,334] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Joining group with current subscription: [test-topic-1217502653] (ConsumerCoordinator:206)
[2020-04-15 00:55:33,337] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Sending JoinGroup (JoinGroupRequestData(groupId='consumer-group-certs-71', sessionTimeoutMs=30000, rebalanceTimeoutMs=300000, memberId='', groupInstanceId='instance1892788014', protocolType='consumer', protocols=[JoinGroupRequestProtocol(name='range', metadata=[0, 1, 0, 0, 0, 1, 0, 21, 116, 101, 115, 116, 45, 116, 111, 112, 105, 99, 45, 49, 50, 49, 55, 53, 48, 50, 54, 53, 51, -1, -1, -1, -1, 0, 0, 0, 0])])) to coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2147483646 rack: null) (AbstractCoordinator:545)
[2020-04-15 00:55:33,338] DEBUG Added sensor with name node-2147483646.bytes-sent (Metrics:416)
[2020-04-15 00:55:33,339] DEBUG Added sensor with name node-2147483646.bytes-received (Metrics:416)
[2020-04-15 00:55:33,339] DEBUG Added sensor with name node-2147483646.latency (Metrics:416)
[2020-04-15 00:55:33,340] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147483646 (Selector:535)
[2020-04-15 00:55:33,342] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Completed connection to node 2147483646. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:55:33,363] DEBUG [SslTransportLayer channelId=2147483646 key=sun.nio.ch.SelectionKeyImpl@5276d6ee] SSL handshake completed successfully with peerHost 'my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:55:33,364] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Successfully authenticated with my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.15 (Selector:564)
[2020-04-15 00:55:33,364] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Initiating API versions fetch from node 2147483646. (NetworkClient:928)
[2020-04-15 00:55:33,368] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Recorded API versions for node 2147483646: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:55:36,415] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Received successful JoinGroup response: JoinGroupResponseData(throttleTimeMs=0, errorCode=0, generationId=1, protocolName='range', leader='instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f', memberId='instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f', members=[JoinGroupResponseMember(memberId='instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f', groupInstanceId='instance1892788014', metadata=[0, 1, 0, 0, 0, 1, 0, 21, 116, 101, 115, 116, 45, 116, 111, 112, 105, 99, 45, 49, 50, 49, 55, 53, 48, 50, 54, 53, 51, -1, -1, -1, -1, 0, 0, 0, 0])]) (AbstractCoordinator:560)
[2020-04-15 00:55:36,416] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Performing assignment using strategy range with subscriptions {instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f=org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Subscription@38145825} (ConsumerCoordinator:546)
[2020-04-15 00:55:36,418] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Finished assignment for group at generation 1: {instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f=org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Assignment@1df8da7a} (ConsumerCoordinator:585)
[2020-04-15 00:55:36,419] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Sending leader SyncGroup to coordinator my-cluster-kafka-1.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2147483646 rack: null) at generation Generation{generationId=1, memberId='instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f', protocol='range'}: SyncGroupRequestData(groupId='consumer-group-certs-71', generationId=1, memberId='instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f', groupInstanceId='instance1892788014', assignments=[SyncGroupRequestAssignment(memberId='instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f', assignment=[0, 1, 0, 0, 0, 1, 0, 21, 116, 101, 115, 116, 45, 116, 111, 112, 105, 99, 45, 49, 50, 49, 55, 53, 48, 50, 54, 53, 51, 0, 0, 0, 1, 0, 0, 0, 0, -1, -1, -1, -1])]) (AbstractCoordinator:670)
[2020-04-15 00:55:36,511] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Successfully joined group with generation 1 (AbstractCoordinator:484)
[2020-04-15 00:55:36,511] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Enabling heartbeat thread (AbstractCoordinator:1160)
[2020-04-15 00:55:36,511] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Executing onJoinComplete with generation 1 and memberId instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f (ConsumerCoordinator:328)
[2020-04-15 00:55:36,515] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Adding newly assigned partitions: test-topic-1217502653-0 (ConsumerCoordinator:267)
{"timestamp":1586912136515,"name":"partitions_assigned","partitions":[{"topic":"test-topic-1217502653","partition":0}]}
[2020-04-15 00:55:36,538] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Fetching committed offsets for partitions: [test-topic-1217502653-0] (ConsumerCoordinator:1182)
[2020-04-15 00:55:36,548] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Found no committed offset for partition test-topic-1217502653-0 (ConsumerCoordinator:1241)
[2020-04-15 00:55:36,552] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Sending ListOffsetRequest (type=ListOffsetRequest, replicaId=-1, partitionTimestamps={test-topic-1217502653-0={timestamp: -2, maxNumOffsets: 1, currentLeaderEpoch: Optional[4]}}, isolationLevel=READ_UNCOMMITTED) to broker my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) (Fetcher:946)
[2020-04-15 00:55:36,557] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Initiating connection to node my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) using address my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.16 (NetworkClient:956)
[2020-04-15 00:55:36,560] DEBUG Added sensor with name node-2.bytes-sent (Metrics:416)
[2020-04-15 00:55:36,561] DEBUG Added sensor with name node-2.bytes-received (Metrics:416)
[2020-04-15 00:55:36,561] DEBUG Added sensor with name node-2.latency (Metrics:416)
[2020-04-15 00:55:36,561] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 (Selector:535)
[2020-04-15 00:55:36,564] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Completed connection to node 2. Fetching API versions. (NetworkClient:914)
[2020-04-15 00:55:36,590] DEBUG [SslTransportLayer channelId=2 key=sun.nio.ch.SelectionKeyImpl@4149c063] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc' peerPort 9093 peerPrincipal 'CN=kafka.strimzi.io, O="Jakub Scholz, Inc.", L=Prague, C=CZ' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' (SslTransportLayer:424)
[2020-04-15 00:55:36,590] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc/172.17.0.16 (Selector:564)
[2020-04-15 00:55:36,590] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Initiating API versions fetch from node 2. (NetworkClient:928)
[2020-04-15 00:55:36,596] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Recorded API versions for node 2: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) (NetworkClient:882)
[2020-04-15 00:55:36,615] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Handling ListOffsetResponse response for test-topic-1217502653-0. Fetched offset 0, timestamp -1 (Fetcher:1002)
[2020-04-15 00:55:36,617] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Not replacing existing epoch 4 with new epoch 0 for partition test-topic-1217502653-0 (Metadata:185)
[2020-04-15 00:55:36,617] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Resetting offset for partition test-topic-1217502653-0 to offset 0. (SubscriptionState:385)
[2020-04-15 00:55:36,622] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Added READ_UNCOMMITTED fetch request for partition test-topic-1217502653-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null), epoch=4}} to node my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) (Fetcher:1138)
[2020-04-15 00:55:36,622] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Built full fetch (sessionId=INVALID, epoch=INITIAL) for node 2 with 1 partition(s). (FetchSessionHandler:200)
[2020-04-15 00:55:36,623] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Sending READ_UNCOMMITTED FullFetchRequest(test-topic-1217502653-0) to broker my-cluster-kafka-2.my-cluster-kafka-brokers.kafka-listeners-cluster-test.svc:9093 (id: 2 rack: null) (Fetcher:259)
[2020-04-15 00:55:36,646] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Node 2 sent a full fetch response that created a new incremental fetch session 524560882 with 1 response partition(s) (FetchSessionHandler:407)
[2020-04-15 00:55:36,648] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Fetch READ_UNCOMMITTED at offset 0 for partition test-topic-1217502653-0 returned fetch data (error=NONE, highWaterMark=700, lastStableOffset = 700, logStartOffset = 0, preferredReadReplica = absent, abortedTransactions = null, recordsSizeInBytes=35944) (Fetcher:308)
[2020-04-15 00:55:36,685] DEBUG Added sensor with name test-topic-1217502653-0.records-lag (Metrics:416)
[2020-04-15 00:55:36,687] DEBUG Added sensor with name test-topic-1217502653-0.records-lead (Metrics:416)
{"timestamp":1586912136690,"name":"records_consumed","count":500,"partitions":[{"topic":"test-topic-1217502653","partition":0,"count":300,"minOffset":0,"maxOffset":299}]}
[2020-04-15 00:55:36,722] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Committed offset 300 for partition test-topic-1217502653-0 (ConsumerCoordinator:1103)
{"timestamp":1586912136723,"name":"offsets_committed","offsets":[{"topic":"test-topic-1217502653","partition":0,"offset":300}],"success":true}
[2020-04-15 00:55:36,729] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Heartbeat thread has closed (AbstractCoordinator:1287)
[2020-04-15 00:55:36,730] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Executing onLeavePrepare with generation Generation{generationId=1, memberId='instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f', protocol='range'} and memberId instance1892788014-573fe7bf-056e-47ba-acc9-6be4ebf3805f (ConsumerCoordinator:699)
[2020-04-15 00:55:36,730] INFO [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Revoke previously assigned partitions test-topic-1217502653-0 (ConsumerCoordinator:286)
{"timestamp":1586912136730,"name":"partitions_revoked","partitions":[{"topic":"test-topic-1217502653","partition":0}]}
[2020-04-15 00:55:36,731] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Resetting generation due to consumer pro-actively leaving the group (AbstractCoordinator:860)
[2020-04-15 00:55:36,732] DEBUG Added sensor with name topic.test-topic-1217502653.bytes-fetched (Metrics:416)
[2020-04-15 00:55:36,732] DEBUG Added sensor with name topic.test-topic-1217502653.records-fetched (Metrics:416)
[2020-04-15 00:55:36,735] DEBUG Removed sensor with name connections-closed: (Metrics:449)
[2020-04-15 00:55:36,735] DEBUG Removed sensor with name connections-created: (Metrics:449)
[2020-04-15 00:55:36,735] DEBUG Removed sensor with name successful-authentication: (Metrics:449)
[2020-04-15 00:55:36,736] DEBUG Removed sensor with name successful-reauthentication: (Metrics:449)
[2020-04-15 00:55:36,736] DEBUG Removed sensor with name successful-authentication-no-reauth: (Metrics:449)
[2020-04-15 00:55:36,736] DEBUG Removed sensor with name failed-authentication: (Metrics:449)
[2020-04-15 00:55:36,736] DEBUG Removed sensor with name failed-reauthentication: (Metrics:449)
[2020-04-15 00:55:36,737] DEBUG Removed sensor with name reauthentication-latency: (Metrics:449)
[2020-04-15 00:55:36,737] DEBUG Removed sensor with name bytes-sent-received: (Metrics:449)
[2020-04-15 00:55:36,737] DEBUG Removed sensor with name bytes-sent: (Metrics:449)
[2020-04-15 00:55:36,738] DEBUG Removed sensor with name bytes-received: (Metrics:449)
[2020-04-15 00:55:36,738] DEBUG Removed sensor with name select-time: (Metrics:449)
[2020-04-15 00:55:36,738] DEBUG Removed sensor with name io-time: (Metrics:449)
[2020-04-15 00:55:36,739] DEBUG Removed sensor with name node--1.bytes-sent (Metrics:449)
[2020-04-15 00:55:36,739] DEBUG Removed sensor with name node--1.bytes-received (Metrics:449)
[2020-04-15 00:55:36,739] DEBUG Removed sensor with name node--1.latency (Metrics:449)
[2020-04-15 00:55:36,739] DEBUG Removed sensor with name node-2147483646.bytes-sent (Metrics:449)
[2020-04-15 00:55:36,740] DEBUG Removed sensor with name node-2147483646.bytes-received (Metrics:449)
[2020-04-15 00:55:36,740] DEBUG Removed sensor with name node-2147483646.latency (Metrics:449)
[2020-04-15 00:55:36,740] DEBUG Removed sensor with name node-2.bytes-sent (Metrics:449)
[2020-04-15 00:55:36,741] DEBUG Removed sensor with name node-2.bytes-received (Metrics:449)
[2020-04-15 00:55:36,741] DEBUG Removed sensor with name node-2.latency (Metrics:449)
[2020-04-15 00:55:36,741] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Kafka consumer has been closed (KafkaConsumer:2306)
{"timestamp":1586912136742,"name":"shutdown_complete"}
[2020-04-15 00:55:36,743] DEBUG [Consumer instanceId=instance1892788014, clientId=consumer-consumer-group-certs-71-instance1892788014, groupId=consumer-group-certs-71] Received user wakeup (ConsumerNetworkClient:186)
0

2020-04-15 00:55:37 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:185] Consumer finished correctly: true
2020-04-15 00:55:37 &amp#27;[32mINFO &amp#27;[m [InternalKafkaClient:188] Consumer consumed 500 messages
2020-04-15 00:55:37 &amp#27;[32mINFO &amp#27;[m [LogCollector:64] Collecting events in namespace kafka-listeners-cluster-test
2020-04-15 00:55:37 &amp#27;[32mINFO &amp#27;[m [LogCollector:71] Collecting configmaps in namespace kafka-listeners-cluster-test
2020-04-15 00:55:37 &amp#27;[32mINFO &amp#27;[m [LogCollector:44] Collecting logs for pods in namespace kafka-listeners-cluster-test
2020-04-15 00:55:43 &amp#27;[32mINFO &amp#27;[m [LogCollector:78] Collecting Deployments in namespaces kafka-listeners-cluster-test
2020-04-15 00:55:43 &amp#27;[32mINFO &amp#27;[m [LogCollector:83] Collecting StatefulSets in namespaces kafka-listeners-cluster-test
2020-04-15 00:55:43 &amp#27;[32mINFO &amp#27;[m [LogCollector:88] Collecting ReplicaSet in namespaces kafka-listeners-cluster-test
2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [LogCollector:93] Collecting CR in namespaces kafka-listeners-cluster-test
2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [Exec:166] Command: [oc, get, strimzi, -o, yaml, -n, kafka-listeners-cluster-test]
2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [Exec:167] Return code: 0
2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [Exec:168] stdout: 
apiVersion: v1
items:
- apiVersion: kafka.strimzi.io/v1beta1
  kind: Kafka
  metadata:
    creationTimestamp: 2020-04-15T00:31:21Z
    generation: 2
    name: my-cluster
    namespace: kafka-listeners-cluster-test
    resourceVersion: "114150"
    selfLink: /apis/kafka.strimzi.io/v1beta1/namespaces/kafka-listeners-cluster-test/kafkas/my-cluster
    uid: 6de9b225-7eb0-11ea-9470-fa163e98cdb6
  spec:
    entityOperator:
      topicOperator:
        image: docker.io/strimzi/operator:latest
        logging:
          loggers:
            rootLogger.level: DEBUG
          type: inline
        reconciliationIntervalSeconds: 90
        topicMetadataMaxAttempts: 6
        zookeeperSessionTimeoutSeconds: 20
      userOperator:
        image: docker.io/strimzi/operator:latest
        logging:
          loggers:
            rootLogger.level: DEBUG
          type: inline
        reconciliationIntervalSeconds: 120
        zookeeperSessionTimeoutSeconds: 6
    kafka:
      config:
        log.message.format.version: "2.4"
        offsets.topic.replication.factor: 3
        transaction.state.log.min.isr: 2
        transaction.state.log.replication.factor: 3
      listeners:
        external:
          configuration:
            brokerCertChainAndKey:
              certificate: ca.crt
              key: ca.key
              secretName: custom-certificate-server-1
          tls: true
          type: loadbalancer
        plain: {}
        tls:
          configuration:
            brokerCertChainAndKey:
              certificate: ca.crt
              key: ca.key
              secretName: custom-certificate-server-2
      logging:
        loggers:
          kafka.root.logger.level: DEBUG
        type: inline
      replicas: 3
      storage:
        deleteClaim: true
        size: "100"
        type: persistent-claim
      version: 2.4.0
    zookeeper:
      logging:
        loggers:
          zookeeper.root.logger: DEBUG
        type: inline
      replicas: 3
      storage:
        deleteClaim: true
        size: "100"
        type: persistent-claim
  status:
    conditions:
    - lastTransitionTime: 2020-04-15T00:55:01+0000
      status: "True"
      type: Ready
    listeners:
    - addresses:
      - host: my-cluster-kafka-bootstrap.kafka-listeners-cluster-test.svc
        port: 9092
      type: plain
    - addresses:
      - host: my-cluster-kafka-bootstrap.kafka-listeners-cluster-test.svc
        port: 9093
      certificates:
      - |
        -----BEGIN CERTIFICATE-----
        MIID2DCCAsCgAwIBAgIUY5+/5fre7Yye9bdcLkaX4rfuwOwwDQYJKoZIhvcNAQEL
        BQAwVDELMAkGA1UEBhMCQ1oxDzANBgNVBAcTBlByYWd1ZTEbMBkGA1UEChMSSmFr
        dWIgU2Nob2x6LCBJbmMuMRcwFQYDVQQDEw5JbnRlcm1lZGlhdGVDQTAeFw0yMDAx
        MjExMDAxMDBaFw0yMDEyMTkxODAxMDBaMFYxCzAJBgNVBAYTAkNaMQ8wDQYDVQQH
        EwZQcmFndWUxGzAZBgNVBAoTEkpha3ViIFNjaG9seiwgSW5jLjEZMBcGA1UEAxMQ
        a2Fma2Euc3RyaW16aS5pbzCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB
        AMupY44JPL6voWsMIBlD4TxKLTiD7WGPl20ez7VJgkpaVqtk3liCzuu6d7DjwQxC
        GjCsewa26mwJ1FJJOEC2MpQ4qgqGUTEWIXL3h27muB43qomsYYDnKTQVwySmR54i
        EIYHQZBqE7sJUo4cxZc9AsQ1vp2eMLnLDQ3fMNcg3jiFRk67LDx90SwdgiWkqTi5
        e786oO4y/1bOg0fdCvDyHqt/+LRMXuD3s9iXgHeAE3Y59Jpgijv8ZakDV4F9fp9W
        WTVh4Oz8whO1ouhkCaBGWA50oW+kPKSwPjyj8DrIqUMkQ16/nzqCfY5nt/Q3HeL4
        qlPbkHsD7Kgl1XiqvV0ErY0CAwEAAaOBnzCBnDAOBgNVHQ8BAf8EBAMCBaAwHQYD
        VR0lBBYwFAYIKwYBBQUHAwEGCCsGAQUFBwMCMAwGA1UdEwEB/wQCMAAwHQYDVR0O
        BBYEFNiIRl+fB0U+BmK6ZgVKY5ioAF7AMB8GA1UdIwQYMBaAFLVhFP0/k00g4+YT
        lL3FKgo6VsypMB0GA1UdEQQWMBSCEiouMTI3LjAuMC4xLm5pcC5pbzANBgkqhkiG
        9w0BAQsFAAOCAQEAQ4KCh93Oc80QkQmN5/hw8D1ru/m7apQOMeYFu/wQzTylyxJv
        FBdlxgdtfMZxFth3yhv7Gd+ftMlknJjYlB68eHXdlhm8pY9Ip1Y7Ks5uprq/Jy3p
        MBaCIfWCoRGsqrXtEYLewbRvh6zOGAAPrBxPDOSZt0GKd3Ivn9N7fv9MVF04LjqE
        Fx3EE6WMb+lezy/uaVuCN1UAFwwk3pHWOHfXIMze9xWd6mAIDdjGfCm0dVoYjdN8
        kgpHNFDyJv55SSuQ10LhxvAVp66Pb4hFfdAT/ItE25xGAUeupJubEpqGqPEZZG5r
        UmE8fUa+fs/tkDyFsWP58hgXxvr1e5rG+zn4kg==
        -----END CERTIFICATE-----
      type: tls
    - addresses:
      - host: 172.29.74.29
        port: 9094
      certificates:
      - |
        -----BEGIN CERTIFICATE-----
        MIID2DCCAsCgAwIBAgIUfxqU7q8SaHIi2sGVi2OmQfv0gNMwDQYJKoZIhvcNAQEL
        BQAwVDELMAkGA1UEBhMCQ1oxDzANBgNVBAcTBlByYWd1ZTEbMBkGA1UEChMSSmFr
        dWIgU2Nob2x6LCBJbmMuMRcwFQYDVQQDEw5JbnRlcm1lZGlhdGVDQTAeFw0yMDAx
        MjExMDU4MDBaFw0yMDEyMTkxODU4MDBaMFYxCzAJBgNVBAYTAkNaMQ8wDQYDVQQH
        EwZQcmFndWUxGzAZBgNVBAoTEkpha3ViIFNjaG9seiwgSW5jLjEZMBcGA1UEAxMQ
        a2Fma2Euc3RyaW16aS5pbzCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB
        ANIzxV80HudTvLWL54FWO+t9Ag4yP6iADRNB+HfU3Om1VO/Jh6aGbNsQCGxGPdth
        VW2NituJwbnlUNveW4g0AApw673fJ6MvivTfeiVfzU1kjkNxR5bRE0vTUXobH09O
        BSb8mvhJDrfAWzC8tpowDpS+Cq4KwY/8FZ22cFTPfAw3c+he9WZBuTloQ49fiY9J
        7KlDQL0ZCwPx5THvyjCSo5zoEDyCyubMLhVfEEvVlzMJ4diTlktFZKLhk6HMbHMr
        5Fe1mxnku9uHAnS/yXnA6b1ejiM+qCye3PTtBcbNPHSg5unioulhUxzHpC8qc2vT
        ul373X3L+LlO0Xoz8ZULJSMCAwEAAaOBnzCBnDAOBgNVHQ8BAf8EBAMCBaAwHQYD
        VR0lBBYwFAYIKwYBBQUHAwEGCCsGAQUFBwMCMAwGA1UdEwEB/wQCMAAwHQYDVR0O
        BBYEFLLT3C1aelVP4NP/l+GOobQWAL0zMB8GA1UdIwQYMBaAFGSGPZR4Hcd5B+rl
        ZhFX/KyH+HBiMB0GA1UdEQQWMBSCEiouMTI3LjAuMC4xLm5pcC5pbzANBgkqhkiG
        9w0BAQsFAAOCAQEAxFAoA1+Xhh8SHBCMsyA/tqS6zl0BVKocRbwYws81EAE45Ass
        fNmvzla9270awCkaj87hEvyFV/brbztAVBz7aQC5n3BLH6JGLnWS4rvxaz5diAW6
        4+CHKrp3DxLsMqWgsJC7K9m0i9dKkG3QYoTbVXbVrvfS9iuaT9ZgyQS0hdA5zDqn
        MfRJ/Nrpnt0d4w7edEySrMu37DXdOnUh20yTVVo+DfuViyunecRrGmzpu7bTnXbn
        fsMj50KWyBBiH4ypt5W0iLtq0lOYjGi+8H7D2iYEBRoSEwbQlNmkyuX5wopIn3F8
        JE8YKhaZ28m1XYbJlpsRItlFgn+V4oNTVxj8Lg==
        -----END CERTIFICATE-----
      type: external
    observedGeneration: 2
- apiVersion: kafka.strimzi.io/v1beta1
  kind: KafkaUser
  metadata:
    creationTimestamp: 2020-04-15T00:39:08Z
    generation: 1
    labels:
      strimzi.io/cluster: my-cluster
    name: alice
    namespace: kafka-listeners-cluster-test
    resourceVersion: "109213"
    selfLink: /apis/kafka.strimzi.io/v1beta1/namespaces/kafka-listeners-cluster-test/kafkausers/alice
    uid: 84769a67-7eb1-11ea-9470-fa163e98cdb6
  spec:
    authentication:
      type: tls
    authorization:
      acls:
      - host: '*'
        operation: Read
        resource:
          name: my-topic
          patternType: literal
          type: topic
        type: allow
      - host: '*'
        operation: Describe
        resource:
          name: my-topic
          patternType: literal
          type: topic
        type: allow
      - host: '*'
        operation: Read
        resource:
          name: my-group
          patternType: literal
          type: group
        type: allow
      - host: '*'
        operation: Write
        resource:
          name: my-topic
          patternType: literal
          type: topic
        type: allow
      - host: '*'
        operation: Create
        resource:
          name: my-topic
          patternType: literal
          type: topic
        type: allow
      - host: '*'
        operation: Describe
        resource:
          name: my-topic
          patternType: literal
          type: topic
        type: allow
      type: simple
  status:
    conditions:
    - lastTransitionTime: 2020-04-15T00:39:09.232Z
      status: "True"
      type: Ready
    observedGeneration: 1
    secret: alice
    username: CN=alice
- apiVersion: kafka.strimzi.io/v1beta1
  kind: KafkaTopic
  metadata:
    creationTimestamp: 2020-04-15T00:30:28Z
    generation: 1
    labels:
      strimzi.io/cluster: my-cluster
    name: consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a
    namespace: kafka-listeners-cluster-test
    resourceVersion: "109915"
    selfLink: /apis/kafka.strimzi.io/v1beta1/namespaces/kafka-listeners-cluster-test/kafkatopics/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a
    uid: 4e6d8fea-7eb0-11ea-9470-fa163e98cdb6
  spec:
    config:
      cleanup.policy: compact
      compression.type: producer
      message.format.version: 2.4-IV1
      segment.bytes: "104857600"
    partitions: 50
    replicas: 3
    topicName: __consumer_offsets
  status:
    conditions:
    - lastTransitionTime: 2020-04-15T00:41:07.898Z
      status: "True"
      type: Ready
    observedGeneration: 1
- apiVersion: kafka.strimzi.io/v1beta1
  kind: KafkaTopic
  metadata:
    creationTimestamp: 2020-04-15T00:39:10Z
    generation: 1
    labels:
      strimzi.io/cluster: my-cluster
    name: test-topic-1217502653
    namespace: kafka-listeners-cluster-test
    resourceVersion: "109231"
    selfLink: /apis/kafka.strimzi.io/v1beta1/namespaces/kafka-listeners-cluster-test/kafkatopics/test-topic-1217502653
    uid: 85705d06-7eb1-11ea-9470-fa163e98cdb6
  spec:
    config:
      message.format.version: 2.4-IV1
    partitions: 1
    replicas: 1
    topicName: test-topic-1217502653
  status:
    conditions:
    - lastTransitionTime: 2020-04-15T00:39:10.145Z
      status: "True"
      type: Ready
    observedGeneration: 1
kind: List
metadata:
  resourceVersion: ""
  selfLink: ""

2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [Exec:169] stderr: 

2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [BaseST:666] Search in strimzi-cluster-operator log for errors in last 0 seconds
2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [BaseST:750] Test execution contains exception, going to recreate test environment
2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [ResourceManager:341] Going to clear all method resources
2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [ResourceManager:177] Deleting Deployment my-cluster-kafka-clients
2020-04-15 00:55:44 &amp#27;[32mINFO &amp#27;[m [ResourceManager:323] Waiting when all the pods are terminated for Deployment my-cluster-kafka-clients
2020-04-15 00:55:44 &amp#27;[33mWARN &amp#27;[m [DeploymentUtils:187] Deployment my-cluster-kafka-clients is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:55:50 &amp#27;[32mINFO &amp#27;[m [PodUtils:138] Waiting when Pod my-cluster-kafka-clients-79bbb6849c-jk4n4 will be deleted
2020-04-15 00:56:28 &amp#27;[32mINFO &amp#27;[m [PodUtils:152] Pod my-cluster-kafka-clients-79bbb6849c-jk4n4 deleted
2020-04-15 00:56:28 &amp#27;[32mINFO &amp#27;[m [ResourceManager:216] Deleting KafkaUser alice in namespace kafka-listeners-cluster-test
2020-04-15 00:56:28 &amp#27;[32mINFO &amp#27;[m [ResourceManager:111] Deleting Kafka my-cluster in namespace kafka-listeners-cluster-test
2020-04-15 00:56:28 &amp#27;[32mINFO &amp#27;[m [ResourceManager:229] Waiting when all the pods are terminated for Kafka my-cluster
2020-04-15 00:56:28 &amp#27;[33mWARN &amp#27;[m [StatefulSetUtils:159] StatefulSet my-cluster-zookeeper is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:56:34 &amp#27;[32mINFO &amp#27;[m [PodUtils:138] Waiting when Pod my-cluster-zookeeper-0 will be deleted
2020-04-15 00:56:41 &amp#27;[32mINFO &amp#27;[m [PodUtils:152] Pod my-cluster-zookeeper-0 deleted
2020-04-15 00:56:41 &amp#27;[32mINFO &amp#27;[m [PodUtils:138] Waiting when Pod my-cluster-zookeeper-1 will be deleted
2020-04-15 00:56:41 &amp#27;[32mINFO &amp#27;[m [PodUtils:152] Pod my-cluster-zookeeper-1 deleted
2020-04-15 00:56:41 &amp#27;[32mINFO &amp#27;[m [PodUtils:138] Waiting when Pod my-cluster-zookeeper-2 will be deleted
2020-04-15 00:56:41 &amp#27;[32mINFO &amp#27;[m [PodUtils:152] Pod my-cluster-zookeeper-2 deleted
2020-04-15 00:56:41 &amp#27;[32mINFO &amp#27;[m [PodUtils:138] Waiting when Pod my-cluster-kafka-0 will be deleted
2020-04-15 00:57:12 &amp#27;[32mINFO &amp#27;[m [PodUtils:152] Pod my-cluster-kafka-0 deleted
2020-04-15 00:57:12 &amp#27;[32mINFO &amp#27;[m [PodUtils:138] Waiting when Pod my-cluster-kafka-1 will be deleted
2020-04-15 00:57:18 &amp#27;[32mINFO &amp#27;[m [PodUtils:152] Pod my-cluster-kafka-1 deleted
2020-04-15 00:57:18 &amp#27;[32mINFO &amp#27;[m [PodUtils:138] Waiting when Pod my-cluster-kafka-2 will be deleted
2020-04-15 00:57:18 &amp#27;[32mINFO &amp#27;[m [PodUtils:152] Pod my-cluster-kafka-2 deleted
2020-04-15 00:57:18 &amp#27;[32mINFO &amp#27;[m [SecretUtils:95] Waiting for Kafka cluster my-cluster secrets deletion
2020-04-15 00:57:18 &amp#27;[33mWARN &amp#27;[m [SecretUtils:103] Secret custom-certificate-chain-1 is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:57:19 &amp#27;[33mWARN &amp#27;[m [SecretUtils:103] Secret custom-certificate-chain-2 is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:57:19 &amp#27;[33mWARN &amp#27;[m [SecretUtils:103] Secret custom-certificate-root-1 is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:57:19 &amp#27;[33mWARN &amp#27;[m [SecretUtils:103] Secret custom-certificate-root-2 is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:57:19 &amp#27;[33mWARN &amp#27;[m [SecretUtils:103] Secret custom-certificate-server-1 is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:57:19 &amp#27;[33mWARN &amp#27;[m [SecretUtils:103] Secret custom-certificate-server-2 is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [SecretUtils:109] Kafka cluster my-cluster secrets deleted
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [PersistentVolumeClaimUtils:58] Waiting till PVC deletion for cluster my-cluster
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [PersistentVolumeClaimUtils:72] PVC for cluster my-cluster was deleted
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [ConfigMapUtils:66] Waiting till ConfigMaps deletion for cluster my-cluster-kafka-config
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [ConfigMapUtils:80] ConfigMaps for cluster my-cluster-kafka-config were deleted
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [ConfigMapUtils:66] Waiting till ConfigMaps deletion for cluster my-cluster-zookeeper-config
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [ConfigMapUtils:80] ConfigMaps for cluster my-cluster-zookeeper-config were deleted
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [ResourceManager:333] Going to clear all class resources
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [ResourceManager:177] Deleting Deployment strimzi-cluster-operator
2020-04-15 00:57:21 &amp#27;[32mINFO &amp#27;[m [ResourceManager:323] Waiting when all the pods are terminated for Deployment strimzi-cluster-operator
2020-04-15 00:57:21 &amp#27;[33mWARN &amp#27;[m [DeploymentUtils:187] Deployment strimzi-cluster-operator is not deleted yet! Triggering force delete by cmd client!
2020-04-15 00:57:26 &amp#27;[32mINFO &amp#27;[m [PodUtils:138] Waiting when Pod strimzi-cluster-operator-66c45d5474-r2rb4 will be deleted
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [PodUtils:152] Pod strimzi-cluster-operator-66c45d5474-r2rb4 deleted
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [ResourceManager:191] Deleting RoleBinding strimzi-cluster-operator-topic-operator-delegation
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [ResourceManager:191] Deleting RoleBinding strimzi-cluster-operator-entity-operator-delegation
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [ResourceManager:184] Deleting ClusterRoleBinding strimzi-cluster-operator-kafka-broker-delegation
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [ResourceManager:184] Deleting ClusterRoleBinding strimzi-cluster-operator
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [ResourceManager:191] Deleting RoleBinding strimzi-cluster-operator
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [ResourceManager:216] Deleting NetworkPolicy global-network-policy in namespace kafka-listeners-cluster-test
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [TimeMeasuringSystem:94] Start time of operation CO_DELETION is correctly stored
2020-04-15 00:57:38 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/048-Crd-kafkamirrormaker2.yaml
2020-04-15 00:57:39 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/047-Crd-kafkaconnector.yaml
2020-04-15 00:57:39 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/046-Crd-kafkabridge.yaml
2020-04-15 00:57:39 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/045-Crd-kafkamirrormaker.yaml
2020-04-15 00:57:40 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/044-Crd-kafkauser.yaml
2020-04-15 00:57:40 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/043-Crd-kafkatopic.yaml
2020-04-15 00:57:40 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/042-Crd-kafkaconnects2i.yaml
2020-04-15 00:57:40 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/041-Crd-kafkaconnect.yaml
2020-04-15 00:57:41 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/040-Crd-kafka.yaml
2020-04-15 00:57:41 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/032-ClusterRole-strimzi-topic-operator.yaml
2020-04-15 00:57:41 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/031-ClusterRole-strimzi-entity-operator.yaml
2020-04-15 00:57:42 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/030-ClusterRole-strimzi-kafka-broker.yaml
2020-04-15 00:57:42 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/021-ClusterRole-strimzi-cluster-operator-role.yaml
2020-04-15 00:57:42 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/020-ClusterRole-strimzi-cluster-operator-role.yaml
2020-04-15 00:57:42 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:185] Deleting configuration file: ../install/cluster-operator/010-ServiceAccount-strimzi-cluster-operator.yaml
2020-04-15 00:57:42 &amp#27;[32mINFO &amp#27;[m [TimeMeasuringSystem:113] End time of operation CO_DELETION is correctly stored
2020-04-15 00:57:42 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:231] Deleting namespace: kafka-listeners-cluster-test
2020-04-15 00:57:49 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:237] Using namespace kafka-listeners-cluster-test
2020-04-15 00:57:49 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:125] Changing to kafka-listeners-cluster-test namespace
2020-04-15 00:57:49 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:206] Creating namespace: kafka-listeners-cluster-test
2020-04-15 00:57:49 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:212] Using namespace kafka-listeners-cluster-test
2020-04-15 00:57:49 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:125] Changing to kafka-listeners-cluster-test namespace
2020-04-15 00:57:49 &amp#27;[32mINFO &amp#27;[m [TimeMeasuringSystem:94] Start time of operation CO_CREATION is correctly stored
2020-04-15 00:57:49 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/010-ServiceAccount-strimzi-cluster-operator.yaml
2020-04-15 00:57:49 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/020-ClusterRole-strimzi-cluster-operator-role.yaml
2020-04-15 00:57:50 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/021-ClusterRole-strimzi-cluster-operator-role.yaml
2020-04-15 00:57:50 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/030-ClusterRole-strimzi-kafka-broker.yaml
2020-04-15 00:57:50 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/031-ClusterRole-strimzi-entity-operator.yaml
2020-04-15 00:57:51 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/032-ClusterRole-strimzi-topic-operator.yaml
2020-04-15 00:57:51 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/040-Crd-kafka.yaml
2020-04-15 00:57:51 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/041-Crd-kafkaconnect.yaml
2020-04-15 00:57:52 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/042-Crd-kafkaconnects2i.yaml
2020-04-15 00:57:52 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/043-Crd-kafkatopic.yaml
2020-04-15 00:57:52 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/044-Crd-kafkauser.yaml
2020-04-15 00:57:52 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/045-Crd-kafkamirrormaker.yaml
2020-04-15 00:57:53 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/046-Crd-kafkabridge.yaml
2020-04-15 00:57:53 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/047-Crd-kafkaconnector.yaml
2020-04-15 00:57:53 &amp#27;[32mINFO &amp#27;[m [KubeClusterResource:103] Applying configuration file: ../install/cluster-operator/048-Crd-kafkamirrormaker2.yaml
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [TimeMeasuringSystem:113] End time of operation CO_CREATION is correctly stored
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [ResourceManager:94] Setting pointer to class resources
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:142] Creating RoleBinding from ../install/cluster-operator/020-RoleBinding-strimzi-cluster-operator.yaml in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:151] Apply RoleBinding in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of RoleBinding strimzi-cluster-operator in namespace (not set)
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:158] Creating ClusterRoleBinding from ../install/cluster-operator/021-ClusterRoleBinding-strimzi-cluster-operator.yaml in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:167] Apply ClusterRoleBinding in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of ClusterRoleBinding strimzi-cluster-operator in namespace (not set)
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:158] Creating ClusterRoleBinding from ../install/cluster-operator/030-ClusterRoleBinding-strimzi-cluster-operator-kafka-broker-delegation.yaml in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:167] Apply ClusterRoleBinding in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of ClusterRoleBinding strimzi-cluster-operator-kafka-broker-delegation in namespace (not set)
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:142] Creating RoleBinding from ../install/cluster-operator/031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:151] Apply RoleBinding in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of RoleBinding strimzi-cluster-operator-entity-operator-delegation in namespace (not set)
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:142] Creating RoleBinding from ../install/cluster-operator/032-RoleBinding-strimzi-cluster-operator-topic-operator-delegation.yaml in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:151] Apply RoleBinding in namespace kafka-listeners-cluster-test
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of RoleBinding strimzi-cluster-operator-topic-operator-delegation in namespace (not set)
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of Deployment strimzi-cluster-operator in namespace (not set)
2020-04-15 00:57:54 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:422] Waiting for deployment strimzi-cluster-operator
2020-04-15 00:58:39 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:424] Deployment strimzi-cluster-operator is ready
2020-04-15 00:58:39 &amp#27;[32mINFO &amp#27;[m [ResourceManager:106] Scheduled deletion of NetworkPolicy global-network-policy in namespace kafka-listeners-cluster-test
2020-04-15 00:58:39 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:402] Network policy successfully set to: DEFAULT_TO_DENY
2020-04-15 00:58:39 &amp#27;[32mINFO &amp#27;[m [KubernetesResource:324] NetworkPolicy successfully set to: true for namespace: kafka-listeners-cluster-test
2020-04-15 00:58:39 &amp#27;[32mINFO &amp#27;[m [BaseST:753] Env recreated.
2020-04-15 00:58:39 &amp#27;[32mINFO &amp#27;[m [ResourceManager:341] Going to clear all method resources
2020-04-15 00:58:39 &amp#27;[33mWARN &amp#27;[m [TimeMeasuringSystem:115] End time of operation TEST_EXECUTION is not set due to exception: java.lang.NullPointerException
2020-04-15 00:58:39 &amp#27;[32mINFO &amp#27;[m [TestSeparator:34] io.strimzi.systemtest.kafka.ListenersST.testCustomCertLoadBalancerAndTlsRollingUpdate-FINISHED
2020-04-15 00:58:39 &amp#27;[32mINFO &amp#27;[m [TestSeparator:35] ############################################################################

 Time: 04/15/2020 08:15:07, Level: ERROR, Log: 
Expected: is <300>
     but: was <500>

 Time: 04/15/2020 08:15:07, Level: INFO, Log: logs-pod-my-cluster-entity-operator-75785674f-2tq94-container-tls-sidecar.log

 Time: 04/15/2020 08:15:07, Level: INFO, Log: describe-pod-my-cluster-entity-operator-75785674f-2tq94-container-tls-sidecar.log

 Time: 04/15/2020 08:15:07, Level: INFO, Log: logs-pod-my-cluster-entity-operator-75785674f-2tq94-container-topic-operator.log

 Time: 04/15/2020 08:15:07, Level: INFO, Log: describe-pod-my-cluster-entity-operator-75785674f-2tq94-container-topic-operator.log

 Time: 04/15/2020 08:15:07, Level: INFO, Log: logs-pod-my-cluster-entity-operator-75785674f-2tq94-container-user-operator.log

 Time: 04/15/2020 08:15:07, Level: INFO, Log: describe-pod-my-cluster-entity-operator-75785674f-2tq94-container-user-operator.log

 Time: 04/15/2020 08:15:07, Level: INFO, Log: logs-pod-my-cluster-kafka-0-container-kafka.log

 Time: 04/15/2020 08:15:07, Level: INFO, Log: describe-pod-my-cluster-kafka-0-container-kafka.log

 Time: 04/15/2020 08:15:07, Level: INFO, Log: logs-pod-my-cluster-kafka-0-container-tls-sidecar.log

 Time: 04/15/2020 08:15:08, Level: INFO, Log: describe-pod-my-cluster-kafka-0-container-tls-sidecar.log

 Time: 04/15/2020 08:15:08, Level: INFO, Log: logs-pod-my-cluster-kafka-1-container-kafka.log

 Time: 04/15/2020 08:15:08, Level: INFO, Log: describe-pod-my-cluster-kafka-1-container-kafka.log

 Time: 04/15/2020 08:15:08, Level: INFO, Log: logs-pod-my-cluster-kafka-1-container-tls-sidecar.log

 Time: 04/15/2020 08:15:08, Level: INFO, Log: describe-pod-my-cluster-kafka-1-container-tls-sidecar.log

 Time: 04/15/2020 08:15:08, Level: INFO, Log: logs-pod-my-cluster-kafka-2-container-kafka.log

 Time: 04/15/2020 08:15:08, Level: INFO, Log: describe-pod-my-cluster-kafka-2-container-kafka.log

 Time: 04/15/2020 08:15:08, Level: INFO, Log: logs-pod-my-cluster-kafka-2-container-tls-sidecar.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: describe-pod-my-cluster-kafka-2-container-tls-sidecar.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: logs-pod-my-cluster-kafka-clients-79bbb6849c-jk4n4-container-my-cluster-kafka-clients.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: describe-pod-my-cluster-kafka-clients-79bbb6849c-jk4n4-container-my-cluster-kafka-clients.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: logs-pod-my-cluster-zookeeper-0-container-tls-sidecar.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: describe-pod-my-cluster-zookeeper-0-container-tls-sidecar.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: logs-pod-my-cluster-zookeeper-0-container-zookeeper.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: describe-pod-my-cluster-zookeeper-0-container-zookeeper.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: logs-pod-my-cluster-zookeeper-1-container-tls-sidecar.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: describe-pod-my-cluster-zookeeper-1-container-tls-sidecar.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: logs-pod-my-cluster-zookeeper-1-container-zookeeper.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: describe-pod-my-cluster-zookeeper-1-container-zookeeper.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: logs-pod-my-cluster-zookeeper-2-container-tls-sidecar.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: describe-pod-my-cluster-zookeeper-2-container-tls-sidecar.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: logs-pod-my-cluster-zookeeper-2-container-zookeeper.log

 Time: 04/15/2020 08:15:09, Level: INFO, Log: describe-pod-my-cluster-zookeeper-2-container-zookeeper.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: logs-pod-strimzi-cluster-operator-66c45d5474-r2rb4-container-strimzi-cluster-operator.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: describe-pod-strimzi-cluster-operator-66c45d5474-r2rb4-container-strimzi-cluster-operator.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: deployments.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: statefulsets.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: replicasets.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: strimzi-custom-resources.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: events-in-namespacekafka-listeners-cluster-test.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: my-cluster-entity-topic-operator-config-kafka-listeners-cluster-test.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: my-cluster-entity-user-operator-config-kafka-listeners-cluster-test.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: my-cluster-kafka-config-kafka-listeners-cluster-test.log

 Time: 04/15/2020 08:15:10, Level: INFO, Log: my-cluster-zookeeper-config-kafka-listeners-cluster-test.log