[2020-04-23 19:19:38,504] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [2020-04-23 19:19:39,052] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) [2020-04-23 19:19:39,053] INFO starting (kafka.server.KafkaServer) [2020-04-23 19:19:39,053] INFO Connecting to zookeeper on zookeeper:2181 (kafka.server.KafkaServer) [2020-04-23 19:19:39,072] INFO [ZooKeeperClient Kafka server] Initializing a new session to zookeeper:2181. (kafka.zookeeper.ZooKeeperClient) [2020-04-23 19:19:39,076] INFO Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,076] INFO Client environment:host.name=kafka-a-0.kafka.default.svc.cluster.local (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,076] INFO Client environment:java.version=11.0.5 (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,076] INFO Client environment:java.vendor=AdoptOpenJDK (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:java.home=/opt/java/openjdk (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] 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-23 19:19:39,077] INFO Client environment:java.library.path=/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:java.compiler= (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:os.version=4.15.0 (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:user.name=root (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:user.home=/root (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,077] INFO Client environment:user.dir=/opt/kafka (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,078] INFO Initiating client connection, connectString=zookeeper:2181 sessionTimeout=6000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@6e950bcf (org.apache.zookeeper.ZooKeeper) [2020-04-23 19:19:39,092] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient) [2020-04-23 19:19:39,100] 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-23 19:19:39,106] INFO Socket connection established to zookeeper/10.109.226.228:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2020-04-23 19:19:39,115] INFO Session establishment complete on server zookeeper/10.109.226.228:2181, sessionid = 0x100000dc2cd0031, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2020-04-23 19:19:39,119] INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient) [2020-04-23 19:19:39,337] INFO Cluster ID = CR-fk2KUTk-knBM_rwsdXg (kafka.server.KafkaServer) [2020-04-23 19:19:39,398] 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-23 19:19:39,408] 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-23 19:19:39,437] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2020-04-23 19:19:39,438] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2020-04-23 19:19:39,439] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2020-04-23 19:19:39,482] INFO Loading logs. (kafka.log.LogManager) [2020-04-23 19:19:39,562] 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-23 19:19:39,573] 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 60 ms (kafka.log.Log) [2020-04-23 19:19:39,592] 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-23 19:19:39,597] 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 14 ms (kafka.log.Log) [2020-04-23 19:19:39,608] 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-23 19:19:39,609] 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-23 19:19:39,623] 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-23 19:19:39,623] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:39,635] 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-23 19:19:39,635] 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-23 19:19:39,650] 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-23 19:19:39,650] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:39,662] 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-23 19:19:39,663] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:39,676] 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-23 19:19:39,677] 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-23 19:19:39,788] 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-23 19:19:39,789] INFO [ProducerStateManager partition=increasing-topic-7-0] Loading producer state from snapshot file '/var/lib/kafka/data/topics/increasing-topic-7-0/00000000000000321455.snapshot' (kafka.log.ProducerStateManager) [2020-04-23 19:19:39,802] INFO [Log partition=increasing-topic-7-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 321455 in 122 ms (kafka.log.Log) [2020-04-23 19:19:39,813] 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-23 19:19:39,814] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:39,826] 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-23 19:19:39,826] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:39,838] 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-23 19:19:39,838] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:39,849] 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-23 19:19:39,849] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:39,860] 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-23 19:19:39,860] 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-23 19:19:39,871] 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-23 19:19:39,871] 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-23 19:19:39,883] 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-23 19:19:39,883] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:39,897] 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-23 19:19:39,897] 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 12 ms (kafka.log.Log) [2020-04-23 19:19:39,908] 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-23 19:19:39,909] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:39,919] 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-23 19:19:39,920] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:39,930] 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-23 19:19:39,931] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:39,943] 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-23 19:19:39,943] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:39,955] 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-23 19:19:39,955] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:39,966] 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-23 19:19:39,966] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:39,984] 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-23 19:19:39,984] 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 15 ms (kafka.log.Log) [2020-04-23 19:19:39,996] 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-23 19:19:39,996] 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-23 19:19:40,010] 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-23 19:19:40,010] 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 12 ms (kafka.log.Log) [2020-04-23 19:19:40,024] 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-23 19:19:40,025] 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-23 19:19:40,026] 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 14 ms (kafka.log.Log) [2020-04-23 19:19:40,038] 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-23 19:19:40,039] 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 12 ms (kafka.log.Log) [2020-04-23 19:19:40,049] 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-23 19:19:40,050] 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-23 19:19:40,061] 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-23 19:19:40,061] 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-23 19:19:40,074] 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-23 19:19:40,074] 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 11 ms (kafka.log.Log) [2020-04-23 19:19:40,085] 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-23 19:19:40,086] 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-23 19:19:40,096] 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-23 19:19:40,096] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:40,106] 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-23 19:19:40,106] 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-23 19:19:40,116] 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-23 19:19:40,117] INFO [ProducerStateManager partition=vault-secret-changes-0] Writing producer snapshot at offset 2 (kafka.log.ProducerStateManager) [2020-04-23 19:19:40,118] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:40,130] 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-23 19:19:40,130] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:40,147] 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-23 19:19:40,147] 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-23 19:19:40,150] 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 18 ms (kafka.log.Log) [2020-04-23 19:19:40,161] 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-23 19:19:40,161] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:40,250] 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-23 19:19:40,251] INFO [ProducerStateManager partition=increasing-topic-1-0] Loading producer state from snapshot file '/var/lib/kafka/data/topics/increasing-topic-1-0/00000000000000079955.snapshot' (kafka.log.ProducerStateManager) [2020-04-23 19:19:40,252] INFO [Log partition=increasing-topic-1-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 79955 in 89 ms (kafka.log.Log) [2020-04-23 19:19:40,263] 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-23 19:19:40,263] 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-23 19:19:40,273] 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-23 19:19:40,273] 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 8 ms (kafka.log.Log) [2020-04-23 19:19:40,285] 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-23 19:19:40,285] 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 10 ms (kafka.log.Log) [2020-04-23 19:19:40,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-23 19:19:40,298] 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 11 ms (kafka.log.Log) [2020-04-23 19:19:40,309] 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-23 19:19:40,309] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:40,320] INFO [Log partition=__consumer_offsets-2, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-23 19:19:40,320] 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 0 in 10 ms (kafka.log.Log) [2020-04-23 19:19:40,329] 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-23 19:19:40,330] 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 8 ms (kafka.log.Log) [2020-04-23 19:19:40,344] 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-23 19:19:40,345] 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-23 19:19:40,345] 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 14 ms (kafka.log.Log) [2020-04-23 19:19:40,358] 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-23 19:19:40,358] 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 11 ms (kafka.log.Log) [2020-04-23 19:19:40,368] 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-23 19:19:40,368] 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 8 ms (kafka.log.Log) [2020-04-23 19:19:40,378] 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-23 19:19:40,378] 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 8 ms (kafka.log.Log) [2020-04-23 19:19:40,394] 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-23 19:19:40,395] 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-23 19:19:40,395] 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 16 ms (kafka.log.Log) [2020-04-23 19:19:40,434] 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-23 19:19:40,435] 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-23 19:19:40,437] 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 41 ms (kafka.log.Log) [2020-04-23 19:19:40,483] 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-23 19:19:40,484] INFO [ProducerStateManager partition=increasing-topic-6-0] Loading producer state from snapshot file '/var/lib/kafka/data/topics/increasing-topic-6-0/00000000000000500000.snapshot' (kafka.log.ProducerStateManager) [2020-04-23 19:19:40,488] INFO [Log partition=increasing-topic-6-0, dir=/var/lib/kafka/data/topics] Completed load of log with 1 segments, log start offset 0 and log end offset 500000 in 49 ms (kafka.log.Log) [2020-04-23 19:19:40,516] 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-23 19:19:40,516] 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 26 ms (kafka.log.Log) [2020-04-23 19:19:40,524] 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-23 19:19:40,524] 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 7 ms (kafka.log.Log) [2020-04-23 19:19:40,532] 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-23 19:19:40,533] 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 7 ms (kafka.log.Log) [2020-04-23 19:19:40,552] 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-23 19:19:40,552] 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-23 19:19:40,573] 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-23 19:19:40,573] 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-23 19:19:40,574] 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 21 ms (kafka.log.Log) [2020-04-23 19:19:40,584] 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-23 19:19:40,585] 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-23 19:19:40,587] 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 12 ms (kafka.log.Log) [2020-04-23 19:19:40,597] 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-23 19:19:40,598] 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 9 ms (kafka.log.Log) [2020-04-23 19:19:40,607] INFO [Log partition=__consumer_offsets-1, dir=/var/lib/kafka/data/topics] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2020-04-23 19:19:40,608] 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 0 in 9 ms (kafka.log.Log) [2020-04-23 19:19:40,620] 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-23 19:19:40,621] 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 12 ms (kafka.log.Log) [2020-04-23 19:19:40,630] 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-23 19:19:40,631] 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-23 19:19:40,634] INFO Logs loading complete in 1151 ms. (kafka.log.LogManager) [2020-04-23 19:19:40,654] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) [2020-04-23 19:19:40,655] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) [2020-04-23 19:19:40,965] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor) [2020-04-23 19:19:41,018] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer) [2020-04-23 19:19:41,023] INFO Awaiting socket connections on 0.0.0.0:9094. (kafka.network.Acceptor) [2020-04-23 19:19:41,034] INFO [SocketServer brokerId=0] Created data-plane acceptor and processors for endpoint : EndPoint(null,9094,ListenerName(OUTSIDE),PLAINTEXT) (kafka.network.SocketServer) [2020-04-23 19:19:41,037] INFO [SocketServer brokerId=0] Started 2 acceptor threads for data-plane (kafka.network.SocketServer) [2020-04-23 19:19:41,079] INFO [ExpirationReaper-0-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-23 19:19:41,081] INFO [ExpirationReaper-0-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-23 19:19:41,090] INFO [ExpirationReaper-0-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-23 19:19:41,095] INFO [ExpirationReaper-0-ElectPreferredLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-23 19:19:41,114] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler) [2020-04-23 19:19:41,164] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.zk.KafkaZkClient) [2020-04-23 19:19:41,179] INFO Stat of the created znode at /brokers/ids/0 is: 1122,1122,1587669581172,1587669581172,1,0,0,72057653140717617,307,0,1122 (kafka.zk.KafkaZkClient) [2020-04-23 19:19:41,180] 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): 1122 (kafka.zk.KafkaZkClient) [2020-04-23 19:19:41,278] INFO [ExpirationReaper-0-topic]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-23 19:19:41,290] INFO [ExpirationReaper-0-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-23 19:19:41,305] INFO [ExpirationReaper-0-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2020-04-23 19:19:41,340] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.group.GroupCoordinator) [2020-04-23 19:19:41,342] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.group.GroupCoordinator) [2020-04-23 19:19:41,346] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:41,372] INFO [ProducerId Manager 0]: Acquired new producerId block (brokerId:0,blockStartProducerId:45000,blockEndProducerId:45999) by writing to Zk with path version 46 (kafka.coordinator.transaction.ProducerIdManager) [2020-04-23 19:19:41,418] INFO [TransactionCoordinator id=0] Starting up. (kafka.coordinator.transaction.TransactionCoordinator) [2020-04-23 19:19:41,422] INFO [TransactionCoordinator id=0] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) [2020-04-23 19:19:41,422] INFO [Transaction Marker Channel Manager 0]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2020-04-23 19:19:41,518] INFO [/config/changes-event-process-thread]: Starting (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2020-04-23 19:19:41,604] INFO [SocketServer brokerId=0] Started data-plane processors for 2 acceptors (kafka.network.SocketServer) [2020-04-23 19:19:41,618] INFO Kafka version: 2.3.1 (org.apache.kafka.common.utils.AppInfoParser) [2020-04-23 19:19:41,618] INFO Kafka commitId: 18a913733fb71c01 (org.apache.kafka.common.utils.AppInfoParser) [2020-04-23 19:19:41,619] INFO Kafka startTimeMs: 1587669581607 (org.apache.kafka.common.utils.AppInfoParser) [2020-04-23 19:19:41,621] INFO [KafkaServer id=0] started (kafka.server.KafkaServer) [2020-04-23 19:19:41,771] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(__consumer_offsets-22, __consumer_offsets-30, __consumer_offsets-8, __consumer_offsets-21, __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, __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, __consumer_offsets-29, __consumer_offsets-34, __consumer_offsets-10, __consumer_offsets-32, __consumer_offsets-40, increasing-topic-6-0) (kafka.server.ReplicaFetcherManager) [2020-04-23 19:19:41,783] INFO Replica loaded for partition __consumer_offsets-0 with initial high watermark 326 (kafka.cluster.Replica) [2020-04-23 19:19:41,786] 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-23 19:19:41,802] INFO Replica loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,802] 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-23 19:19:41,816] INFO Replica loaded for partition __consumer_offsets-48 with initial high watermark 502 (kafka.cluster.Replica) [2020-04-23 19:19:41,816] 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-23 19:19:41,820] INFO Replica loaded for partition vault-secret-changes-0 with initial high watermark 2 (kafka.cluster.Replica) [2020-04-23 19:19:41,820] 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-23 19:19:41,835] INFO Replica loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,835] 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-23 19:19:41,851] INFO Replica loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,851] 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-23 19:19:41,868] INFO Replica loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,869] 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-23 19:19:41,879] INFO Replica loaded for partition item-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0 with initial high watermark 4 (kafka.cluster.Replica) [2020-04-23 19:19:41,880] 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-23 19:19:41,890] INFO Replica loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,890] 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-23 19:19:41,902] INFO Replica loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,902] 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-23 19:19:41,911] INFO Replica loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,911] 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-23 19:19:41,923] INFO Replica loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,923] 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-23 19:19:41,933] INFO Replica loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,934] INFO [Partition __consumer_offsets-1 broker=0] __consumer_offsets-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-23 19:19:41,943] INFO Replica loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,943] 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-23 19:19:41,955] INFO Replica loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,955] 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-23 19:19:41,967] INFO Replica loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,968] 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-23 19:19:41,977] INFO Replica loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:41,977] 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-23 19:19:41,989] INFO Replica loaded for partition increasing-topic-5-0 with initial high watermark 501872 (kafka.cluster.Replica) [2020-04-23 19:19:41,989] 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-23 19:19:41,999] INFO Replica loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,000] 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-23 19:19:42,014] INFO Replica loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,015] 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-23 19:19:42,025] INFO Replica loaded for partition __consumer_offsets-49 with initial high watermark 526 (kafka.cluster.Replica) [2020-04-23 19:19:42,025] 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-23 19:19:42,027] INFO Replica loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,027] 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-23 19:19:42,037] INFO Replica loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,037] 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-23 19:19:42,046] INFO Replica loaded for partition __consumer_offsets-46 with initial high watermark 506 (kafka.cluster.Replica) [2020-04-23 19:19:42,046] 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-23 19:19:42,049] INFO Replica loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,049] 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-23 19:19:42,067] INFO Replica loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,067] 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-23 19:19:42,077] INFO Replica loaded for partition increasing-topic-7-0 with initial high watermark 321455 (kafka.cluster.Replica) [2020-04-23 19:19:42,077] 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-23 19:19:42,080] INFO Replica loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,081] 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-23 19:19:42,092] INFO Replica loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,093] 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-23 19:19:42,104] INFO Replica loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,104] 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-23 19:19:42,114] INFO Replica loaded for partition host-changes-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,114] 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-23 19:19:42,130] INFO Replica loaded for partition increasing-topic-1-0 with initial high watermark 79955 (kafka.cluster.Replica) [2020-04-23 19:19:42,130] 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-23 19:19:42,132] INFO Replica loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,132] 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-23 19:19:42,145] INFO Replica loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,150] INFO [Partition __consumer_offsets-2 broker=0] __consumer_offsets-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2020-04-23 19:19:42,163] INFO Replica loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,163] 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-23 19:19:42,178] INFO Replica loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,178] 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-23 19:19:42,208] INFO Replica loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,209] 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-23 19:19:42,221] INFO Replica loaded for partition increasing-topic-4-0 with initial high watermark 500000 (kafka.cluster.Replica) [2020-04-23 19:19:42,221] 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-23 19:19:42,231] INFO Replica loaded for partition app-changes-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,231] 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-23 19:19:42,252] INFO Replica loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,252] 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-23 19:19:42,267] INFO Replica loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,267] 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-23 19:19:42,283] INFO Replica loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,283] 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-23 19:19:42,298] INFO Replica loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,299] 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-23 19:19:42,310] INFO Replica loaded for partition view-changes-ede5b1f0-84d7-11ea-b2b1-334723ba948f-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,311] 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-23 19:19:42,322] INFO Replica loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,323] 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-23 19:19:42,334] INFO Replica loaded for partition __consumer_offsets-47 with initial high watermark 499 (kafka.cluster.Replica) [2020-04-23 19:19:42,334] 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-23 19:19:42,338] INFO Replica loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,338] 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-23 19:19:42,347] INFO Replica loaded for partition increasing-topic-3-0 with initial high watermark 515004 (kafka.cluster.Replica) [2020-04-23 19:19:42,347] 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-23 19:19:42,356] INFO Replica loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,357] 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-23 19:19:42,365] INFO Replica loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,366] 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-23 19:19:42,376] INFO Replica loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,376] 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-23 19:19:42,388] INFO Replica loaded for partition __consumer_offsets-44 with initial high watermark 88 (kafka.cluster.Replica) [2020-04-23 19:19:42,388] 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-23 19:19:42,391] INFO Replica loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,392] 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-23 19:19:42,404] INFO Replica loaded for partition increasing-topic-6-0 with initial high watermark 500000 (kafka.cluster.Replica) [2020-04-23 19:19:42,404] 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-23 19:19:42,406] INFO Replica loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,406] 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-23 19:19:42,415] INFO Replica loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,415] 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-23 19:19:42,424] INFO Replica loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,424] 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-23 19:19:42,433] INFO Replica loaded for partition feature-flag-changes-0 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,434] 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-23 19:19:42,443] INFO Replica loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,444] 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-23 19:19:42,452] INFO Replica loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,453] 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-23 19:19:42,462] INFO Replica loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,462] 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-23 19:19:42,472] INFO Replica loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Replica) [2020-04-23 19:19:42,473] 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-23 19:19:42,482] INFO Replica loaded for partition increasing-topic-0-0 with initial high watermark 500000 (kafka.cluster.Replica) [2020-04-23 19:19:42,482] 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-23 19:19:42,494] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-37 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-43 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,496] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,497] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-34 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,498] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,498] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,498] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,498] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,498] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,498] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,498] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,498] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,499] INFO [GroupMetadataManager brokerId=0] Scheduling loading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,524] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-25 in 27 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,525] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-31 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,525] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-37 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,525] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-43 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,581] INFO [GroupCoordinator 0]: Loading group metadata for tfp-6 with generation 26 (kafka.coordinator.group.GroupCoordinator) [2020-04-23 19:19:42,583] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-49 in 58 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,591] INFO [GroupCoordinator 0]: Loading group metadata for tfp-1 with generation 13 (kafka.coordinator.group.GroupCoordinator) [2020-04-23 19:19:42,592] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-44 in 8 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,592] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-1 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,592] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-7 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,593] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-13 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,593] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-19 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,593] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-2 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,593] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-8 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,594] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-14 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,594] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-20 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,594] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-26 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,594] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-32 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,594] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-38 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,595] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-3 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,595] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-9 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,595] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-15 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,595] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-21 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,596] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-27 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,596] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-33 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,596] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-39 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,596] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-45 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,597] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-22 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,597] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-28 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,597] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-34 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,597] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-40 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,622] INFO [GroupCoordinator 0]: Loading group metadata for tfp-3 with generation 8 (kafka.coordinator.group.GroupCoordinator) [2020-04-23 19:19:42,622] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-46 in 25 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,622] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-41 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,674] INFO [GroupCoordinator 0]: Loading group metadata for tfp-4 with generation 2 (kafka.coordinator.group.GroupCoordinator) [2020-04-23 19:19:42,674] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-47 in 51 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,675] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-4 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,675] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-10 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,675] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-16 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,675] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-5 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,676] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-11 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,676] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-17 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,676] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-23 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,676] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-29 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,677] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-35 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,681] INFO [GroupCoordinator 0]: Loading group metadata for tfp-7 with generation 8 (kafka.coordinator.group.GroupCoordinator) [2020-04-23 19:19:42,681] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-0 in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,682] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-6 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,682] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-12 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,700] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-18 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,701] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-24 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,701] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-30 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,701] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-36 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,701] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-42 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:19:42,706] INFO [GroupCoordinator 0]: Loading group metadata for tfp-5 with generation 6 (kafka.coordinator.group.GroupCoordinator) [2020-04-23 19:19:42,706] INFO [GroupMetadataManager brokerId=0] Finished loading offsets and group metadata from __consumer_offsets-48 in 5 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:20:10,677] INFO [Log partition=increasing-topic-1-0, dir=/var/lib/kafka/data/topics] Found deletable segments with base offsets [0] due to retention time 604800000ms breach (kafka.log.Log) [2020-04-23 19:20:10,690] INFO [Log partition=increasing-topic-1-0, dir=/var/lib/kafka/data/topics] Rolled new log segment at offset 79955 in 9 ms. (kafka.log.Log) [2020-04-23 19:20:10,690] INFO [Log partition=increasing-topic-1-0, dir=/var/lib/kafka/data/topics] Scheduling log segment [baseOffset 0, size 1518214] for deletion. (kafka.log.Log) [2020-04-23 19:20:10,692] INFO [Log partition=increasing-topic-1-0, dir=/var/lib/kafka/data/topics] Incrementing log start offset to 79955 (kafka.log.Log) [2020-04-23 19:20:10,706] INFO [Log partition=increasing-topic-7-0, dir=/var/lib/kafka/data/topics] Found deletable segments with base offsets [0] due to retention time 604800000ms breach (kafka.log.Log) [2020-04-23 19:20:10,712] INFO [Log partition=increasing-topic-7-0, dir=/var/lib/kafka/data/topics] Rolled new log segment at offset 321455 in 5 ms. (kafka.log.Log) [2020-04-23 19:20:10,712] INFO [Log partition=increasing-topic-7-0, dir=/var/lib/kafka/data/topics] Scheduling log segment [baseOffset 0, size 4513814] for deletion. (kafka.log.Log) [2020-04-23 19:20:10,712] INFO [Log partition=increasing-topic-7-0, dir=/var/lib/kafka/data/topics] Incrementing log start offset to 321455 (kafka.log.Log) [2020-04-23 19:20:10,720] INFO [Log partition=increasing-topic-6-0, dir=/var/lib/kafka/data/topics] Found deletable segments with base offsets [0] due to retention time 604800000ms breach (kafka.log.Log) [2020-04-23 19:20:10,721] INFO [Log partition=increasing-topic-6-0, dir=/var/lib/kafka/data/topics] Rolled new log segment at offset 500000 in 1 ms. (kafka.log.Log) [2020-04-23 19:20:10,721] INFO [Log partition=increasing-topic-6-0, dir=/var/lib/kafka/data/topics] Scheduling log segment [baseOffset 0, size 7063459] for deletion. (kafka.log.Log) [2020-04-23 19:20:10,721] INFO [Log partition=increasing-topic-6-0, dir=/var/lib/kafka/data/topics] Incrementing log start offset to 500000 (kafka.log.Log) [2020-04-23 19:21:10,692] INFO [Log partition=increasing-topic-1-0, dir=/var/lib/kafka/data/topics] Deleting segment 0 (kafka.log.Log) [2020-04-23 19:21:10,695] INFO Deleted log /var/lib/kafka/data/topics/increasing-topic-1-0/00000000000000000000.log.deleted. (kafka.log.LogSegment) [2020-04-23 19:21:10,698] INFO Deleted offset index /var/lib/kafka/data/topics/increasing-topic-1-0/00000000000000000000.index.deleted. (kafka.log.LogSegment) [2020-04-23 19:21:10,699] INFO Deleted time index /var/lib/kafka/data/topics/increasing-topic-1-0/00000000000000000000.timeindex.deleted. (kafka.log.LogSegment) [2020-04-23 19:21:10,712] INFO [Log partition=increasing-topic-7-0, dir=/var/lib/kafka/data/topics] Deleting segment 0 (kafka.log.Log) [2020-04-23 19:21:10,713] INFO Deleted log /var/lib/kafka/data/topics/increasing-topic-7-0/00000000000000000000.log.deleted. (kafka.log.LogSegment) [2020-04-23 19:21:10,713] INFO Deleted offset index /var/lib/kafka/data/topics/increasing-topic-7-0/00000000000000000000.index.deleted. (kafka.log.LogSegment) [2020-04-23 19:21:10,713] INFO Deleted time index /var/lib/kafka/data/topics/increasing-topic-7-0/00000000000000000000.timeindex.deleted. (kafka.log.LogSegment) [2020-04-23 19:21:10,721] INFO [Log partition=increasing-topic-6-0, dir=/var/lib/kafka/data/topics] Deleting segment 0 (kafka.log.Log) [2020-04-23 19:21:10,722] INFO Deleted log /var/lib/kafka/data/topics/increasing-topic-6-0/00000000000000000000.log.deleted. (kafka.log.LogSegment) [2020-04-23 19:21:10,722] INFO Deleted offset index /var/lib/kafka/data/topics/increasing-topic-6-0/00000000000000000000.index.deleted. (kafka.log.LogSegment) [2020-04-23 19:21:10,722] INFO Deleted time index /var/lib/kafka/data/topics/increasing-topic-6-0/00000000000000000000.timeindex.deleted. (kafka.log.LogSegment) [2020-04-23 19:29:41,349] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 9 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2020-04-23 19:39:41,341] INFO [GroupMetadataManager brokerId=0] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)