rodolk@rodolk-VirtualBox:/usr/local/kafka$ bin/kafka-console-consumer.sh --bootstrap-server ubuntutests:9093 --consumer.config config/consumer.properties --topic my-topic [2021-10-04 07:09:20,099] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [2021-10-04 07:09:20,403] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = latest bootstrap.servers = [ubuntutests:9093] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-test-consumer-group-7-1 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 = test-consumer-group-7 group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 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 = GSSAPI security.protocol = SSL security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = /usr/local/kafka/test/client.keystore.jks ssl.keystore.password = [hidden] ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = /usr/local/kafka/test/server/kafka.truststore.jks ssl.truststore.password = [hidden] ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2021-10-04 07:09:20,409] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Initializing the Kafka consumer (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-10-04 07:09:20,432] TRACE Registered metric named MetricName [name=count, group=kafka-metrics-count, description=total number of registered metrics, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:20.855 PDT|SSLCipher.java:438|jdk.tls.keyLimits: entry = AES/GCM/NoPadding KeyUpdate 2^37. AES/GCM/NOPADDING:KEYUPDATE = 137438953472 [2021-10-04 07:09:21,012] DEBUG Created SSL context with keystore SecurityStore(path=/usr/local/kafka/test/client.keystore.jks, modificationTime=Tue Sep 28 10:46:35 PDT 2021), truststore SecurityStore(path=/usr/local/kafka/test/server/kafka.truststore.jks, modificationTime=Tue Sep 28 10:44:13 PDT 2021), provider SunJSSE. (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory) [2021-10-04 07:09:21,019] TRACE Added sensor with name fetch-throttle-time (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,020] TRACE Registered metric named MetricName [name=fetch-throttle-time-avg, group=consumer-fetch-manager-metrics, description=The average throttle time in ms, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,021] TRACE Registered metric named MetricName [name=fetch-throttle-time-max, group=consumer-fetch-manager-metrics, description=The maximum throttle time in ms, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,033] TRACE Added sensor with name connections-closed: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,035] TRACE Registered metric named MetricName [name=connection-close-total, group=consumer-metrics, description=The total number of connections closed, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,036] TRACE Registered metric named MetricName [name=connection-close-rate, group=consumer-metrics, description=The number of connections closed per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,036] TRACE Added sensor with name connections-created: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,036] TRACE Registered metric named MetricName [name=connection-creation-total, group=consumer-metrics, description=The total number of new connections established, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,037] TRACE Registered metric named MetricName [name=connection-creation-rate, group=consumer-metrics, description=The number of new connections established per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,037] TRACE Added sensor with name successful-authentication: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,038] TRACE Registered metric named MetricName [name=successful-authentication-total, group=consumer-metrics, description=The total number of connections with successful authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,039] TRACE Registered metric named MetricName [name=successful-authentication-rate, group=consumer-metrics, description=The number of connections with successful authentication per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,039] TRACE Added sensor with name successful-reauthentication: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,047] TRACE Registered metric named MetricName [name=successful-reauthentication-total, group=consumer-metrics, description=The total number of successful re-authentication of connections, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,047] TRACE Registered metric named MetricName [name=successful-reauthentication-rate, group=consumer-metrics, description=The number of successful re-authentication of connections per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,047] TRACE Added sensor with name successful-authentication-no-reauth: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,049] TRACE Registered metric named MetricName [name=successful-authentication-no-reauth-total, group=consumer-metrics, description=The total number of connections with successful authentication where the client does not support re-authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,049] TRACE Added sensor with name failed-authentication: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,049] TRACE Registered metric named MetricName [name=failed-authentication-total, group=consumer-metrics, description=The total number of connections with failed authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,050] TRACE Registered metric named MetricName [name=failed-authentication-rate, group=consumer-metrics, description=The number of connections with failed authentication per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,050] TRACE Added sensor with name failed-reauthentication: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,055] TRACE Registered metric named MetricName [name=failed-reauthentication-total, group=consumer-metrics, description=The total number of failed re-authentication of connections, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,055] TRACE Registered metric named MetricName [name=failed-reauthentication-rate, group=consumer-metrics, description=The number of failed re-authentication of connections per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,055] TRACE Added sensor with name reauthentication-latency: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,056] TRACE Registered metric named MetricName [name=reauthentication-latency-max, group=consumer-metrics, description=The max latency observed due to re-authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,063] TRACE Registered metric named MetricName [name=reauthentication-latency-avg, group=consumer-metrics, description=The average latency observed due to re-authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,063] TRACE Added sensor with name bytes-sent-received: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,063] TRACE Registered metric named MetricName [name=network-io-total, group=consumer-metrics, description=The total number of network operations (reads or writes) on all connections, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,064] TRACE Registered metric named MetricName [name=network-io-rate, group=consumer-metrics, description=The number of network operations (reads or writes) on all connections per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,064] TRACE Added sensor with name bytes-sent: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,071] TRACE Registered metric named MetricName [name=outgoing-byte-total, group=consumer-metrics, description=The total number of outgoing bytes sent to all servers, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,072] TRACE Registered metric named MetricName [name=outgoing-byte-rate, group=consumer-metrics, description=The number of outgoing bytes sent to all servers per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,072] TRACE Added sensor with name requests-sent: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,072] TRACE Registered metric named MetricName [name=request-total, group=consumer-metrics, description=The total number of requests sent, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,072] TRACE Registered metric named MetricName [name=request-rate, group=consumer-metrics, description=The number of requests sent per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,072] TRACE Registered metric named MetricName [name=request-size-avg, group=consumer-metrics, description=The average size of requests sent., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,073] TRACE Registered metric named MetricName [name=request-size-max, group=consumer-metrics, description=The maximum size of any request sent., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,073] TRACE Added sensor with name bytes-received: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,073] TRACE Registered metric named MetricName [name=incoming-byte-total, group=consumer-metrics, description=The total number of bytes read off all sockets, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,073] TRACE Registered metric named MetricName [name=incoming-byte-rate, group=consumer-metrics, description=The number of bytes read off all sockets per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,073] TRACE Added sensor with name responses-received: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,074] TRACE Registered metric named MetricName [name=response-total, group=consumer-metrics, description=The total number of responses received, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,074] TRACE Registered metric named MetricName [name=response-rate, group=consumer-metrics, description=The number of responses received per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,074] TRACE Added sensor with name select-time: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,074] TRACE Registered metric named MetricName [name=select-total, group=consumer-metrics, description=The total number of times the I/O layer checked for new I/O to perform, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,081] TRACE Registered metric named MetricName [name=select-rate, group=consumer-metrics, description=The number of times the I/O layer checked for new I/O to perform per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,081] TRACE Registered metric named MetricName [name=io-wait-time-ns-avg, group=consumer-metrics, description=The average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,082] TRACE Registered metric named MetricName [name=io-waittime-total, group=consumer-metrics, description=The total time the I/O thread spent waiting, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,083] TRACE Registered metric named MetricName [name=io-wait-ratio, group=consumer-metrics, description=The fraction of time the I/O thread spent waiting, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,083] TRACE Added sensor with name io-time: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,084] TRACE Registered metric named MetricName [name=io-time-ns-avg, group=consumer-metrics, description=The average length of time for I/O per select call in nanoseconds., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,085] TRACE Registered metric named MetricName [name=iotime-total, group=consumer-metrics, description=The total time the I/O thread spent doing I/O, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,085] TRACE Registered metric named MetricName [name=io-ratio, group=consumer-metrics, description=The fraction of time the I/O thread spent doing I/O, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,088] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] sslCiphers: created new gauge suite with maxEntries = 100. (org.apache.kafka.common.network.Selector) [2021-10-04 07:09:21,088] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] clients: created new gauge suite with maxEntries = 100. (org.apache.kafka.common.network.Selector) [2021-10-04 07:09:21,089] TRACE Registered metric named MetricName [name=connection-count, group=consumer-metrics, description=The current number of active connections., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,126] TRACE Added sensor with name heartbeat-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,126] TRACE Registered metric named MetricName [name=heartbeat-response-time-max, group=consumer-coordinator-metrics, description=The max time taken to receive a response to a heartbeat request, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,127] TRACE Registered metric named MetricName [name=heartbeat-total, group=consumer-coordinator-metrics, description=The total number of heartbeats, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,127] TRACE Registered metric named MetricName [name=heartbeat-rate, group=consumer-coordinator-metrics, description=The number of heartbeats per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,127] TRACE Added sensor with name join-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,127] TRACE Registered metric named MetricName [name=join-time-avg, group=consumer-coordinator-metrics, description=The average time taken for a group rejoin, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,127] TRACE Registered metric named MetricName [name=join-time-max, group=consumer-coordinator-metrics, description=The max time taken for a group rejoin, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,127] TRACE Registered metric named MetricName [name=join-total, group=consumer-coordinator-metrics, description=The total number of group joins, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,128] TRACE Registered metric named MetricName [name=join-rate, group=consumer-coordinator-metrics, description=The number of group joins per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,128] TRACE Added sensor with name sync-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,128] TRACE Registered metric named MetricName [name=sync-time-avg, group=consumer-coordinator-metrics, description=The average time taken for a group sync, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,128] TRACE Registered metric named MetricName [name=sync-time-max, group=consumer-coordinator-metrics, description=The max time taken for a group sync, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,128] TRACE Registered metric named MetricName [name=sync-total, group=consumer-coordinator-metrics, description=The total number of group syncs, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,128] TRACE Registered metric named MetricName [name=sync-rate, group=consumer-coordinator-metrics, description=The number of group syncs per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,128] TRACE Added sensor with name rebalance-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,129] TRACE Registered metric named MetricName [name=rebalance-latency-avg, group=consumer-coordinator-metrics, description=The average time taken for a group to complete a successful rebalance, which may be composed of several failed re-trials until it succeeded, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,129] TRACE Registered metric named MetricName [name=rebalance-latency-max, group=consumer-coordinator-metrics, description=The max time taken for a group to complete a successful rebalance, which may be composed of several failed re-trials until it succeeded, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,129] TRACE Registered metric named MetricName [name=rebalance-latency-total, group=consumer-coordinator-metrics, description=The total number of milliseconds this consumer has spent in successful rebalances since creation, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,129] TRACE Registered metric named MetricName [name=rebalance-total, group=consumer-coordinator-metrics, description=The total number of successful rebalance events, each event is composed of several failed re-trials until it succeeded, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,129] TRACE Registered metric named MetricName [name=rebalance-rate-per-hour, group=consumer-coordinator-metrics, description=The number of successful rebalance events per hour, each event is composed of several failed re-trials until it succeeded, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,130] TRACE Added sensor with name failed-rebalance (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,130] TRACE Registered metric named MetricName [name=failed-rebalance-total, group=consumer-coordinator-metrics, description=The total number of failed rebalance events, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,130] TRACE Registered metric named MetricName [name=failed-rebalance-rate-per-hour, group=consumer-coordinator-metrics, description=The number of failed rebalance events per hour, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,130] TRACE Registered metric named MetricName [name=last-rebalance-seconds-ago, group=consumer-coordinator-metrics, description=The number of seconds since the last successful rebalance event, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,131] TRACE Registered metric named MetricName [name=last-heartbeat-seconds-ago, group=consumer-coordinator-metrics, description=The number of seconds since the last coordinator heartbeat was sent, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,131] TRACE Added sensor with name commit-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,132] TRACE Registered metric named MetricName [name=commit-latency-avg, group=consumer-coordinator-metrics, description=The average time taken for a commit request, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,132] TRACE Registered metric named MetricName [name=commit-latency-max, group=consumer-coordinator-metrics, description=The max time taken for a commit request, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,132] TRACE Registered metric named MetricName [name=commit-total, group=consumer-coordinator-metrics, description=The total number of commit calls, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,132] TRACE Registered metric named MetricName [name=commit-rate, group=consumer-coordinator-metrics, description=The number of commit calls per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,132] TRACE Added sensor with name partition-revoked-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,132] TRACE Registered metric named MetricName [name=partition-revoked-latency-avg, group=consumer-coordinator-metrics, description=The average time taken for a partition-revoked rebalance listener callback, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,132] TRACE Registered metric named MetricName [name=partition-revoked-latency-max, group=consumer-coordinator-metrics, description=The max time taken for a partition-revoked rebalance listener callback, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,132] TRACE Added sensor with name partition-assigned-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,133] TRACE Registered metric named MetricName [name=partition-assigned-latency-avg, group=consumer-coordinator-metrics, description=The average time taken for a partition-assigned rebalance listener callback, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,133] TRACE Registered metric named MetricName [name=partition-assigned-latency-max, group=consumer-coordinator-metrics, description=The max time taken for a partition-assigned rebalance listener callback, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,133] TRACE Added sensor with name partition-lost-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,133] TRACE Registered metric named MetricName [name=partition-lost-latency-avg, group=consumer-coordinator-metrics, description=The average time taken for a partition-lost rebalance listener callback, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,133] TRACE Registered metric named MetricName [name=partition-lost-latency-max, group=consumer-coordinator-metrics, description=The max time taken for a partition-lost rebalance listener callback, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,134] TRACE Registered metric named MetricName [name=assigned-partitions, group=consumer-coordinator-metrics, description=The number of partitions currently assigned to this consumer, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,136] TRACE Added sensor with name bytes-fetched (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,136] TRACE Registered metric named MetricName [name=fetch-size-avg, group=consumer-fetch-manager-metrics, description=The average number of bytes fetched per request, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,136] TRACE Registered metric named MetricName [name=fetch-size-max, group=consumer-fetch-manager-metrics, description=The maximum number of bytes fetched per request, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,136] TRACE Registered metric named MetricName [name=bytes-consumed-total, group=consumer-fetch-manager-metrics, description=The total number of bytes consumed, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,136] TRACE Registered metric named MetricName [name=bytes-consumed-rate, group=consumer-fetch-manager-metrics, description=The average number of bytes consumed per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,136] TRACE Added sensor with name records-fetched (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,136] TRACE Registered metric named MetricName [name=records-per-request-avg, group=consumer-fetch-manager-metrics, description=The average number of records in each request, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,137] TRACE Registered metric named MetricName [name=records-consumed-total, group=consumer-fetch-manager-metrics, description=The total number of records consumed, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,137] TRACE Registered metric named MetricName [name=records-consumed-rate, group=consumer-fetch-manager-metrics, description=The average number of records consumed per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,137] TRACE Added sensor with name fetch-latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,137] TRACE Registered metric named MetricName [name=fetch-latency-avg, group=consumer-fetch-manager-metrics, description=The average time taken for a fetch request., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,137] TRACE Registered metric named MetricName [name=fetch-latency-max, group=consumer-fetch-manager-metrics, description=The max time taken for any fetch request., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,137] TRACE Registered metric named MetricName [name=fetch-total, group=consumer-fetch-manager-metrics, description=The total number of fetch requests., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,137] TRACE Registered metric named MetricName [name=fetch-rate, group=consumer-fetch-manager-metrics, description=The number of fetch requests per second., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,137] TRACE Added sensor with name records-lag (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,138] TRACE Registered metric named MetricName [name=records-lag-max, group=consumer-fetch-manager-metrics, description=The maximum lag in terms of number of records for any partition in this window, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,138] TRACE Added sensor with name records-lead (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,138] TRACE Registered metric named MetricName [name=records-lead-min, group=consumer-fetch-manager-metrics, description=The minimum lead in terms of number of records for any partition in this window, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,140] TRACE Registered metric named MetricName [name=last-poll-seconds-ago, group=consumer-metrics, description=The number of seconds since the last poll() invocation., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,140] TRACE Added sensor with name time-between-poll (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,140] TRACE Registered metric named MetricName [name=time-between-poll-avg, group=consumer-metrics, description=The average delay between invocations of poll()., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,140] TRACE Registered metric named MetricName [name=time-between-poll-max, group=consumer-metrics, description=The max delay between invocations of poll()., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,140] TRACE Added sensor with name poll-idle-ratio-avg (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,140] TRACE Registered metric named MetricName [name=poll-idle-ratio-avg, group=consumer-metrics, description=The average fraction of time the consumer's poll() is idle as opposed to waiting for the user code to process records., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,160] INFO Kafka version: 2.8.0 (org.apache.kafka.common.utils.AppInfoParser) [2021-10-04 07:09:21,167] INFO Kafka commitId: ebb1d6e21cc92130 (org.apache.kafka.common.utils.AppInfoParser) [2021-10-04 07:09:21,171] INFO Kafka startTimeMs: 1633356561140 (org.apache.kafka.common.utils.AppInfoParser) [2021-10-04 07:09:21,176] TRACE Registered metric named MetricName [name=version, group=app-info, description=Metric indicating version, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,177] TRACE Registered metric named MetricName [name=commit-id, group=app-info, description=Metric indicating commit-id, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,177] TRACE Registered metric named MetricName [name=start-time-ms, group=app-info, description=Metric indicating start-time-ms, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,177] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Kafka consumer initialized (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-10-04 07:09:21,178] INFO [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Subscribed to topic(s): my-topic (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-10-04 07:09:21,185] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Found least loaded node ubuntutests:9093 (id: -1 rack: null) with no active connection (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,186] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Sending FindCoordinator request to broker ubuntutests:9093 (id: -1 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-10-04 07:09:21,430] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Initiating connection to node ubuntutests:9093 (id: -1 rack: null) using address ubuntutests/192.168.56.102 (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,446] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Found least loaded connecting node ubuntutests:9093 (id: -1 rack: null) (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,446] TRACE Added sensor with name node--1.requests-sent (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,447] TRACE Registered metric named MetricName [name=request-total, group=consumer-node-metrics, description=The total number of requests sent, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,447] TRACE Registered metric named MetricName [name=request-rate, group=consumer-node-metrics, description=The number of requests sent per second, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,448] TRACE Registered metric named MetricName [name=request-size-avg, group=consumer-node-metrics, description=The average size of requests sent., tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,448] TRACE Registered metric named MetricName [name=request-size-max, group=consumer-node-metrics, description=The maximum size of any request sent., tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,448] TRACE Added sensor with name node--1.bytes-sent (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,449] TRACE Registered metric named MetricName [name=outgoing-byte-total, group=consumer-node-metrics, description=The total number of outgoing bytes, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,450] TRACE Registered metric named MetricName [name=outgoing-byte-rate, group=consumer-node-metrics, description=The number of outgoing bytes per second, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,450] TRACE Added sensor with name node--1.responses-received (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,450] TRACE Registered metric named MetricName [name=response-total, group=consumer-node-metrics, description=The total number of responses received, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,450] TRACE Registered metric named MetricName [name=response-rate, group=consumer-node-metrics, description=The number of responses received per second, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,450] TRACE Added sensor with name node--1.bytes-received (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,450] TRACE Registered metric named MetricName [name=incoming-byte-total, group=consumer-node-metrics, description=The total number of incoming bytes, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,452] TRACE Registered metric named MetricName [name=incoming-byte-rate, group=consumer-node-metrics, description=The number of incoming bytes per second, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,452] TRACE Added sensor with name node--1.latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,452] TRACE Registered metric named MetricName [name=request-latency-avg, group=consumer-node-metrics, description=, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,452] TRACE Registered metric named MetricName [name=request-latency-max, group=consumer-node-metrics, description=, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,453] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 (org.apache.kafka.common.network.Selector) javax.net.ssl|WARNING|01|main|2021-10-04 07:09:21.495 PDT|ServerNameExtension.java:261|Unable to indicate server name javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.495 PDT|SSLExtensions.java:260|Ignore, context unavailable extension: server_name javax.net.ssl|WARNING|01|main|2021-10-04 07:09:21.515 PDT|SignatureScheme.java:295|Signature algorithm, ed25519, is not supported by the underlying providers javax.net.ssl|WARNING|01|main|2021-10-04 07:09:21.516 PDT|SignatureScheme.java:295|Signature algorithm, ed448, is not supported by the underlying providers javax.net.ssl|INFO|01|main|2021-10-04 07:09:21.538 PDT|AlpnExtension.java:161|No available application protocols javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.538 PDT|SSLExtensions.java:260|Ignore, context unavailable extension: application_layer_protocol_negotiation javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.539 PDT|SSLExtensions.java:260|Ignore, context unavailable extension: renegotiation_info javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.551 PDT|ClientHello.java:653|Produced ClientHello handshake message ( "ClientHello": { "client version" : "TLSv1.2", "random" : "A1 27 04 7C 4F A9 82 FF 59 1A BC 3E 6C 6C 24 E4 E8 16 95 A3 16 95 0C BC 69 73 B3 8F C3 90 FF 50", "session id" : "", "cipher suites" : "[TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384(0xC02C), TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256(0xC02B), TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384(0xC030), TLS_RSA_WITH_AES_256_GCM_SHA384(0x009D), TLS_ECDH_ECDSA_WITH_AES_256_GCM_SHA384(0xC02E), TLS_ECDH_RSA_WITH_AES_256_GCM_SHA384(0xC032), TLS_DHE_RSA_WITH_AES_256_GCM_SHA384(0x009F), TLS_DHE_DSS_WITH_AES_256_GCM_SHA384(0x00A3), TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256(0xC02F), TLS_RSA_WITH_AES_128_GCM_SHA256(0x009C), TLS_ECDH_ECDSA_WITH_AES_128_GCM_SHA256(0xC02D), TLS_ECDH_RSA_WITH_AES_128_GCM_SHA256(0xC031), TLS_DHE_RSA_WITH_AES_128_GCM_SHA256(0x009E), TLS_DHE_DSS_WITH_AES_128_GCM_SHA256(0x00A2), TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA384(0xC024), TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384(0xC028), TLS_RSA_WITH_AES_256_CBC_SHA256(0x003D), TLS_ECDH_ECDSA_WITH_AES_256_CBC_SHA384(0xC026), TLS_ECDH_RSA_WITH_AES_256_CBC_SHA384(0xC02A), TLS_DHE_RSA_WITH_AES_256_CBC_SHA256(0x006B), TLS_DHE_DSS_WITH_AES_256_CBC_SHA256(0x006A), TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA(0xC00A), TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA(0xC014), TLS_RSA_WITH_AES_256_CBC_SHA(0x0035), TLS_ECDH_ECDSA_WITH_AES_256_CBC_SHA(0xC005), TLS_ECDH_RSA_WITH_AES_256_CBC_SHA(0xC00F), TLS_DHE_RSA_WITH_AES_256_CBC_SHA(0x0039), TLS_DHE_DSS_WITH_AES_256_CBC_SHA(0x0038), TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256(0xC023), TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256(0xC027), TLS_RSA_WITH_AES_128_CBC_SHA256(0x003C), TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA256(0xC025), TLS_ECDH_RSA_WITH_AES_128_CBC_SHA256(0xC029), TLS_DHE_RSA_WITH_AES_128_CBC_SHA256(0x0067), TLS_DHE_DSS_WITH_AES_128_CBC_SHA256(0x0040), TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA(0xC009), TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA(0xC013), TLS_RSA_WITH_AES_128_CBC_SHA(0x002F), TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA(0xC004), TLS_ECDH_RSA_WITH_AES_128_CBC_SHA(0xC00E), TLS_DHE_RSA_WITH_AES_128_CBC_SHA(0x0033), TLS_DHE_DSS_WITH_AES_128_CBC_SHA(0x0032), TLS_EMPTY_RENEGOTIATION_INFO_SCSV(0x00FF)]", "compression methods" : "00", "extensions" : [ "status_request (5)": { "certificate status type": ocsp "OCSP status request": { "responder_id": "request extensions": { } } }, "supported_groups (10)": { "versions": [x25519, secp256r1, secp384r1, secp521r1, x448, ffdhe2048, ffdhe3072, ffdhe4096, ffdhe6144, ffdhe8192] }, "ec_point_formats (11)": { "formats": [uncompressed] }, "signature_algorithms (13)": { "signature schemes": [ecdsa_secp256r1_sha256, ecdsa_secp384r1_sha384, ecdsa_secp521r1_sha512, rsa_pss_rsae_sha256, rsa_pss_rsae_sha384, rsa_pss_rsae_sha512, rsa_pss_pss_sha256, rsa_pss_pss_sha384, rsa_pss_pss_sha512, rsa_pkcs1_sha256, rsa_pkcs1_sha384, rsa_pkcs1_sha512, dsa_sha256, ecdsa_sha224, rsa_sha224, dsa_sha224, ecdsa_sha1, rsa_pkcs1_sha1, dsa_sha1] }, "signature_algorithms_cert (50)": { "signature schemes": [ecdsa_secp256r1_sha256, ecdsa_secp384r1_sha384, ecdsa_secp521r1_sha512, rsa_pss_rsae_sha256, rsa_pss_rsae_sha384, rsa_pss_rsae_sha512, rsa_pss_pss_sha256, rsa_pss_pss_sha384, rsa_pss_pss_sha512, rsa_pkcs1_sha256, rsa_pkcs1_sha384, rsa_pkcs1_sha512, dsa_sha256, ecdsa_sha224, rsa_sha224, dsa_sha224, ecdsa_sha1, rsa_pkcs1_sha1, dsa_sha1] }, "status_request_v2 (17)": { "cert status request": { "certificate status type": ocsp_multi "OCSP status request": { "responder_id": "request extensions": { } } } }, "extended_master_secret (23)": { }, "supported_versions (43)": { "versions": [TLSv1.2] } ] } ) [2021-10-04 07:09:21,553] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake NEED_WRAP channelId -1, appReadBuffer pos 0, netReadBuffer pos 0, netWriteBuffer pos 0 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,553] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake handshakeWrap -1 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,554] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake NEED_WRAP channelId -1, handshakeResult Status = OK HandshakeStatus = NEED_UNWRAP bytesConsumed = 0 bytesProduced = 289 sequenceNumber = 0, appReadBuffer pos 0, netReadBuffer pos 0, netWriteBuffer pos 0 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,554] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake NEED_UNWRAP channelId -1, appReadBuffer pos 0, netReadBuffer pos 0, netWriteBuffer pos 289 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,554] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake handshakeUnwrap -1 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,554] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake handshakeUnwrap: handshakeStatus NEED_UNWRAP status BUFFER_UNDERFLOW (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,554] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake NEED_UNWRAP channelId -1, handshakeResult Status = BUFFER_UNDERFLOW HandshakeStatus = NEED_UNWRAP bytesConsumed = 0 bytesProduced = 0, appReadBuffer pos 0, netReadBuffer pos 0, netWriteBuffer pos 289 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,566] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Completed connection to node -1. Fetching API versions. (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,567] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Found least loaded connecting node ubuntutests:9093 (id: -1 rack: null) (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,567] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake NEED_UNWRAP channelId -1, appReadBuffer pos 0, netReadBuffer pos 2242, netWriteBuffer pos 289 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,568] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake handshakeUnwrap -1 (org.apache.kafka.common.network.SslTransportLayer) javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.569 PDT|ServerHello.java:872|Consuming ServerHello handshake message ( "ServerHello": { "server version" : "TLSv1.2", "random" : "D8 51 06 6D E3 66 36 8A CC D0 1C 04 07 40 A8 19 10 35 62 77 3B 60 28 DA 42 24 3B 05 80 92 88 A3", "session id" : "55 CC FA 0F FC 38 D8 4B 4D BF A3 B3 4B 7F 9C E3 5D D3 96 9B E0 9B AD 9C E4 AA FA AD 3A 70 C9 B8", "cipher suite" : "TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384(0xC030)", "compression methods" : "00", "extensions" : [ "extended_master_secret (23)": { }, "renegotiation_info (65,281)": { "renegotiated connection": [] } ] } ) javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.569 PDT|SSLExtensions.java:173|Ignore unavailable extension: supported_versions javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.570 PDT|ServerHello.java:968|Negotiated protocol version: TLSv1.2 javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.571 PDT|SSLExtensions.java:192|Consumed extension: renegotiation_info javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.571 PDT|SSLExtensions.java:173|Ignore unavailable extension: server_name javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.571 PDT|SSLExtensions.java:173|Ignore unavailable extension: max_fragment_length javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.571 PDT|SSLExtensions.java:173|Ignore unavailable extension: status_request javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.572 PDT|SSLExtensions.java:173|Ignore unavailable extension: ec_point_formats javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.572 PDT|SSLExtensions.java:173|Ignore unavailable extension: status_request_v2 javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.572 PDT|SSLExtensions.java:192|Consumed extension: extended_master_secret javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.574 PDT|SSLExtensions.java:192|Consumed extension: renegotiation_info javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.583 PDT|SSLExtensions.java:207|Ignore unavailable extension: server_name javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.583 PDT|SSLExtensions.java:207|Ignore unavailable extension: max_fragment_length javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.584 PDT|SSLExtensions.java:207|Ignore unavailable extension: status_request javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.584 PDT|SSLExtensions.java:207|Ignore unavailable extension: ec_point_formats javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.584 PDT|SSLExtensions.java:207|Ignore unavailable extension: application_layer_protocol_negotiation javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.585 PDT|SSLExtensions.java:207|Ignore unavailable extension: status_request_v2 javax.net.ssl|WARNING|01|main|2021-10-04 07:09:21.586 PDT|SSLExtensions.java:215|Ignore impact of unsupported extension: extended_master_secret javax.net.ssl|WARNING|01|main|2021-10-04 07:09:21.586 PDT|SSLExtensions.java:215|Ignore impact of unsupported extension: renegotiation_info javax.net.ssl|DEBUG|01|main|2021-10-04 07:09:21.593 PDT|CertificateMessage.java:366|Consuming server Certificate handshake message ( "Certificates": [ "certificate" : { "version" : "v1", "serial number" : "65 A6 52 BE 40 34 2B 6E 09 DD 08 51 4D DE A8 DA 38 F8 92 5F", "signature algorithm": "SHA256withRSA", "issuer" : "EMAILADDRESS=a@mi.com, CN=*.wayaga.com, O=Wayaga, L=Hillsboro, ST=OR, C=US", "not before" : "2021-09-28 08:05:33.000 PDT", "not after" : "2022-09-28 08:05:33.000 PDT", "subject" : "CN=kafka01.wayaga.com, OU=Unknown, O=Wayaga, L=Hillsboro, ST=OR, C=US", "subject public key" : "RSA"}, "certificate" : { "version" : "v3", "serial number" : "69 F0 75 93 F0 7C 4F 0D 2A 77 AF 6E DF 4E 23 77 D4 C1 A2 FF", "signature algorithm": "SHA256withRSA", "issuer" : "EMAILADDRESS=a@mi.com, CN=*.wayaga.com, O=Wayaga, L=Hillsboro, ST=OR, C=US", "not before" : "2021-09-28 07:50:37.000 PDT", "not after" : "2021-10-28 07:50:37.000 PDT", "subject" : "EMAILADDRESS=a@mi.com, CN=*.wayaga.com, O=Wayaga, L=Hillsboro, ST=OR, C=US", "subject public key" : "RSA", "extensions" : [ { ObjectId: 2.5.29.35 Criticality=false AuthorityKeyIdentifier [ KeyIdentifier [ 0000: 98 C7 AB 30 18 58 70 D1 61 04 EA 54 50 66 E0 B9 ...0.Xp.a..TPf.. 0010: C8 91 20 56 .. V ] ] }, { ObjectId: 2.5.29.19 Criticality=true BasicConstraints:[ CA:true PathLen:2147483647 ] }, { ObjectId: 2.5.29.14 Criticality=false SubjectKeyIdentifier [ KeyIdentifier [ 0000: 98 C7 AB 30 18 58 70 D1 61 04 EA 54 50 66 E0 B9 ...0.Xp.a..TPf.. 0010: C8 91 20 56 .. V ] ] } ]} ] ) javax.net.ssl|ERROR|01|main|2021-10-04 07:09:21.828 PDT|TransportContext.java:341|Fatal (CERTIFICATE_UNKNOWN): No name matching ubuntutests found ( "throwable" : { java.security.cert.CertificateException: No name matching ubuntutests found at java.base/sun.security.util.HostnameChecker.matchDNS(HostnameChecker.java:234) at java.base/sun.security.util.HostnameChecker.match(HostnameChecker.java:103) at java.base/sun.security.ssl.X509TrustManagerImpl.checkIdentity(X509TrustManagerImpl.java:455) at java.base/sun.security.ssl.X509TrustManagerImpl.checkIdentity(X509TrustManagerImpl.java:429) at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:283) at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:141) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:632) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369) at java.base/sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:392) at java.base/sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:443) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1074) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1061) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1008) at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:430) at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:514) at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:368) at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:291) at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) at org.apache.kafka.common.network.Selector.poll(Selector.java:481) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:215) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:245) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:480) at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1261) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1230) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1210) at kafka.tools.ConsoleConsumer$ConsumerWrapper.receive(ConsoleConsumer.scala:443) at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:102) at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:76) at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53) at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)} ) [2021-10-04 07:09:21,832] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake handshakeUnwrap: handshakeStatus NEED_WRAP status OK (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,832] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake NEED_UNWRAP channelId -1, handshakeResult Status = OK HandshakeStatus = NEED_TASK bytesConsumed = 2242 bytesProduced = 0, appReadBuffer pos 0, netReadBuffer pos 0, netWriteBuffer pos 289 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,833] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Found least loaded connecting node ubuntutests:9093 (id: -1 rack: null) (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,833] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake NEED_WRAP channelId -1, appReadBuffer pos 0, netReadBuffer pos 0, netWriteBuffer pos 289 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,833] TRACE [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=ubuntutests/192.168.56.102:9093], selector=sun.nio.ch.EPollSelectorImpl@4e858e0a, interestOps=8, readyOps=0] SSLHandshake handshakeWrap -1 (org.apache.kafka.common.network.SslTransportLayer) [2021-10-04 07:09:21,833] INFO [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Failed authentication with ubuntutests/192.168.56.102 (SSL handshake failed) (org.apache.kafka.common.network.Selector) javax.net.ssl|WARNING|01|main|2021-10-04 07:09:21.834 PDT|SSLEngineOutputRecord.java:168|outbound has closed, ignore outbound application data [2021-10-04 07:09:21,835] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,836] ERROR [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Connection to node -1 (ubuntutests/192.168.56.102:9093) failed authentication due to: SSL handshake failed (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,836] WARN [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Bootstrap broker ubuntutests:9093 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient) [2021-10-04 07:09:21,850] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] FindCoordinator request failed due to {} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed Caused by: javax.net.ssl.SSLHandshakeException: No name matching ubuntutests found at java.base/sun.security.ssl.Alert.createSSLException(Alert.java:131) at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:349) at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:292) at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:287) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:654) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369) at java.base/sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:392) at java.base/sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:443) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1074) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1061) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1008) at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:430) at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:514) at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:368) at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:291) at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) at org.apache.kafka.common.network.Selector.poll(Selector.java:481) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:215) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:245) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:480) at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1261) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1230) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1210) at kafka.tools.ConsoleConsumer$ConsumerWrapper.receive(ConsoleConsumer.scala:443) at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:102) at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:76) at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53) at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala) Caused by: java.security.cert.CertificateException: No name matching ubuntutests found at java.base/sun.security.util.HostnameChecker.matchDNS(HostnameChecker.java:234) at java.base/sun.security.util.HostnameChecker.match(HostnameChecker.java:103) at java.base/sun.security.ssl.X509TrustManagerImpl.checkIdentity(X509TrustManagerImpl.java:455) at java.base/sun.security.ssl.X509TrustManagerImpl.checkIdentity(X509TrustManagerImpl.java:429) at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:283) at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:141) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:632) ... 29 more [2021-10-04 07:09:21,864] ERROR Error processing message, terminating consumer process: (kafka.tools.ConsoleConsumer$) org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed Caused by: javax.net.ssl.SSLHandshakeException: No name matching ubuntutests found at java.base/sun.security.ssl.Alert.createSSLException(Alert.java:131) at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:349) at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:292) at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:287) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:654) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369) at java.base/sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:392) at java.base/sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:443) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1074) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1061) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1008) at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:430) at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:514) at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:368) at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:291) at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) at org.apache.kafka.common.network.Selector.poll(Selector.java:481) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:215) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:245) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:480) at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1261) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1230) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1210) at kafka.tools.ConsoleConsumer$ConsumerWrapper.receive(ConsoleConsumer.scala:443) at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:102) at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:76) at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53) at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala) Caused by: java.security.cert.CertificateException: No name matching ubuntutests found at java.base/sun.security.util.HostnameChecker.matchDNS(HostnameChecker.java:234) at java.base/sun.security.util.HostnameChecker.match(HostnameChecker.java:103) at java.base/sun.security.ssl.X509TrustManagerImpl.checkIdentity(X509TrustManagerImpl.java:455) at java.base/sun.security.ssl.X509TrustManagerImpl.checkIdentity(X509TrustManagerImpl.java:429) at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:283) at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:141) at java.base/sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:632) ... 29 more [2021-10-04 07:09:21,899] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Closing the Kafka consumer (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-10-04 07:09:21,903] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Sending synchronous auto-commit of offsets {} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-10-04 07:09:21,903] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Executing onLeavePrepare with generation Generation{generationId=-1, memberId='', protocol='null'} and memberId (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-10-04 07:09:21,903] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Resetting generation due to consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-10-04 07:09:21,903] TRACE Removed metric named MetricName [name=last-poll-seconds-ago, group=consumer-metrics, description=The number of seconds since the last poll() invocation., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,904] TRACE Removed metric named MetricName [name=time-between-poll-avg, group=consumer-metrics, description=The average delay between invocations of poll()., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,904] TRACE Removed metric named MetricName [name=time-between-poll-max, group=consumer-metrics, description=The max delay between invocations of poll()., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,904] TRACE Removed sensor with name time-between-poll (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,905] TRACE Removed metric named MetricName [name=poll-idle-ratio-avg, group=consumer-metrics, description=The average fraction of time the consumer's poll() is idle as opposed to waiting for the user code to process records., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,905] TRACE Removed sensor with name poll-idle-ratio-avg (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,905] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,905] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,905] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,912] TRACE Removed metric named MetricName [name=connection-count, group=consumer-metrics, description=The current number of active connections., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,912] TRACE Removed metric named MetricName [name=connection-close-total, group=consumer-metrics, description=The total number of connections closed, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,912] TRACE Removed metric named MetricName [name=connection-close-rate, group=consumer-metrics, description=The number of connections closed per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,912] TRACE Removed sensor with name connections-closed: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,913] TRACE Removed metric named MetricName [name=connection-creation-total, group=consumer-metrics, description=The total number of new connections established, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,913] TRACE Removed metric named MetricName [name=connection-creation-rate, group=consumer-metrics, description=The number of new connections established per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,913] TRACE Removed sensor with name connections-created: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,914] TRACE Removed metric named MetricName [name=successful-authentication-total, group=consumer-metrics, description=The total number of connections with successful authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,914] TRACE Removed metric named MetricName [name=successful-authentication-rate, group=consumer-metrics, description=The number of connections with successful authentication per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,914] TRACE Removed sensor with name successful-authentication: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,914] TRACE Removed metric named MetricName [name=successful-reauthentication-total, group=consumer-metrics, description=The total number of successful re-authentication of connections, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,917] TRACE Removed metric named MetricName [name=successful-reauthentication-rate, group=consumer-metrics, description=The number of successful re-authentication of connections per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,918] TRACE Removed sensor with name successful-reauthentication: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,918] TRACE Removed metric named MetricName [name=successful-authentication-no-reauth-total, group=consumer-metrics, description=The total number of connections with successful authentication where the client does not support re-authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,919] TRACE Removed sensor with name successful-authentication-no-reauth: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,919] TRACE Removed metric named MetricName [name=failed-authentication-total, group=consumer-metrics, description=The total number of connections with failed authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,920] TRACE Removed metric named MetricName [name=failed-authentication-rate, group=consumer-metrics, description=The number of connections with failed authentication per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,920] TRACE Removed sensor with name failed-authentication: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,922] TRACE Removed metric named MetricName [name=failed-reauthentication-total, group=consumer-metrics, description=The total number of failed re-authentication of connections, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,922] TRACE Removed metric named MetricName [name=failed-reauthentication-rate, group=consumer-metrics, description=The number of failed re-authentication of connections per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,925] TRACE Removed sensor with name failed-reauthentication: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,925] TRACE Removed metric named MetricName [name=reauthentication-latency-max, group=consumer-metrics, description=The max latency observed due to re-authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,926] TRACE Removed metric named MetricName [name=reauthentication-latency-avg, group=consumer-metrics, description=The average latency observed due to re-authentication, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,926] TRACE Removed sensor with name reauthentication-latency: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,926] TRACE Removed metric named MetricName [name=network-io-total, group=consumer-metrics, description=The total number of network operations (reads or writes) on all connections, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,930] TRACE Removed metric named MetricName [name=network-io-rate, group=consumer-metrics, description=The number of network operations (reads or writes) on all connections per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,939] TRACE Removed sensor with name bytes-sent-received: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,939] TRACE Removed metric named MetricName [name=outgoing-byte-total, group=consumer-metrics, description=The total number of outgoing bytes sent to all servers, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,940] TRACE Removed metric named MetricName [name=outgoing-byte-rate, group=consumer-metrics, description=The number of outgoing bytes sent to all servers per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,940] TRACE Removed sensor with name bytes-sent: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,940] TRACE Removed metric named MetricName [name=incoming-byte-total, group=consumer-metrics, description=The total number of bytes read off all sockets, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,941] TRACE Removed metric named MetricName [name=incoming-byte-rate, group=consumer-metrics, description=The number of bytes read off all sockets per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,941] TRACE Removed sensor with name bytes-received: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,941] TRACE Removed metric named MetricName [name=request-total, group=consumer-metrics, description=The total number of requests sent, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,941] TRACE Removed metric named MetricName [name=request-rate, group=consumer-metrics, description=The number of requests sent per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,942] TRACE Removed metric named MetricName [name=request-size-avg, group=consumer-metrics, description=The average size of requests sent., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,942] TRACE Removed metric named MetricName [name=request-size-max, group=consumer-metrics, description=The maximum size of any request sent., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,943] TRACE Removed sensor with name requests-sent: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,943] TRACE Removed metric named MetricName [name=response-total, group=consumer-metrics, description=The total number of responses received, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,944] TRACE Removed metric named MetricName [name=response-rate, group=consumer-metrics, description=The number of responses received per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,944] TRACE Removed sensor with name responses-received: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,944] TRACE Removed metric named MetricName [name=select-total, group=consumer-metrics, description=The total number of times the I/O layer checked for new I/O to perform, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,944] TRACE Removed metric named MetricName [name=select-rate, group=consumer-metrics, description=The number of times the I/O layer checked for new I/O to perform per second, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,945] TRACE Removed metric named MetricName [name=io-wait-time-ns-avg, group=consumer-metrics, description=The average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,945] TRACE Removed metric named MetricName [name=io-waittime-total, group=consumer-metrics, description=The total time the I/O thread spent waiting, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,945] TRACE Removed metric named MetricName [name=io-wait-ratio, group=consumer-metrics, description=The fraction of time the I/O thread spent waiting, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,945] TRACE Removed sensor with name select-time: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,945] TRACE Removed metric named MetricName [name=io-time-ns-avg, group=consumer-metrics, description=The average length of time for I/O per select call in nanoseconds., tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,945] TRACE Removed metric named MetricName [name=iotime-total, group=consumer-metrics, description=The total time the I/O thread spent doing I/O, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,945] TRACE Removed metric named MetricName [name=io-ratio, group=consumer-metrics, description=The fraction of time the I/O thread spent doing I/O, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,945] TRACE Removed sensor with name io-time: (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,946] TRACE Removed metric named MetricName [name=request-total, group=consumer-node-metrics, description=The total number of requests sent, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,946] TRACE Removed metric named MetricName [name=request-rate, group=consumer-node-metrics, description=The number of requests sent per second, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,946] TRACE Removed metric named MetricName [name=request-size-avg, group=consumer-node-metrics, description=The average size of requests sent., tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,946] TRACE Removed metric named MetricName [name=request-size-max, group=consumer-node-metrics, description=The maximum size of any request sent., tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,946] TRACE Removed sensor with name node--1.requests-sent (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,946] TRACE Removed metric named MetricName [name=outgoing-byte-total, group=consumer-node-metrics, description=The total number of outgoing bytes, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,947] TRACE Removed metric named MetricName [name=outgoing-byte-rate, group=consumer-node-metrics, description=The number of outgoing bytes per second, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,947] TRACE Removed sensor with name node--1.bytes-sent (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,947] TRACE Removed metric named MetricName [name=response-total, group=consumer-node-metrics, description=The total number of responses received, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,947] TRACE Removed metric named MetricName [name=response-rate, group=consumer-node-metrics, description=The number of responses received per second, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,947] TRACE Removed sensor with name node--1.responses-received (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,948] TRACE Removed metric named MetricName [name=incoming-byte-total, group=consumer-node-metrics, description=The total number of incoming bytes, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,948] TRACE Removed metric named MetricName [name=incoming-byte-rate, group=consumer-node-metrics, description=The number of incoming bytes per second, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,948] TRACE Removed sensor with name node--1.bytes-received (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,949] TRACE Removed metric named MetricName [name=request-latency-avg, group=consumer-node-metrics, description=, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,951] TRACE Removed metric named MetricName [name=request-latency-max, group=consumer-node-metrics, description=, tags={client-id=consumer-test-consumer-group-7-1, node-id=node--1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,951] TRACE Removed sensor with name node--1.latency (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,951] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] sslCiphers: entering performPendingMetricsOperations (org.apache.kafka.common.network.Selector) [2021-10-04 07:09:21,953] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] sslCiphers: leaving performPendingMetricsOperations (org.apache.kafka.common.network.Selector) [2021-10-04 07:09:21,953] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] sslCiphers: closed 0 metric(s). (org.apache.kafka.common.network.Selector) [2021-10-04 07:09:21,953] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] clients: entering performPendingMetricsOperations (org.apache.kafka.common.network.Selector) [2021-10-04 07:09:21,953] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] clients: leaving performPendingMetricsOperations (org.apache.kafka.common.network.Selector) [2021-10-04 07:09:21,953] TRACE [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] clients: closed 0 metric(s). (org.apache.kafka.common.network.Selector) [2021-10-04 07:09:21,954] TRACE Removed metric named MetricName [name=version, group=app-info, description=Metric indicating version, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,954] TRACE Removed metric named MetricName [name=commit-id, group=app-info, description=Metric indicating commit-id, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,956] TRACE Removed metric named MetricName [name=start-time-ms, group=app-info, description=Metric indicating start-time-ms, tags={client-id=consumer-test-consumer-group-7-1}] (org.apache.kafka.common.metrics.Metrics) [2021-10-04 07:09:21,956] INFO App info kafka.consumer for consumer-test-consumer-group-7-1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2021-10-04 07:09:21,956] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Kafka consumer has been closed (org.apache.kafka.clients.consumer.KafkaConsumer) Processed a total of 0 messages [2021-10-04 07:09:21,967] DEBUG [Consumer clientId=consumer-test-consumer-group-7-1, groupId=test-consumer-group-7] Received user wakeup (org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient) [1]+ Done gedit config/consumer.properties rodolk@rodolk-VirtualBox:/usr/local/kafka$