[2020-04-24 15:23:18,246] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [2020-04-24 15:23:18,941] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) [2020-04-24 15:23:18,942] INFO starting (kafka.server.KafkaServer) [2020-04-24 15:23:18,943] INFO Connecting to zookeeper on zookeeper:2181 (kafka.server.KafkaServer) [2020-04-24 15:23:18,995] INFO [ZooKeeperClient Kafka server] Initializing a new session to zookeeper:2181. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 15:23:19,003] INFO Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,003] INFO Client environment:host.name=kafka-a-0.kafka.default.svc.cluster.local (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,003] INFO Client environment:java.version=11.0.5 (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,003] INFO Client environment:java.vendor=AdoptOpenJDK (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,003] INFO Client environment:java.home=/opt/java/openjdk (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,003] INFO Client environment:java.class.path=/opt/kafka/libs/extensions/*:/opt/kafka/bin/../libs/activation-1.1.1.jar:/opt/kafka/bin/../libs/aopalliance-repackaged-2.5.0.jar:/opt/kafka/bin/../libs/argparse4j-0.7.0.jar:/opt/kafka/bin/../libs/audience-annotations-0.5.0.jar:/opt/kafka/bin/../libs/commons-lang3-3.8.1.jar:/opt/kafka/bin/../libs/connect-api-2.3.1.jar:/opt/kafka/bin/../libs/connect-basic-auth-extension-2.3.1.jar:/opt/kafka/bin/../libs/connect-file-2.3.1.jar:/opt/kafka/bin/../libs/connect-json-2.3.1.jar:/opt/kafka/bin/../libs/connect-runtime-2.3.1.jar:/opt/kafka/bin/../libs/connect-transforms-2.3.1.jar:/opt/kafka/bin/../libs/extensions:/opt/kafka/bin/../libs/guava-20.0.jar:/opt/kafka/bin/../libs/hk2-api-2.5.0.jar:/opt/kafka/bin/../libs/hk2-locator-2.5.0.jar:/opt/kafka/bin/../libs/hk2-utils-2.5.0.jar:/opt/kafka/bin/../libs/jackson-annotations-2.10.0.jar:/opt/kafka/bin/../libs/jackson-core-2.10.0.jar:/opt/kafka/bin/../libs/jackson-databind-2.10.0.jar:/opt/kafka/bin/../libs/jackson-dataformat-csv-2.10.0.jar:/opt/kafka/bin/../libs/jackson-datatype-jdk8-2.10.0.jar:/opt/kafka/bin/../libs/jackson-jaxrs-base-2.10.0.jar:/opt/kafka/bin/../libs/jackson-jaxrs-json-provider-2.10.0.jar:/opt/kafka/bin/../libs/jackson-module-jaxb-annotations-2.10.0.jar:/opt/kafka/bin/../libs/jackson-module-paranamer-2.10.0.jar:/opt/kafka/bin/../libs/jackson-module-scala_2.12-2.10.0.jar:/opt/kafka/bin/../libs/jakarta.activation-api-1.2.1.jar:/opt/kafka/bin/../libs/jakarta.annotation-api-1.3.4.jar:/opt/kafka/bin/../libs/jakarta.inject-2.5.0.jar:/opt/kafka/bin/../libs/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/opt/kafka/bin/../libs/javassist-3.22.0-CR2.jar:/opt/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/opt/kafka/bin/../libs/javax.ws.rs-api-2.1.1.jar:/opt/kafka/bin/../libs/jaxb-api-2.3.0.jar:/opt/kafka/bin/../libs/jersey-client-2.28.jar:/opt/kafka/bin/../libs/jersey-common-2.28.jar:/opt/kafka/bin/../libs/jersey-container-servlet-2.28.jar:/opt/kafka/bin/../libs/jersey-container-servlet-core-2.28.jar:/opt/kafka/bin/../libs/jersey-hk2-2.28.jar:/opt/kafka/bin/../libs/jersey-media-jaxb-2.28.jar:/opt/kafka/bin/../libs/jersey-server-2.28.jar:/opt/kafka/bin/../libs/jetty-client-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jetty-continuation-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jetty-http-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jetty-io-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jetty-security-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jetty-server-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jetty-servlet-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jetty-servlets-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jetty-util-9.4.18.v20190429.jar:/opt/kafka/bin/../libs/jopt-simple-5.0.4.jar:/opt/kafka/bin/../libs/jsr305-3.0.2.jar:/opt/kafka/bin/../libs/kafka_2.12-2.3.1.jar:/opt/kafka/bin/../libs/kafka_2.12-2.3.1-sources.jar:/opt/kafka/bin/../libs/kafka-clients-2.3.1.jar:/opt/kafka/bin/../libs/kafka-log4j-appender-2.3.1.jar:/opt/kafka/bin/../libs/kafka-streams-2.3.1.jar:/opt/kafka/bin/../libs/kafka-streams-examples-2.3.1.jar:/opt/kafka/bin/../libs/kafka-streams-scala_2.12-2.3.1.jar:/opt/kafka/bin/../libs/kafka-streams-test-utils-2.3.1.jar:/opt/kafka/bin/../libs/kafka-tools-2.3.1.jar:/opt/kafka/bin/../libs/log4j-1.2.17.jar:/opt/kafka/bin/../libs/lz4-java-1.6.0.jar:/opt/kafka/bin/../libs/maven-artifact-3.6.1.jar:/opt/kafka/bin/../libs/metrics-core-2.2.0.jar:/opt/kafka/bin/../libs/osgi-resource-locator-1.0.1.jar:/opt/kafka/bin/../libs/paranamer-2.8.jar:/opt/kafka/bin/../libs/plexus-utils-3.2.0.jar:/opt/kafka/bin/../libs/reflections-0.9.11.jar:/opt/kafka/bin/../libs/rocksdbjni-5.18.3.jar:/opt/kafka/bin/../libs/scala-library-2.12.10.jar:/opt/kafka/bin/../libs/scala-library-2.12.8.jar:/opt/kafka/bin/../libs/scala-logging_2.12-3.9.0.jar:/opt/kafka/bin/../libs/scala-reflect-2.12.8.jar:/opt/kafka/bin/../libs/slf4j-api-1.7.26.jar:/opt/kafka/bin/../libs/slf4j-log4j12-1.7.26.jar:/opt/kafka/bin/../libs/snappy-java-1.1.7.3.jar:/opt/kafka/bin/../libs/spotbugs-annotations-3.1.9.jar:/opt/kafka/bin/../libs/validation-api-2.0.1.Final.jar:/opt/kafka/bin/../libs/zkclient-0.11.jar:/opt/kafka/bin/../libs/zookeeper-3.4.14.jar:/opt/kafka/bin/../libs/zstd-jni-1.4.0-1.jar (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,003] INFO Client environment:java.library.path=/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,003] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,004] INFO Client environment:java.compiler= (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,004] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,004] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,004] INFO Client environment:os.version=4.15.0 (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,004] INFO Client environment:user.name=root (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,004] INFO Client environment:user.home=/root (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,004] INFO Client environment:user.dir=/opt/kafka (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,005] INFO Initiating client connection, connectString=zookeeper:2181 sessionTimeout=6000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@6e950bcf (org.apache.zookeeper.ZooKeeper) [2020-04-24 15:23:19,039] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 15:23:19,047] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 15:23:19,058] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 15:23:19,070] INFO Session establishment complete on server zookeeper/10.109.226.228:2181, sessionid = 0x100000dc2cd0054, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2020-04-24 15:23:19,074] INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 15:23:19,388] INFO Cluster ID = CR-fk2KUTk-knBM_rwsdXg (kafka.server.KafkaServer) [2020-04-24 15:23:19,452] INFO KafkaConfig values: advertised.host.name = null advertised.listeners = PLAINTEXT://:9092,OUTSIDE://192.168.1.45:32400 advertised.port = null alter.config.policy.class.name = null alter.log.dirs.replication.quota.window.num = 11 alter.log.dirs.replication.quota.window.size.seconds = 1 authorizer.class.name = auto.create.topics.enable = true auto.leader.rebalance.enable = true background.threads = 10 broker.id = 0 broker.id.generation.enable = true broker.rack = null client.quota.callback.class = null compression.type = producer connection.failed.authentication.delay.ms = 100 connections.max.idle.ms = 600000 connections.max.reauth.ms = 0 control.plane.listener.name = null controlled.shutdown.enable = true controlled.shutdown.max.retries = 3 controlled.shutdown.retry.backoff.ms = 5000 controller.socket.timeout.ms = 30000 create.topic.policy.class.name = null default.replication.factor = 1 delegation.token.expiry.check.interval.ms = 3600000 delegation.token.expiry.time.ms = 86400000 delegation.token.master.key = null delegation.token.max.lifetime.ms = 604800000 delete.records.purgatory.purge.interval.requests = 1 delete.topic.enable = true fetch.purgatory.purge.interval.requests = 1000 group.initial.rebalance.delay.ms = 0 group.max.session.timeout.ms = 1800000 group.max.size = 2147483647 group.min.session.timeout.ms = 6000 host.name = inter.broker.listener.name = PLAINTEXT inter.broker.protocol.version = 2.3-IV1 kafka.metrics.polling.interval.secs = 10 kafka.metrics.reporters = [] leader.imbalance.check.interval.seconds = 300 leader.imbalance.per.broker.percentage = 10 listener.security.protocol.map = PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,OUTSIDE:PLAINTEXT listeners = PLAINTEXT://:9092,OUTSIDE://:9094 log.cleaner.backoff.ms = 15000 log.cleaner.dedupe.buffer.size = 134217728 log.cleaner.delete.retention.ms = 86400000 log.cleaner.enable = true log.cleaner.io.buffer.load.factor = 0.9 log.cleaner.io.buffer.size = 524288 log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308 log.cleaner.max.compaction.lag.ms = 9223372036854775807 log.cleaner.min.cleanable.ratio = 0.5 log.cleaner.min.compaction.lag.ms = 0 log.cleaner.threads = 1 log.cleanup.policy = [delete] log.dir = /tmp/kafka-logs log.dirs = /var/lib/kafka/data/topics log.flush.interval.messages = 9223372036854775807 log.flush.interval.ms = null log.flush.offset.checkpoint.interval.ms = 60000 log.flush.scheduler.interval.ms = 9223372036854775807 log.flush.start.offset.checkpoint.interval.ms = 60000 log.index.interval.bytes = 4096 log.index.size.max.bytes = 10485760 log.message.downconversion.enable = true log.message.format.version = 2.3-IV1 log.message.timestamp.difference.max.ms = 9223372036854775807 log.message.timestamp.type = CreateTime log.preallocate = false log.retention.bytes = 104857600 log.retention.check.interval.ms = 300000 log.retention.hours = 168 log.retention.minutes = null log.retention.ms = null log.roll.hours = 168 log.roll.jitter.hours = 0 log.roll.jitter.ms = null log.roll.ms = null log.segment.bytes = 1073741824 log.segment.delete.delay.ms = 60000 max.connections = 2147483647 max.connections.per.ip = 2147483647 max.connections.per.ip.overrides = max.incremental.fetch.session.cache.slots = 1000 message.max.bytes = 1000012 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 min.insync.replicas = 1 num.io.threads = 8 num.network.threads = 3 num.partitions = 1 num.recovery.threads.per.data.dir = 1 num.replica.alter.log.dirs.threads = null num.replica.fetchers = 1 offset.metadata.max.bytes = 4096 offsets.commit.required.acks = -1 offsets.commit.timeout.ms = 5000 offsets.load.buffer.size = 5242880 offsets.retention.check.interval.ms = 600000 offsets.retention.minutes = 10080 offsets.topic.compression.codec = 0 offsets.topic.num.partitions = 50 offsets.topic.replication.factor = 1 offsets.topic.segment.bytes = 104857600 password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding password.encoder.iterations = 4096 password.encoder.key.length = 128 password.encoder.keyfactory.algorithm = null password.encoder.old.secret = null password.encoder.secret = null port = 9092 principal.builder.class = null producer.purgatory.purge.interval.requests = 1000 queued.max.request.bytes = -1 queued.max.requests = 500 quota.consumer.default = 9223372036854775807 quota.producer.default = 9223372036854775807 quota.window.num = 11 quota.window.size.seconds = 1 replica.fetch.backoff.ms = 1000 replica.fetch.max.bytes = 1048576 replica.fetch.min.bytes = 1 replica.fetch.response.max.bytes = 10485760 replica.fetch.wait.max.ms = 500 replica.high.watermark.checkpoint.interval.ms = 5000 replica.lag.time.max.ms = 10000 replica.socket.receive.buffer.bytes = 65536 replica.socket.timeout.ms = 30000 replication.quota.window.num = 11 replication.quota.window.size.seconds = 1 request.timeout.ms = 30000 reserved.broker.max.id = 1000 sasl.client.callback.handler.class = null sasl.enabled.mechanisms = [GSSAPI] sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.principal.to.local.rules = [DEFAULT] 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.inter.broker.protocol = GSSAPI sasl.server.callback.handler.class = null security.inter.broker.protocol = PLAINTEXT socket.receive.buffer.bytes = 102400 socket.request.max.bytes = 104857600 socket.send.buffer.bytes = 102400 ssl.cipher.suites = [] ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.principal.mapping.rules = [DEFAULT] ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.abort.timed.out.transaction.cleanup.interval.ms = 60000 transaction.max.timeout.ms = 900000 transaction.remove.expired.transaction.cleanup.interval.ms = 3600000 transaction.state.log.load.buffer.size = 5242880 transaction.state.log.min.isr = 1 transaction.state.log.num.partitions = 50 transaction.state.log.replication.factor = 1 transaction.state.log.segment.bytes = 104857600 transactional.id.expiration.ms = 604800000 unclean.leader.election.enable = false zookeeper.connect = zookeeper:2181 zookeeper.connection.timeout.ms = null zookeeper.max.in.flight.requests = 10 zookeeper.session.timeout.ms = 6000 zookeeper.set.acl = false zookeeper.sync.time.ms = 2000 (kafka.server.KafkaConfig) [2020-04-24 15:23:19,465] INFO KafkaConfig values: advertised.host.name = null advertised.listeners = PLAINTEXT://:9092,OUTSIDE://192.168.1.45:32400 advertised.port = null alter.config.policy.class.name = null alter.log.dirs.replication.quota.window.num = 11 alter.log.dirs.replication.quota.window.size.seconds = 1 authorizer.class.name = auto.create.topics.enable = true auto.leader.rebalance.enable = true background.threads = 10 broker.id = 0 broker.id.generation.enable = true broker.rack = null client.quota.callback.class = null compression.type = producer connection.failed.authentication.delay.ms = 100 connections.max.idle.ms = 600000 connections.max.reauth.ms = 0 control.plane.listener.name = null controlled.shutdown.enable = true controlled.shutdown.max.retries = 3 controlled.shutdown.retry.backoff.ms = 5000 controller.socket.timeout.ms = 30000 create.topic.policy.class.name = null default.replication.factor = 1 delegation.token.expiry.check.interval.ms = 3600000 delegation.token.expiry.time.ms = 86400000 delegation.token.master.key = null delegation.token.max.lifetime.ms = 604800000 delete.records.purgatory.purge.interval.requests = 1 delete.topic.enable = true fetch.purgatory.purge.interval.requests = 1000 group.initial.rebalance.delay.ms = 0 group.max.session.timeout.ms = 1800000 group.max.size = 2147483647 group.min.session.timeout.ms = 6000 host.name = inter.broker.listener.name = PLAINTEXT inter.broker.protocol.version = 2.3-IV1 kafka.metrics.polling.interval.secs = 10 kafka.metrics.reporters = [] leader.imbalance.check.interval.seconds = 300 leader.imbalance.per.broker.percentage = 10 listener.security.protocol.map = PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,OUTSIDE:PLAINTEXT listeners = PLAINTEXT://:9092,OUTSIDE://:9094 log.cleaner.backoff.ms = 15000 log.cleaner.dedupe.buffer.size = 134217728 log.cleaner.delete.retention.ms = 86400000 log.cleaner.enable = true log.cleaner.io.buffer.load.factor = 0.9 log.cleaner.io.buffer.size = 524288 log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308 log.cleaner.max.compaction.lag.ms = 9223372036854775807 log.cleaner.min.cleanable.ratio = 0.5 log.cleaner.min.compaction.lag.ms = 0 log.cleaner.threads = 1 log.cleanup.policy = [delete] log.dir = /tmp/kafka-logs log.dirs = /var/lib/kafka/data/topics log.flush.interval.messages = 9223372036854775807 log.flush.interval.ms = null log.flush.offset.checkpoint.interval.ms = 60000 log.flush.scheduler.interval.ms = 9223372036854775807 log.flush.start.offset.checkpoint.interval.ms = 60000 log.index.interval.bytes = 4096 log.index.size.max.bytes = 10485760 log.message.downconversion.enable = true log.message.format.version = 2.3-IV1 log.message.timestamp.difference.max.ms = 9223372036854775807 log.message.timestamp.type = CreateTime log.preallocate = false log.retention.bytes = 104857600 log.retention.check.interval.ms = 300000 log.retention.hours = 168 log.retention.minutes = null log.retention.ms = null log.roll.hours = 168 log.roll.jitter.hours = 0 log.roll.jitter.ms = null log.roll.ms = null log.segment.bytes = 1073741824 log.segment.delete.delay.ms = 60000 max.connections = 2147483647 max.connections.per.ip = 2147483647 max.connections.per.ip.overrides = max.incremental.fetch.session.cache.slots = 1000 message.max.bytes = 1000012 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 min.insync.replicas = 1 num.io.threads = 8 num.network.threads = 3 num.partitions = 1 num.recovery.threads.per.data.dir = 1 num.replica.alter.log.dirs.threads = null num.replica.fetchers = 1 offset.metadata.max.bytes = 4096 offsets.commit.required.acks = -1 offsets.commit.timeout.ms = 5000 offsets.load.buffer.size = 5242880 offsets.retention.check.interval.ms = 600000 offsets.retention.minutes = 10080 offsets.topic.compression.codec = 0 offsets.topic.num.partitions = 50 offsets.topic.replication.factor = 1 offsets.topic.segment.bytes = 104857600 password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding password.encoder.iterations = 4096 password.encoder.key.length = 128 password.encoder.keyfactory.algorithm = null password.encoder.old.secret = null password.encoder.secret = null port = 9092 principal.builder.class = null producer.purgatory.purge.interval.requests = 1000 queued.max.request.bytes = -1 queued.max.requests = 500 quota.consumer.default = 9223372036854775807 quota.producer.default = 9223372036854775807 quota.window.num = 11 quota.window.size.seconds = 1 replica.fetch.backoff.ms = 1000 replica.fetch.max.bytes = 1048576 replica.fetch.min.bytes = 1 replica.fetch.response.max.bytes = 10485760 replica.fetch.wait.max.ms = 500 replica.high.watermark.checkpoint.interval.ms = 5000 replica.lag.time.max.ms = 10000 replica.socket.receive.buffer.bytes = 65536 replica.socket.timeout.ms = 30000 replication.quota.window.num = 11 replication.quota.window.size.seconds = 1 request.timeout.ms = 30000 reserved.broker.max.id = 1000 sasl.client.callback.handler.class = null sasl.enabled.mechanisms = [GSSAPI] sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.principal.to.local.rules = [DEFAULT] 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.inter.broker.protocol = GSSAPI sasl.server.callback.handler.class = null security.inter.broker.protocol = PLAINTEXT socket.receive.buffer.bytes = 102400 socket.request.max.bytes = 104857600 socket.send.buffer.bytes = 102400 ssl.cipher.suites = [] ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.principal.mapping.rules = [DEFAULT] ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.abort.timed.out.transaction.cleanup.interval.ms = 60000 transaction.max.timeout.ms = 900000 transaction.remove.expired.transaction.cleanup.interval.ms = 3600000 transaction.state.log.load.buffer.size = 5242880 transaction.state.log.min.isr = 1 transaction.state.log.num.partitions = 50 transaction.state.log.replication.factor = 1 transaction.state.log.segment.bytes = 104857600 transactional.id.expiration.ms = 604800000 unclean.leader.election.enable = false zookeeper.connect = zookeeper:2181 zookeeper.connection.timeout.ms = null zookeeper.max.in.flight.requests = 10 zookeeper.session.timeout.ms = 6000 zookeeper.set.acl = false zookeeper.sync.time.ms = 2000 (kafka.server.KafkaConfig) [2020-04-24 15:23:19,496] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2020-04-24 15:23:19,496] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2020-04-24 15:23:19,498] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2020-04-24 15:23:19,557] INFO Loading logs. (kafka.log.LogManager) [2020-04-24 15:23:19,671] INFO [Log partition=__consumer_offsets-19, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,681] INFO [Log partition=__consumer_offsets-19, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 82 ms (kafka.log.Log) [2020-04-24 15:23:19,704] INFO [Log partition=increasing-topic-3-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 515004 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,712] INFO [Log partition=increasing-topic-3-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 515004 and log end offset 515004 in 18 ms (kafka.log.Log) [2020-04-24 15:23:19,724] INFO [Log partition=__consumer_offsets-16, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,724] INFO [Log partition=__consumer_offsets-16, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:19,736] INFO [Log partition=__consumer_offsets-32, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,736] INFO [Log partition=__consumer_offsets-32, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:19,748] INFO [Log partition=__consumer_offsets-38, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,749] INFO [Log partition=__consumer_offsets-38, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:19,761] INFO [Log partition=__consumer_offsets-28, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,761] INFO [Log partition=__consumer_offsets-28, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:19,772] INFO [Log partition=__consumer_offsets-41, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,772] INFO [Log partition=__consumer_offsets-41, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 8 ms (kafka.log.Log) [2020-04-24 15:23:19,785] INFO [Log partition=__consumer_offsets-37, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,786] INFO [Log partition=__consumer_offsets-37, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 10 ms (kafka.log.Log) [2020-04-24 15:23:19,802] INFO [Log partition=increasing-topic-7-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 321455 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,803] INFO [ProducerStateManager partition=increasing-topic-7-0] Writing producer snapshot at offset 321455 (kafka.log.ProducerStateManager) [2020-04-24 15:23:19,813] INFO [Log partition=increasing-topic-7-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 321455 and log end offset 321455 in 21 ms (kafka.log.Log) [2020-04-24 15:23:19,828] INFO [Log partition=__consumer_offsets-11, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,828] INFO [Log partition=__consumer_offsets-11, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 10 ms (kafka.log.Log) [2020-04-24 15:23:19,843] INFO [Log partition=item-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 4 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,844] INFO [Log partition=item-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 4 and log end offset 4 in 12 ms (kafka.log.Log) [2020-04-24 15:23:19,861] INFO [Log partition=__consumer_offsets-8, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,861] INFO [Log partition=__consumer_offsets-8, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 14 ms (kafka.log.Log) [2020-04-24 15:23:19,872] INFO [Log partition=__consumer_offsets-39, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,872] INFO [Log partition=__consumer_offsets-39, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 8 ms (kafka.log.Log) [2020-04-24 15:23:19,883] INFO [Log partition=__consumer_offsets-31, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,884] INFO [Log partition=__consumer_offsets-31, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:19,895] INFO [Log partition=__consumer_offsets-25, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,895] INFO [Log partition=__consumer_offsets-25, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:19,906] INFO [Log partition=__consumer_offsets-43, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,907] INFO [Log partition=__consumer_offsets-43, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 10 ms (kafka.log.Log) [2020-04-24 15:23:19,922] INFO [Log partition=__consumer_offsets-6, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,922] INFO [Log partition=__consumer_offsets-6, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 13 ms (kafka.log.Log) [2020-04-24 15:23:19,939] INFO [Log partition=increasing-topic-4-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 500000 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,940] INFO [Log partition=increasing-topic-4-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 500000 and log end offset 500000 in 15 ms (kafka.log.Log) [2020-04-24 15:23:19,953] INFO [Log partition=increasing-topic-5-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 501872 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,954] INFO [Log partition=increasing-topic-5-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 501872 and log end offset 501872 in 12 ms (kafka.log.Log) [2020-04-24 15:23:19,969] INFO [Log partition=__consumer_offsets-21, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,970] INFO [Log partition=__consumer_offsets-21, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 14 ms (kafka.log.Log) [2020-04-24 15:23:19,982] INFO [Log partition=__consumer_offsets-7, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,982] INFO [Log partition=__consumer_offsets-7, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:19,994] INFO [Log partition=__consumer_offsets-20, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:19,994] INFO [Log partition=__consumer_offsets-20, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,007] INFO [Log partition=__consumer_offsets-18, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,008] INFO [Log partition=__consumer_offsets-18, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 11 ms (kafka.log.Log) [2020-04-24 15:23:20,019] INFO [Log partition=__consumer_offsets-40, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,019] INFO [Log partition=__consumer_offsets-40, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,030] INFO [Log partition=app-changes-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,031] INFO [Log partition=app-changes-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 10 ms (kafka.log.Log) [2020-04-24 15:23:20,047] INFO [Log partition=__consumer_offsets-17, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,047] INFO [Log partition=__consumer_offsets-17, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 14 ms (kafka.log.Log) [2020-04-24 15:23:20,071] INFO [Log partition=__consumer_offsets-44, dir=/var/lib/kafka/data/topics] Loading producer state till offset 88 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,073] INFO [ProducerStateManager partition=__consumer_offsets-44] Loading producer state from snapshot file '/var/lib/kafka/data/topics/__consumer_offsets-44/00000000000000000088.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,085] INFO [Log partition=__consumer_offsets-44, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 88 in 36 ms (kafka.log.Log) [2020-04-24 15:23:20,095] INFO [Log partition=__consumer_offsets-42, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,096] INFO [Log partition=__consumer_offsets-42, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,107] INFO [Log partition=__consumer_offsets-9, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,107] INFO [Log partition=__consumer_offsets-9, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,118] INFO [Log partition=__consumer_offsets-45, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,118] INFO [Log partition=__consumer_offsets-45, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,133] INFO [Log partition=__consumer_offsets-13, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,134] INFO [Log partition=__consumer_offsets-13, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 14 ms (kafka.log.Log) [2020-04-24 15:23:20,146] INFO [Log partition=__consumer_offsets-24, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,146] INFO [Log partition=__consumer_offsets-24, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 10 ms (kafka.log.Log) [2020-04-24 15:23:20,162] INFO [Log partition=__consumer_offsets-27, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,162] INFO [Log partition=__consumer_offsets-27, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 12 ms (kafka.log.Log) [2020-04-24 15:23:20,173] INFO [Log partition=__consumer_offsets-35, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,173] INFO [Log partition=__consumer_offsets-35, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,183] INFO [Log partition=vault-secret-changes-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 2 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,184] INFO [Log partition=vault-secret-changes-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 2 and log end offset 2 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,195] INFO [Log partition=increasing-topic-2-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,195] INFO [Log partition=increasing-topic-2-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,206] INFO [Log partition=__consumer_offsets-33, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,206] INFO [Log partition=__consumer_offsets-33, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,230] INFO [Log partition=__consumer_offsets-48, dir=/var/lib/kafka/data/topics] Loading producer state till offset 502 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,231] INFO [ProducerStateManager partition=__consumer_offsets-48] Loading producer state from snapshot file '/var/lib/kafka/data/topics/__consumer_offsets-48/00000000000000000502.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,232] INFO [Log partition=__consumer_offsets-48, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 502 in 25 ms (kafka.log.Log) [2020-04-24 15:23:20,242] INFO [Log partition=__consumer_offsets-4, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,243] INFO [Log partition=__consumer_offsets-4, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,254] INFO [Log partition=increasing-topic-1-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 79955 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,255] INFO [Log partition=increasing-topic-1-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 79955 and log end offset 79955 in 11 ms (kafka.log.Log) [2020-04-24 15:23:20,265] INFO [Log partition=__consumer_offsets-12, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,265] INFO [Log partition=__consumer_offsets-12, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,277] INFO [Log partition=__consumer_offsets-10, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,278] INFO [Log partition=__consumer_offsets-10, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 10 ms (kafka.log.Log) [2020-04-24 15:23:20,288] INFO [Log partition=host-changes-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,288] INFO [Log partition=host-changes-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,298] INFO [Log partition=feature-flag-changes-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,299] INFO [Log partition=feature-flag-changes-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,310] INFO [Log partition=__consumer_offsets-29, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,310] INFO [Log partition=__consumer_offsets-29, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 10 ms (kafka.log.Log) [2020-04-24 15:23:20,321] INFO [Log partition=__consumer_offsets-2, dir=/var/lib/kafka/data/topics] Loading producer state till offset 282 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,322] INFO [ProducerStateManager partition=__consumer_offsets-2] Loading producer state from snapshot file '/var/lib/kafka/data/topics/__consumer_offsets-2/00000000000000000282.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,323] INFO [Log partition=__consumer_offsets-2, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 282 in 12 ms (kafka.log.Log) [2020-04-24 15:23:20,331] INFO [Log partition=__consumer_offsets-30, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,331] INFO [Log partition=__consumer_offsets-30, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 7 ms (kafka.log.Log) [2020-04-24 15:23:20,346] INFO [Log partition=__consumer_offsets-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 326 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,347] INFO [ProducerStateManager partition=__consumer_offsets-0] Loading producer state from snapshot file '/var/lib/kafka/data/topics/__consumer_offsets-0/00000000000000000326.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,348] INFO [Log partition=__consumer_offsets-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 326 in 15 ms (kafka.log.Log) [2020-04-24 15:23:20,356] INFO [Log partition=__consumer_offsets-34, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,357] INFO [Log partition=__consumer_offsets-34, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 8 ms (kafka.log.Log) [2020-04-24 15:23:20,365] INFO [Log partition=__consumer_offsets-14, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,365] INFO [Log partition=__consumer_offsets-14, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 7 ms (kafka.log.Log) [2020-04-24 15:23:20,375] INFO [Log partition=view-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,375] INFO [Log partition=view-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,385] INFO [Log partition=increasing-topic-9-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 278054 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,386] INFO [ProducerStateManager partition=increasing-topic-9-0] Loading producer state from snapshot file '/var/lib/kafka/data/topics/increasing-topic-9-0/00000000000000278054.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,387] INFO [Log partition=increasing-topic-9-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 278054 in 11 ms (kafka.log.Log) [2020-04-24 15:23:20,404] INFO [Log partition=__consumer_offsets-46, dir=/var/lib/kafka/data/topics] Loading producer state till offset 506 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,405] INFO [ProducerStateManager partition=__consumer_offsets-46] Loading producer state from snapshot file '/var/lib/kafka/data/topics/__consumer_offsets-46/00000000000000000506.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,407] INFO [Log partition=__consumer_offsets-46, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 506 in 18 ms (kafka.log.Log) [2020-04-24 15:23:20,425] INFO [Log partition=__consumer_offsets-49, dir=/var/lib/kafka/data/topics] Loading producer state till offset 526 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,426] INFO [ProducerStateManager partition=__consumer_offsets-49] Loading producer state from snapshot file '/var/lib/kafka/data/topics/__consumer_offsets-49/00000000000000000526.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,426] INFO [Log partition=__consumer_offsets-49, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 526 in 18 ms (kafka.log.Log) [2020-04-24 15:23:20,437] INFO [Log partition=increasing-topic-8-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 507903 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,437] INFO [ProducerStateManager partition=increasing-topic-8-0] Loading producer state from snapshot file '/var/lib/kafka/data/topics/increasing-topic-8-0/00000000000000507903.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,438] INFO [Log partition=increasing-topic-8-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 507903 in 10 ms (kafka.log.Log) [2020-04-24 15:23:20,445] INFO [Log partition=increasing-topic-6-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 500000 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,446] INFO [Log partition=increasing-topic-6-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 500000 and log end offset 500000 in 7 ms (kafka.log.Log) [2020-04-24 15:23:20,452] INFO [Log partition=__consumer_offsets-5, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,452] INFO [Log partition=__consumer_offsets-5, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2020-04-24 15:23:20,458] INFO [Log partition=__consumer_offsets-3, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,458] INFO [Log partition=__consumer_offsets-3, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2020-04-24 15:23:20,465] INFO [Log partition=__consumer_offsets-23, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,465] INFO [Log partition=__consumer_offsets-23, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2020-04-24 15:23:20,483] INFO [Log partition=__consumer_offsets-22, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,484] INFO [Log partition=__consumer_offsets-22, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 18 ms (kafka.log.Log) [2020-04-24 15:23:20,518] INFO [Log partition=__consumer_offsets-47, dir=/var/lib/kafka/data/topics] Loading producer state till offset 499 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,519] INFO [ProducerStateManager partition=__consumer_offsets-47] Loading producer state from snapshot file '/var/lib/kafka/data/topics/__consumer_offsets-47/00000000000000000499.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,520] INFO [Log partition=__consumer_offsets-47, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 499 in 14 ms (kafka.log.Log) [2020-04-24 15:23:20,528] INFO [Log partition=increasing-topic-0-0, dir=/var/lib/kafka/data/topics] Loading producer state till offset 500000 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,529] INFO [ProducerStateManager partition=increasing-topic-0-0] Loading producer state from snapshot file '/var/lib/kafka/data/topics/increasing-topic-0-0/00000000000000500000.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,529] INFO [Log partition=increasing-topic-0-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 500000 in 8 ms (kafka.log.Log) [2020-04-24 15:23:20,539] INFO [Log partition=__consumer_offsets-36, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,539] INFO [Log partition=__consumer_offsets-36, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 8 ms (kafka.log.Log) [2020-04-24 15:23:20,550] INFO [Log partition=__consumer_offsets-1, dir=/var/lib/kafka/data/topics] Loading producer state till offset 509 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,551] INFO [ProducerStateManager partition=__consumer_offsets-1] Loading producer state from snapshot file '/var/lib/kafka/data/topics/__consumer_offsets-1/00000000000000000509.snapshot' (kafka.log.ProducerStateManager) [2020-04-24 15:23:20,552] INFO [Log partition=__consumer_offsets-1, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 509 in 12 ms (kafka.log.Log) [2020-04-24 15:23:20,562] INFO [Log partition=__consumer_offsets-26, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,562] INFO [Log partition=__consumer_offsets-26, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,572] INFO [Log partition=__consumer_offsets-15, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-24 15:23:20,572] INFO [Log partition=__consumer_offsets-15, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 9 ms (kafka.log.Log) [2020-04-24 15:23:20,575] INFO Logs loading complete in 1018 ms. (kafka.log.LogManager) [2020-04-24 15:23:20,585] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) [2020-04-24 15:23:20,586] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) [2020-04-24 15:23:20,945] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor) [2020-04-24 15:23:20,982] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer) [2020-04-24 15:23:20,982] INFO Awaiting socket connections on 0.0.0.0:9094. (kafka.network.Acceptor) [2020-04-24 15:23:20,993] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9094,ListenerName(OUTSIDE),PLAINTEXT) (kafka.network.SocketServer) [2020-04-24 15:23:20,994] INFO [SocketServer brokerId=0] Started 2 acceptor threads for data-plane (kafka.network.SocketServer) [2020-04-24 15:23:21,027] INFO [ExpirationReaper-0-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-24 15:23:21,028] INFO [ExpirationReaper-0-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-24 15:23:21,033] INFO [ExpirationReaper-0-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-24 15:23:21,034] INFO [ExpirationReaper-0-ElectPreferredLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-24 15:23:21,046] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler) [2020-04-24 15:23:21,095] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.zk.KafkaZkClient) [2020-04-24 15:23:21,121] INFO Stat of the created znode at /brokers/ids/0 is: 1750,1750,1587741801106,1587741801106,1,0,0,72057653140717652,307,0,1750 (kafka.zk.KafkaZkClient) [2020-04-24 15:23:21,121] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(kafka-a-0.kafka.default.svc.cluster.local,9092,ListenerName(PLAINTEXT),PLAINTEXT), EndPoint(192.168.1.45,32400,ListenerName(OUTSIDE),PLAINTEXT)), czxid (broker epoch): 1750 (kafka.zk.KafkaZkClient) [2020-04-24 15:23:21,202] INFO [ExpirationReaper-0-topic]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-24 15:23:21,213] INFO [ExpirationReaper-0-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-24 15:23:21,215] INFO [ExpirationReaper-0-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-24 15:23:21,246] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:21,247] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:21,264] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 15 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:21,266] INFO [ProducerId Manager 0]: Acquired new producerId block (brokerId:0,blockStartProducerId:76000,blockEndProducerId:76999) by writing to Zk with path version 77 (kafka.coordinator.transaction.ProducerIdManager) [2020-04-24 15:23:21,300] INFO [TransactionCoordinator id=0] Starting up. (kafka.coordinator.transaction.TransactionCoordinator) [2020-04-24 15:23:21,313] INFO [Transaction Marker Channel Manager 0]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2020-04-24 15:23:21,313] INFO [TransactionCoordinator id=0] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) [2020-04-24 15:23:21,356] INFO [/config/changes-event-process-thread]: Starting (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2020-04-24 15:23:21,423] INFO [SocketServer brokerId=0] Started data-plane processors for 2 acceptors (kafka.network.SocketServer) [2020-04-24 15:23:21,443] INFO Kafka version: 2.3.1 (org.apache.kafka.common.utils.AppInfoParser) [2020-04-24 15:23:21,444] INFO Kafka commitId: 18a913733fb71c01 (org.apache.kafka.common.utils.AppInfoParser) [2020-04-24 15:23:21,444] INFO Kafka startTimeMs: 1587741801424 (org.apache.kafka.common.utils.AppInfoParser) [2020-04-24 15:23:21,465] INFO [KafkaServer id=0] started (kafka.server.KafkaServer) [2020-04-24 15:23:21,604] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(__consumer_offsets-22, __consumer_offsets-30, __consumer_offsets-8, __consumer_offsets-21, increasing-topic-9-0, __consumer_offsets-4, __consumer_offsets-27, __consumer_offsets-7, __consumer_offsets-9, vault-secret-changes-0, increasing-topic-5-0, __consumer_offsets-46, __consumer_offsets-25, __consumer_offsets-35, increasing-topic-0-0, __consumer_offsets-41, __consumer_offsets-33, __consumer_offsets-23, __consumer_offsets-49, __consumer_offsets-47, __consumer_offsets-16, increasing-topic-8-0, __consumer_offsets-28, __consumer_offsets-31, __consumer_offsets-36, __consumer_offsets-42, increasing-topic-4-0, __consumer_offsets-3, __consumer_offsets-18, __consumer_offsets-37, __consumer_offsets-15, __consumer_offsets-24, increasing-topic-1-0, __consumer_offsets-38, __consumer_offsets-17, feature-flag-changes-0, __consumer_offsets-48, __consumer_offsets-19, __consumer_offsets-11, host-changes-0, increasing-topic-7-0, __consumer_offsets-13, app-changes-0, __consumer_offsets-2, __consumer_offsets-43, __consumer_offsets-6, __consumer_offsets-14, view-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0, __consumer_offsets-20, __consumer_offsets-0, __consumer_offsets-44, __consumer_offsets-39, __consumer_offsets-12, increasing-topic-3-0, __consumer_offsets-45, __consumer_offsets-1, __consumer_offsets-5, __consumer_offsets-26, item-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0, increasing-topic-2-0, __consumer_offsets-29, __consumer_offsets-34, __consumer_offsets-10, __consumer_offsets-32, __consumer_offsets-40, increasing-topic-6-0) (kafka.server.ReplicaFetcherManager) [2020-04-24 15:23:21,615] INFO Replica loaded for partition __consumer_offsets-0 with initial high watermark 326 (kafka.cluster.Replica) [2020-04-24 15:23:21,618] INFO [Partition __consumer_offsets-0 broker=0] __consumer_offsets-0 starts at Leader Epoch 0 from offset 326. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,633] INFO Replica loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,633] INFO [Partition __consumer_offsets-29 broker=0] __consumer_offsets-29 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,652] INFO Replica loaded for partition __consumer_offsets-48 with initial high watermark 502 (kafka.cluster.Replica) [2020-04-24 15:23:21,652] INFO [Partition __consumer_offsets-48 broker=0] __consumer_offsets-48 starts at Leader Epoch 0 from offset 502. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,659] INFO Replica loaded for partition vault-secret-changes-0 with initial high watermark 2 (kafka.cluster.Replica) [2020-04-24 15:23:21,659] INFO [Partition vault-secret-changes-0 broker=0] vault-secret-changes-0 starts at Leader Epoch 0 from offset 2. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,680] INFO Replica loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,681] INFO [Partition __consumer_offsets-10 broker=0] __consumer_offsets-10 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,694] INFO Replica loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,694] INFO [Partition __consumer_offsets-45 broker=0] __consumer_offsets-45 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,711] INFO Replica loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,711] INFO [Partition __consumer_offsets-26 broker=0] __consumer_offsets-26 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,723] INFO Replica loaded for partition item-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0 with initial high watermark 4 (kafka.cluster.Replica) [2020-04-24 15:23:21,723] INFO [Partition item-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0 broker=0] item-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0 starts at Leader Epoch 0 from offset 4. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,738] INFO Replica loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,738] INFO [Partition __consumer_offsets-7 broker=0] __consumer_offsets-7 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,756] INFO Replica loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,756] INFO [Partition __consumer_offsets-42 broker=0] __consumer_offsets-42 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,767] INFO Replica loaded for partition increasing-topic-8-0 with initial high watermark 507903 (kafka.cluster.Replica) [2020-04-24 15:23:21,767] INFO [Partition increasing-topic-8-0 broker=0] increasing-topic-8-0 starts at Leader Epoch 0 from offset 507903. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,770] INFO Replica loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,770] INFO [Partition __consumer_offsets-4 broker=0] __consumer_offsets-4 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,780] INFO Replica loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,780] INFO [Partition __consumer_offsets-23 broker=0] __consumer_offsets-23 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,790] INFO Replica loaded for partition __consumer_offsets-1 with initial high watermark 509 (kafka.cluster.Replica) [2020-04-24 15:23:21,790] INFO [Partition __consumer_offsets-1 broker=0] __consumer_offsets-1 starts at Leader Epoch 0 from offset 509. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,792] INFO Replica loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,792] INFO [Partition __consumer_offsets-20 broker=0] __consumer_offsets-20 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,806] INFO Replica loaded for partition increasing-topic-2-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,806] INFO [Partition increasing-topic-2-0 broker=0] increasing-topic-2-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,816] INFO Replica loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,816] INFO [Partition __consumer_offsets-39 broker=0] __consumer_offsets-39 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,825] INFO Replica loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,826] INFO [Partition __consumer_offsets-17 broker=0] __consumer_offsets-17 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,835] INFO Replica loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,835] INFO [Partition __consumer_offsets-36 broker=0] __consumer_offsets-36 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,846] INFO Replica loaded for partition increasing-topic-5-0 with initial high watermark 501872 (kafka.cluster.Replica) [2020-04-24 15:23:21,847] INFO [Partition increasing-topic-5-0 broker=0] increasing-topic-5-0 starts at Leader Epoch 0 from offset 501872. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,863] INFO Replica loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,864] INFO [Partition __consumer_offsets-14 broker=0] __consumer_offsets-14 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,876] INFO Replica loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,876] INFO [Partition __consumer_offsets-33 broker=0] __consumer_offsets-33 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,889] INFO Replica loaded for partition __consumer_offsets-49 with initial high watermark 526 (kafka.cluster.Replica) [2020-04-24 15:23:21,890] INFO [Partition __consumer_offsets-49 broker=0] __consumer_offsets-49 starts at Leader Epoch 0 from offset 526. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,892] INFO Replica loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,893] INFO [Partition __consumer_offsets-11 broker=0] __consumer_offsets-11 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,904] INFO Replica loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,904] INFO [Partition __consumer_offsets-30 broker=0] __consumer_offsets-30 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,916] INFO Replica loaded for partition __consumer_offsets-46 with initial high watermark 506 (kafka.cluster.Replica) [2020-04-24 15:23:21,916] INFO [Partition __consumer_offsets-46 broker=0] __consumer_offsets-46 starts at Leader Epoch 0 from offset 506. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,919] INFO Replica loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,920] INFO [Partition __consumer_offsets-27 broker=0] __consumer_offsets-27 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,931] INFO Replica loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,932] INFO [Partition __consumer_offsets-8 broker=0] __consumer_offsets-8 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,942] INFO Replica loaded for partition increasing-topic-7-0 with initial high watermark 321455 (kafka.cluster.Replica) [2020-04-24 15:23:21,942] INFO [Partition increasing-topic-7-0 broker=0] increasing-topic-7-0 starts at Leader Epoch 0 from offset 321455. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,954] INFO Replica loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,954] INFO [Partition __consumer_offsets-24 broker=0] __consumer_offsets-24 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,964] INFO Replica loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,965] INFO [Partition __consumer_offsets-43 broker=0] __consumer_offsets-43 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,975] INFO Replica loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,976] INFO [Partition __consumer_offsets-5 broker=0] __consumer_offsets-5 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,986] INFO Replica loaded for partition host-changes-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:21,986] INFO [Partition host-changes-0 broker=0] host-changes-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:21,996] INFO Replica loaded for partition increasing-topic-1-0 with initial high watermark 79955 (kafka.cluster.Replica) [2020-04-24 15:23:21,997] INFO [Partition increasing-topic-1-0 broker=0] increasing-topic-1-0 starts at Leader Epoch 0 from offset 79955. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,006] INFO Replica loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,006] INFO [Partition __consumer_offsets-21 broker=0] __consumer_offsets-21 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,016] INFO Replica loaded for partition __consumer_offsets-2 with initial high watermark 282 (kafka.cluster.Replica) [2020-04-24 15:23:22,016] INFO [Partition __consumer_offsets-2 broker=0] __consumer_offsets-2 starts at Leader Epoch 0 from offset 282. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,018] INFO Replica loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,018] INFO [Partition __consumer_offsets-40 broker=0] __consumer_offsets-40 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,031] INFO Replica loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,031] INFO [Partition __consumer_offsets-37 broker=0] __consumer_offsets-37 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,042] INFO Replica loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,042] INFO [Partition __consumer_offsets-18 broker=0] __consumer_offsets-18 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,054] INFO Replica loaded for partition increasing-topic-4-0 with initial high watermark 500000 (kafka.cluster.Replica) [2020-04-24 15:23:22,054] INFO [Partition increasing-topic-4-0 broker=0] increasing-topic-4-0 starts at Leader Epoch 0 from offset 500000. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,064] INFO Replica loaded for partition app-changes-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,064] INFO [Partition app-changes-0 broker=0] app-changes-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,075] INFO Replica loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,075] INFO [Partition __consumer_offsets-34 broker=0] __consumer_offsets-34 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,085] INFO Replica loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,085] INFO [Partition __consumer_offsets-15 broker=0] __consumer_offsets-15 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,095] INFO Replica loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,095] INFO [Partition __consumer_offsets-12 broker=0] __consumer_offsets-12 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,105] INFO Replica loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,105] INFO [Partition __consumer_offsets-31 broker=0] __consumer_offsets-31 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,114] INFO Replica loaded for partition view-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,114] INFO [Partition view-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0 broker=0] view-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,124] INFO Replica loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,124] INFO [Partition __consumer_offsets-9 broker=0] __consumer_offsets-9 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,138] INFO Replica loaded for partition __consumer_offsets-47 with initial high watermark 499 (kafka.cluster.Replica) [2020-04-24 15:23:22,138] INFO [Partition __consumer_offsets-47 broker=0] __consumer_offsets-47 starts at Leader Epoch 0 from offset 499. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,140] INFO Replica loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,140] INFO [Partition __consumer_offsets-19 broker=0] __consumer_offsets-19 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,153] INFO Replica loaded for partition increasing-topic-3-0 with initial high watermark 515004 (kafka.cluster.Replica) [2020-04-24 15:23:22,154] INFO [Partition increasing-topic-3-0 broker=0] increasing-topic-3-0 starts at Leader Epoch 0 from offset 515004. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,164] INFO Replica loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,164] INFO [Partition __consumer_offsets-28 broker=0] __consumer_offsets-28 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,174] INFO Replica loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,174] INFO [Partition __consumer_offsets-38 broker=0] __consumer_offsets-38 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,183] INFO Replica loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,183] INFO [Partition __consumer_offsets-35 broker=0] __consumer_offsets-35 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,193] INFO Replica loaded for partition __consumer_offsets-44 with initial high watermark 88 (kafka.cluster.Replica) [2020-04-24 15:23:22,193] INFO [Partition __consumer_offsets-44 broker=0] __consumer_offsets-44 starts at Leader Epoch 0 from offset 88. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,195] INFO Replica loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,195] INFO [Partition __consumer_offsets-6 broker=0] __consumer_offsets-6 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,209] INFO Replica loaded for partition increasing-topic-6-0 with initial high watermark 500000 (kafka.cluster.Replica) [2020-04-24 15:23:22,210] INFO [Partition increasing-topic-6-0 broker=0] increasing-topic-6-0 starts at Leader Epoch 0 from offset 500000. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,219] INFO Replica loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,219] INFO [Partition __consumer_offsets-25 broker=0] __consumer_offsets-25 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,228] INFO Replica loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,228] INFO [Partition __consumer_offsets-16 broker=0] __consumer_offsets-16 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,237] INFO Replica loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,237] INFO [Partition __consumer_offsets-22 broker=0] __consumer_offsets-22 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,246] INFO Replica loaded for partition feature-flag-changes-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,246] INFO [Partition feature-flag-changes-0 broker=0] feature-flag-changes-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,257] INFO Replica loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,257] INFO [Partition __consumer_offsets-41 broker=0] __consumer_offsets-41 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,268] INFO Replica loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,268] INFO [Partition __consumer_offsets-32 broker=0] __consumer_offsets-32 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,281] INFO Replica loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,281] INFO [Partition __consumer_offsets-3 broker=0] __consumer_offsets-3 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,291] INFO Replica loaded for partition increasing-topic-9-0 with initial high watermark 278054 (kafka.cluster.Replica) [2020-04-24 15:23:22,291] INFO [Partition increasing-topic-9-0 broker=0] increasing-topic-9-0 starts at Leader Epoch 0 from offset 278054. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,293] INFO Replica loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-24 15:23:22,293] INFO [Partition __consumer_offsets-13 broker=0] __consumer_offsets-13 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,304] INFO Replica loaded for partition increasing-topic-0-0 with initial high watermark 500000 (kafka.cluster.Replica) [2020-04-24 15:23:22,305] INFO [Partition increasing-topic-0-0 broker=0] increasing-topic-0-0 starts at Leader Epoch 0 from offset 500000. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-24 15:23:22,312] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-37 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-43 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,314] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,315] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,316] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,316] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-34 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,316] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,316] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,316] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,316] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,317] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,317] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,318] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,337] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-25 in 23 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,338] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-31 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,339] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-37 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,339] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-43 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,441] INFO [GroupCoordinator 0]: Loading group metadata for tfp-6 with generation 26 (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:22,446] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-49 in 107 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,453] INFO [GroupCoordinator 0]: Loading group metadata for tfp-1 with generation 13 (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:22,453] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-44 in 7 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,477] INFO [GroupCoordinator 0]: Loading group metadata for tfp-8 with generation 12 (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:22,477] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-1 in 24 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,477] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-7 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,477] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-13 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,478] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-19 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,484] INFO [GroupCoordinator 0]: Loading group metadata for tfp-9 with generation 10 (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:22,484] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-2 in 6 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,484] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-8 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,484] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-14 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,484] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-20 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,485] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-26 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,485] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-32 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,485] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-38 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,485] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-3 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,485] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-9 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,485] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-15 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,485] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-21 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,486] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-27 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,486] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-33 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,486] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-39 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,486] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-45 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,486] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-22 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,486] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-28 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,486] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-34 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,487] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-40 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,493] INFO [GroupCoordinator 0]: Loading group metadata for tfp-3 with generation 8 (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:22,493] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-46 in 6 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,493] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-41 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,499] INFO [GroupCoordinator 0]: Loading group metadata for tfp-4 with generation 2 (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:22,499] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-47 in 6 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,499] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-4 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,499] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-10 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,500] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-16 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,500] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-5 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,500] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-11 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,500] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-17 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,500] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-23 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,500] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-29 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,500] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-35 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,505] INFO [GroupCoordinator 0]: Loading group metadata for tfp-7 with generation 8 (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:22,506] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-0 in 6 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,506] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-6 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,506] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-12 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,506] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-18 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,506] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-24 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,506] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-30 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,507] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-36 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,507] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-42 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:23:22,513] INFO [GroupCoordinator 0]: Loading group metadata for tfp-5 with generation 6 (kafka.coordinator.group.GroupCoordinator) [2020-04-24 15:23:22,513] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-48 in 6 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:33:21,251] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 5 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:43:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 15:53:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 16:03:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 16:13:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 16:23:21,248] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 16:33:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 16:43:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 16:53:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 17:03:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 17:13:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 17:23:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 17:33:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 17:43:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 17:53:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 18:03:21,248] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 18:10:24,323] WARN Client session timed out, have not heard from server in 4000ms for sessionid 0x100000dc2cd0054 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:10:24,398] INFO Client session timed out, have not heard from server in 4000ms for sessionid 0x100000dc2cd0054, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:10:27,018] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:10:27,024] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:10:27,073] INFO Session establishment complete on server zookeeper/10.109.226.228:2181, sessionid = 0x100000dc2cd0054, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:11:54,650] WARN Client session timed out, have not heard from server in 4001ms for sessionid 0x100000dc2cd0054 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:11:54,869] INFO Client session timed out, have not heard from server in 4001ms for sessionid 0x100000dc2cd0054, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:12:02,535] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:12:02,538] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:12:02,540] INFO Session establishment complete on server zookeeper/10.109.226.228:2181, sessionid = 0x100000dc2cd0054, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:13:00,973] WARN Client session timed out, have not heard from server in 4002ms for sessionid 0x100000dc2cd0054 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:13:01,029] INFO Client session timed out, have not heard from server in 4002ms for sessionid 0x100000dc2cd0054, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:13:08,484] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:13:08,724] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:13:14,560] WARN Client session timed out, have not heard from server in 6029ms for sessionid 0x100000dc2cd0054 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:13:14,574] INFO Client session timed out, have not heard from server in 6029ms for sessionid 0x100000dc2cd0054, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:13:22,462] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1204 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 18:14:05,681] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:05,681] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:05,685] WARN Unable to reconnect to ZooKeeper service, session 0x100000dc2cd0054 has expired (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:05,869] INFO Unable to reconnect to ZooKeeper service, session 0x100000dc2cd0054 has expired, closing socket connection (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:06,086] INFO EventThread shut down for session: 0x100000dc2cd0054 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:06,140] INFO [ZooKeeperClient Kafka server] Session expired. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 18:14:06,145] INFO [ZooKeeperClient Kafka server] Initializing a new session to zookeeper:2181. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 18:14:06,145] INFO Initiating client connection, connectString=zookeeper:2181 sessionTimeout=6000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@6e950bcf (org.apache.zookeeper.ZooKeeper) [2020-04-24 18:14:06,161] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:06,174] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:06,251] INFO Session establishment complete on server zookeeper/10.109.226.228:2181, sessionid = 0x100000dc2cd0055, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:06,286] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.zk.KafkaZkClient) [2020-04-24 18:14:06,318] INFO Stat of the created znode at /brokers/ids/0 is: 1756,1756,1587752046304,1587752046304,1,0,0,72057653140717653,307,0,1756 (kafka.zk.KafkaZkClient) [2020-04-24 18:14:06,319] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(kafka-a-0.kafka.default.svc.cluster.local,9092,ListenerName(PLAINTEXT),PLAINTEXT), EndPoint(192.168.1.45,32400,ListenerName(OUTSIDE),PLAINTEXT)), czxid (broker epoch): 1756 (kafka.zk.KafkaZkClient) [2020-04-24 18:14:22,069] WARN Client session timed out, have not heard from server in 5568ms for sessionid 0x100000dc2cd0055 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:22,093] INFO Client session timed out, have not heard from server in 5568ms for sessionid 0x100000dc2cd0055, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:33,444] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:34,104] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:43,019] WARN Client session timed out, have not heard from server in 8967ms for sessionid 0x100000dc2cd0055 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:14:50,951] INFO Client session timed out, have not heard from server in 8967ms for sessionid 0x100000dc2cd0055, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:50,684] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:51,044] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:51,085] INFO EventThread shut down for session: 0x100000dc2cd0055 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:51,085] INFO [ZooKeeperClient Kafka server] Session expired. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 18:17:51,085] WARN Unable to reconnect to ZooKeeper service, session 0x100000dc2cd0055 has expired (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:51,085] INFO Unable to reconnect to ZooKeeper service, session 0x100000dc2cd0055 has expired, closing socket connection (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:51,088] INFO [ZooKeeperClient Kafka server] Initializing a new session to zookeeper:2181. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 18:17:51,088] INFO Initiating client connection, connectString=zookeeper:2181 sessionTimeout=6000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@6e950bcf (org.apache.zookeeper.ZooKeeper) [2020-04-24 18:17:53,142] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:53,321] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:53,347] INFO Session establishment complete on server zookeeper/10.109.226.228:2181, sessionid = 0x100000dc2cd0056, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:17:53,351] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.zk.KafkaZkClient) [2020-04-24 18:17:53,358] INFO Stat of the created znode at /brokers/ids/0 is: 1761,1761,1587752273353,1587752273353,1,0,0,72057653140717654,307,0,1761 (kafka.zk.KafkaZkClient) [2020-04-24 18:17:53,358] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(kafka-a-0.kafka.default.svc.cluster.local,9092,ListenerName(PLAINTEXT),PLAINTEXT), EndPoint(192.168.1.45,32400,ListenerName(OUTSIDE),PLAINTEXT)), czxid (broker epoch): 1761 (kafka.zk.KafkaZkClient) [2020-04-24 18:17:54,913] WARN Attempting to send response via channel for which there is no open connection, connection id 172.17.0.7:9092-172.17.0.6:56324-7 (kafka.network.Processor) [2020-04-24 18:19:35,233] WARN Client session timed out, have not heard from server in 4001ms for sessionid 0x100000dc2cd0056 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:19:36,869] INFO Client session timed out, have not heard from server in 4001ms for sessionid 0x100000dc2cd0056, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:19:38,562] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:19:38,567] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:19:38,582] INFO Session establishment complete on server zookeeper/10.109.226.228:2181, sessionid = 0x100000dc2cd0056, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:20:58,708] WARN Client session timed out, have not heard from server in 4016ms for sessionid 0x100000dc2cd0056 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:00,480] INFO Client session timed out, have not heard from server in 4016ms for sessionid 0x100000dc2cd0056, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:15,391] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:17,066] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:23,313] WARN Session 0x100000dc2cd0056 for server zookeeper/10.109.226.228:2181, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.io.IOException: Connection reset by peer at java.base/sun.nio.ch.FileDispatcherImpl.read0(Native Method) at java.base/sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) at java.base/sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:276) at java.base/sun.nio.ch.IOUtil.read(IOUtil.java:233) at java.base/sun.nio.ch.IOUtil.read(IOUtil.java:223) at java.base/sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:358) at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:68) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:366) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141) [2020-04-24 18:21:27,028] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:27,028] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:27,029] INFO [ZooKeeperClient Kafka server] Session expired. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 18:21:27,030] WARN Unable to reconnect to ZooKeeper service, session 0x100000dc2cd0056 has expired (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:27,030] INFO Unable to reconnect to ZooKeeper service, session 0x100000dc2cd0056 has expired, closing socket connection (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:27,031] INFO EventThread shut down for session: 0x100000dc2cd0056 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:27,032] INFO [ZooKeeperClient Kafka server] Initializing a new session to zookeeper:2181. (kafka.zookeeper.ZooKeeperClient) [2020-04-24 18:21:27,032] INFO Initiating client connection, connectString=zookeeper:2181 sessionTimeout=6000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@6e950bcf (org.apache.zookeeper.ZooKeeper) [2020-04-24 18:21:27,069] INFO Opening socket connection to server zookeeper/10.109.226.228:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:27,082] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:27,089] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.zk.KafkaZkClient) [2020-04-24 18:21:27,143] INFO Session establishment complete on server zookeeper/10.109.226.228:2181, sessionid = 0x100000dc2cd0057, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2020-04-24 18:21:27,153] INFO Stat of the created znode at /brokers/ids/0 is: 1766,1766,1587752487144,1587752487144,1,0,0,72057653140717655,307,0,1766 (kafka.zk.KafkaZkClient) [2020-04-24 18:21:27,153] INFO Registered broker 0 at path /brokers/ids/0 with addresses: ArrayBuffer(EndPoint(kafka-a-0.kafka.default.svc.cluster.local,9092,ListenerName(PLAINTEXT),PLAINTEXT), EndPoint(192.168.1.45,32400,ListenerName(OUTSIDE),PLAINTEXT)), czxid (broker epoch): 1766 (kafka.zk.KafkaZkClient) [2020-04-24 18:23:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 18:33:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 18:43:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 18:53:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 19:03:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 19:13:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 19:23:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 19:33:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 19:43:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 19:53:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 20:03:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 20:13:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 20:23:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 20:33:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 20:41:56,238] WARN Attempting to send response via channel for which there is no open connection, connection id 172.17.0.7:9092-172.17.0.18:47694-868 (kafka.network.Processor) [2020-04-24 20:43:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-24 20:53:21,247] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)