https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.5.0/org.apache.nifi.processors.standard.GetSFTP/index.html Can anyone explain what is write attributes in NIFI. where i can find this in getsftp processor. Thanks in advance ... View more

Hi, I am trying to start Kafka but i got the below error. anyone can help what is the issue ? bin/kafka-server-start.sh config/server.properties [2018-03-06 23:46:43,391] INFO KafkaConfig values: advertised.host.name = null advertised.listeners = null advertised.port = null alter.config.policy.class.name = null 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 compression.type = producer connections.max.idle.ms = 600000 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 delete.records.purgatory.purge.interval.requests = 1 delete.topic.enable = false fetch.purgatory.purge.interval.requests = 1000 group.initial.rebalance.delay.ms = 0 group.max.session.timeout.ms = 300000 group.min.session.timeout.ms = 6000 host.name = inter.broker.listener.name = null inter.broker.protocol.version = 0.11.0-IV2 leader.imbalance.check.interval.seconds = 300 leader.imbalance.per.broker.percentage = 10 listener.security.protocol.map = SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,TRACE:TRACE,SASL_SSL:SASL_SSL,PLAINTEXT:PLAINTEXT listeners = null 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.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 = /tmp/kafka-logs 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.format.version = 0.11.0-IV2 log.message.timestamp.difference.max.ms = 9223372036854775807 log.message.timestamp.type = CreateTime log.preallocate = false log.retention.bytes = -1 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.per.ip = 2147483647 max.connections.per.ip.overrides = 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.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 = 1440 offsets.topic.compression.codec = 0 offsets.topic.num.partitions = 50 offsets.topic.replication.factor = 1 offsets.topic.segment.bytes = 104857600 port = 9092 principal.builder.class = class org.apache.kafka.common.security.auth.DefaultPrincipalBuilder producer.purgatory.purge.interval.requests = 1000 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.enabled.mechanisms = [GSSAPI] 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.mechanism.inter.broker.protocol = GSSAPI security.inter.broker.protocol = PLAINTEXT socket.receive.buffer.bytes = 102400 socket.request.max.bytes = 104857600 socket.send.buffer.bytes = 102400 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS 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 = localhost:2181 zookeeper.connection.timeout.ms = 6000 zookeeper.session.timeout.ms = 6000 zookeeper.set.acl = false zookeeper.sync.time.ms = 2000 (kafka.server.KafkaConfig) [2018-03-06 23:46:43,440] INFO starting (kafka.server.KafkaServer) [2018-03-06 23:46:43,444] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer) [2018-03-06 23:46:43,465] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2018-03-06 23:46:43,472] INFO Client environment:zookeeper.version=3.4.10-39d3a4f269333c922ed3db283be479f9deacaa0f, built on 03/23/2017 10:13 GMT (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,472] INFO Client environment:host.name=localhost (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,472] INFO Client environment:java.version=1.8.0_151 (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,472] INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,472] INFO Client environment:java.home=/opt/jdk1.8.0_151/jre (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,473] INFO Client environment:java.class.path=:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/aopalliance-repackaged-2.5.0-b05.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/argparse4j-0.7.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/commons-lang3-3.5.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/connect-api-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/connect-file-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/connect-json-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/connect-runtime-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/connect-transforms-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/guava-20.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/hk2-api-2.5.0-b05.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/hk2-locator-2.5.0-b05.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/hk2-utils-2.5.0-b05.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jackson-annotations-2.8.5.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jackson-core-2.8.5.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jackson-databind-2.8.5.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jackson-jaxrs-base-2.8.5.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jackson-jaxrs-json-provider-2.8.5.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jackson-module-jaxb-annotations-2.8.5.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/javassist-3.21.0-GA.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/javax.annotation-api-1.2.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/javax.inject-1.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/javax.inject-2.5.0-b05.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/javax.servlet-api-3.1.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/javax.ws.rs-api-2.0.1.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jersey-client-2.24.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jersey-common-2.24.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jersey-container-servlet-2.24.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jersey-container-servlet-core-2.24.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jersey-guava-2.24.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jersey-media-jaxb-2.24.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jersey-server-2.24.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jetty-continuation-9.2.15.v20160210.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jetty-http-9.2.15.v20160210.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jetty-io-9.2.15.v20160210.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jetty-security-9.2.15.v20160210.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jetty-server-9.2.15.v20160210.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jetty-servlet-9.2.15.v20160210.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jetty-servlets-9.2.15.v20160210.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jetty-util-9.2.15.v20160210.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/jopt-simple-5.0.3.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/kafka_2.11-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/kafka_2.11-0.11.0.0-sources.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/kafka_2.11-0.11.0.0-test-sources.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/kafka-clients-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/kafka-log4j-appender-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/kafka-streams-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/kafka-streams-examples-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/kafka-tools-0.11.0.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/log4j-1.2.17.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/lz4-1.3.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/maven-artifact-3.5.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/metrics-core-2.2.0.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/osgi-resource-locator-1.0.1.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/plexus-utils-3.0.24.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/reflections-0.9.11.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/rocksdbjni-5.0.1.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/scala-library-2.11.11.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/scala-parser-combinators_2.11-1.0.4.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/slf4j-api-1.7.25.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/slf4j-log4j12-1.7.25.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/snappy-java-1.1.2.6.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/validation-api-1.1.0.Final.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/zkclient-0.10.jar:/root/tools/kafka_2.11-0.11.0.0/bin/../libs/zookeeper-3.4.10.jar (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,473] INFO Client environment:java.library.path=/usr/local/lib/:/usr/lib/x86_64-linux-gnu/:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,473] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,473] INFO Client environment:java.compiler=<NA> (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,473] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,473] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,473] INFO Client environment:os.version=3.10.0-693.11.6.el7.x86_64 (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,474] INFO Client environment:user.name=root (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,474] INFO Client environment:user.home=/root (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,474] INFO Client environment:user.dir=/root/tools/kafka_2.11-0.11.0.0 (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,475] INFO Initiating client connection, connectString=localhost:2181 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@3ce1e309 (org.apache.zookeeper.ZooKeeper) [2018-03-06 23:46:43,489] INFO Waiting for keeper state SyncConnected (org.I0Itec.zkclient.ZkClient) [2018-03-06 23:46:43,492] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [2018-03-06 23:46:43,499] INFO Socket connection established to localhost/0:0:0:0:0:0:0:1:2181, initiating session (org.apache.zookeeper.ClientCnxn) [2018-03-06 23:46:43,506] INFO Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2181, sessionid = 0x16122b9656b0043, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2018-03-06 23:46:43,508] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) [2018-03-06 23:46:43,684] INFO Cluster ID = ZJijkPwNQTeZMGTWsv2Qkg (kafka.server.KafkaServer) [2018-03-06 23:46:43,722] INFO [ThrottledRequestReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledRequestReaper) [2018-03-06 23:46:43,722] INFO [ThrottledRequestReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledRequestReaper) [2018-03-06 23:46:43,723] INFO [ThrottledRequestReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledRequestReaper) [2018-03-06 23:46:43,858] INFO Loading logs. (kafka.log.LogManager) [2018-03-06 23:46:43,917] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/getId-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/getId-0/00000000000000000000.timeindex, /tmp/kafka-logs/getId-0/00000000000000000000.index, and /tmp/kafka-logs/getId-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:43,943] INFO Recovering unflushed segment 0 in log getId-0. (kafka.log.Log) [2018-03-06 23:46:43,949] INFO Loading producer state from offset 0 for partition getId-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:43,951] INFO Completed load of log getId-0 with 1 log segments, log start offset 0 and log end offset 0 in 53 ms (kafka.log.Log) [2018-03-06 23:46:43,960] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-0/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-0/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:43,962] INFO Recovering unflushed segment 0 in log __consumer_offsets-0. (kafka.log.Log) [2018-03-06 23:46:43,963] INFO Loading producer state from offset 0 for partition __consumer_offsets-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:43,964] INFO Completed load of log __consumer_offsets-0 with 1 log segments, log start offset 0 and log end offset 0 in 6 ms (kafka.log.Log) [2018-03-06 23:46:43,970] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-29/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-29/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-29/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-29/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:43,989] INFO Recovering unflushed segment 0 in log __consumer_offsets-29. (kafka.log.Log) [2018-03-06 23:46:43,996] INFO Loading producer state from offset 6 for partition __consumer_offsets-29 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:43,999] INFO Loading producer state from snapshot file 00000000000000000006.snapshot for partition __consumer_offsets-29 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,006] INFO Completed load of log __consumer_offsets-29 with 1 log segments, log start offset 0 and log end offset 6 in 38 ms (kafka.log.Log) [2018-03-06 23:46:44,013] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-48/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-48/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-48/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-48/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,028] INFO Recovering unflushed segment 0 in log __consumer_offsets-48. (kafka.log.Log) [2018-03-06 23:46:44,034] INFO Loading producer state from offset 16 for partition __consumer_offsets-48 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,034] INFO Loading producer state from snapshot file 00000000000000000016.snapshot for partition __consumer_offsets-48 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,035] INFO Completed load of log __consumer_offsets-48 with 1 log segments, log start offset 0 and log end offset 16 in 25 ms (kafka.log.Log) [2018-03-06 23:46:44,040] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-10/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-10/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-10/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-10/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,042] INFO Recovering unflushed segment 0 in log __consumer_offsets-10. (kafka.log.Log) [2018-03-06 23:46:44,042] INFO Loading producer state from offset 0 for partition __consumer_offsets-10 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,043] INFO Completed load of log __consumer_offsets-10 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,048] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-45/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-45/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-45/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-45/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,050] INFO Recovering unflushed segment 0 in log __consumer_offsets-45. (kafka.log.Log) [2018-03-06 23:46:44,051] INFO Loading producer state from offset 0 for partition __consumer_offsets-45 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,051] INFO Completed load of log __consumer_offsets-45 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,056] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-26/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-26/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-26/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-26/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,057] INFO Recovering unflushed segment 0 in log __consumer_offsets-26. (kafka.log.Log) [2018-03-06 23:46:44,058] INFO Loading producer state from offset 0 for partition __consumer_offsets-26 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,059] INFO Completed load of log __consumer_offsets-26 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,064] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-7/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-7/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-7/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-7/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,066] INFO Recovering unflushed segment 0 in log __consumer_offsets-7. (kafka.log.Log) [2018-03-06 23:46:44,066] INFO Loading producer state from offset 0 for partition __consumer_offsets-7 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,067] INFO Completed load of log __consumer_offsets-7 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,072] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-42/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-42/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-42/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-42/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,073] INFO Recovering unflushed segment 0 in log __consumer_offsets-42. (kafka.log.Log) [2018-03-06 23:46:44,074] INFO Loading producer state from offset 0 for partition __consumer_offsets-42 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,076] INFO Completed load of log __consumer_offsets-42 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,082] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-4/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-4/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-4/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-4/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,083] INFO Recovering unflushed segment 0 in log __consumer_offsets-4. (kafka.log.Log) [2018-03-06 23:46:44,084] INFO Loading producer state from offset 0 for partition __consumer_offsets-4 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,085] INFO Completed load of log __consumer_offsets-4 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,089] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/mac_addr-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/mac_addr-0/00000000000000000000.timeindex, /tmp/kafka-logs/mac_addr-0/00000000000000000000.index, and /tmp/kafka-logs/mac_addr-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,090] INFO Recovering unflushed segment 0 in log mac_addr-0. (kafka.log.Log) [2018-03-06 23:46:44,091] INFO Loading producer state from offset 0 for partition mac_addr-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,092] INFO Completed load of log mac_addr-0 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,096] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-23/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-23/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-23/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-23/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,097] INFO Recovering unflushed segment 0 in log __consumer_offsets-23. (kafka.log.Log) [2018-03-06 23:46:44,098] INFO Loading producer state from offset 0 for partition __consumer_offsets-23 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,099] INFO Completed load of log __consumer_offsets-23 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,104] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-1/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-1/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-1/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-1/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,106] INFO Recovering unflushed segment 0 in log __consumer_offsets-1. (kafka.log.Log) [2018-03-06 23:46:44,108] INFO Loading producer state from offset 0 for partition __consumer_offsets-1 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,109] INFO Completed load of log __consumer_offsets-1 with 1 log segments, log start offset 0 and log end offset 0 in 7 ms (kafka.log.Log) [2018-03-06 23:46:44,114] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-20/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-20/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-20/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-20/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,115] INFO Recovering unflushed segment 0 in log __consumer_offsets-20. (kafka.log.Log) [2018-03-06 23:46:44,116] INFO Loading producer state from offset 0 for partition __consumer_offsets-20 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,116] INFO Completed load of log __consumer_offsets-20 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,120] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-39/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-39/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-39/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-39/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,122] INFO Recovering unflushed segment 0 in log __consumer_offsets-39. (kafka.log.Log) [2018-03-06 23:46:44,122] INFO Loading producer state from offset 0 for partition __consumer_offsets-39 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,123] INFO Completed load of log __consumer_offsets-39 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,128] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-17/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-17/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-17/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-17/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,131] INFO Recovering unflushed segment 0 in log __consumer_offsets-17. (kafka.log.Log) [2018-03-06 23:46:44,132] INFO Loading producer state from offset 0 for partition __consumer_offsets-17 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,133] INFO Completed load of log __consumer_offsets-17 with 1 log segments, log start offset 0 and log end offset 0 in 6 ms (kafka.log.Log) [2018-03-06 23:46:44,137] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/putId-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/putId-0/00000000000000000000.timeindex, /tmp/kafka-logs/putId-0/00000000000000000000.index, and /tmp/kafka-logs/putId-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,139] INFO Recovering unflushed segment 0 in log putId-0. (kafka.log.Log) [2018-03-06 23:46:44,140] INFO Loading producer state from offset 0 for partition putId-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,141] INFO Completed load of log putId-0 with 1 log segments, log start offset 0 and log end offset 0 in 6 ms (kafka.log.Log) [2018-03-06 23:46:44,147] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-36/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-36/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-36/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-36/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,148] INFO Recovering unflushed segment 0 in log __consumer_offsets-36. (kafka.log.Log) [2018-03-06 23:46:44,149] INFO Loading producer state from offset 0 for partition __consumer_offsets-36 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,150] INFO Completed load of log __consumer_offsets-36 with 1 log segments, log start offset 0 and log end offset 0 in 6 ms (kafka.log.Log) [2018-03-06 23:46:44,154] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-14/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-14/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-14/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-14/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,156] INFO Recovering unflushed segment 0 in log __consumer_offsets-14. (kafka.log.Log) [2018-03-06 23:46:44,157] INFO Loading producer state from offset 0 for partition __consumer_offsets-14 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,157] INFO Completed load of log __consumer_offsets-14 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,162] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-33/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-33/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-33/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-33/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,164] INFO Recovering unflushed segment 0 in log __consumer_offsets-33. (kafka.log.Log) [2018-03-06 23:46:44,166] INFO Loading producer state from offset 0 for partition __consumer_offsets-33 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,167] INFO Completed load of log __consumer_offsets-33 with 1 log segments, log start offset 0 and log end offset 0 in 7 ms (kafka.log.Log) [2018-03-06 23:46:44,173] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/cablemodem-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/cablemodem-0/00000000000000000000.timeindex, /tmp/kafka-logs/cablemodem-0/00000000000000000000.index, and /tmp/kafka-logs/cablemodem-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,174] INFO Recovering unflushed segment 0 in log cablemodem-0. (kafka.log.Log) [2018-03-06 23:46:44,175] INFO Loading producer state from offset 0 for partition cablemodem-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,176] INFO Completed load of log cablemodem-0 with 1 log segments, log start offset 0 and log end offset 0 in 6 ms (kafka.log.Log) [2018-03-06 23:46:44,182] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/neighbour-ssids-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/neighbour-ssids-0/00000000000000000000.timeindex, /tmp/kafka-logs/neighbour-ssids-0/00000000000000000000.index, and /tmp/kafka-logs/neighbour-ssids-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,183] INFO Recovering unflushed segment 0 in log neighbour-ssids-0. (kafka.log.Log) [2018-03-06 23:46:44,184] INFO Loading producer state from offset 0 for partition neighbour-ssids-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,184] INFO Completed load of log neighbour-ssids-0 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,188] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-49/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-49/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-49/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-49/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,189] INFO Recovering unflushed segment 0 in log __consumer_offsets-49. (kafka.log.Log) [2018-03-06 23:46:44,190] INFO Loading producer state from offset 0 for partition __consumer_offsets-49 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,191] INFO Completed load of log __consumer_offsets-49 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,194] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-11/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-11/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-11/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-11/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,195] INFO Recovering unflushed segment 0 in log __consumer_offsets-11. (kafka.log.Log) [2018-03-06 23:46:44,196] INFO Loading producer state from offset 0 for partition __consumer_offsets-11 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,197] INFO Completed load of log __consumer_offsets-11 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,201] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-30/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-30/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-30/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-30/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,218] INFO Recovering unflushed segment 0 in log __consumer_offsets-30. (kafka.log.Log) [2018-03-06 23:46:44,229] INFO Loading producer state from offset 201 for partition __consumer_offsets-30 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,229] INFO Loading producer state from snapshot file 00000000000000000201.snapshot for partition __consumer_offsets-30 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,230] INFO Completed load of log __consumer_offsets-30 with 1 log segments, log start offset 0 and log end offset 201 in 31 ms (kafka.log.Log) [2018-03-06 23:46:44,233] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/test-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/test-0/00000000000000000000.timeindex, /tmp/kafka-logs/test-0/00000000000000000000.index, and /tmp/kafka-logs/test-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,238] INFO Recovering unflushed segment 0 in log test-0. (kafka.log.Log) [2018-03-06 23:46:44,241] INFO Loading producer state from offset 4 for partition test-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,241] INFO Loading producer state from snapshot file 00000000000000000004.snapshot for partition test-0 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,242] INFO Completed load of log test-0 with 1 log segments, log start offset 0 and log end offset 4 in 9 ms (kafka.log.Log) [2018-03-06 23:46:44,245] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-46/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-46/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-46/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-46/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,247] INFO Recovering unflushed segment 0 in log __consumer_offsets-46. (kafka.log.Log) [2018-03-06 23:46:44,247] INFO Loading producer state from offset 0 for partition __consumer_offsets-46 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,248] INFO Completed load of log __consumer_offsets-46 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,252] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-27/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-27/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-27/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-27/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,260] INFO Recovering unflushed segment 0 in log __consumer_offsets-27. (kafka.log.Log) [2018-03-06 23:46:44,265] INFO Loading producer state from offset 77 for partition __consumer_offsets-27 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,266] INFO Loading producer state from snapshot file 00000000000000000077.snapshot for partition __consumer_offsets-27 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,266] INFO Completed load of log __consumer_offsets-27 with 1 log segments, log start offset 0 and log end offset 77 in 16 ms (kafka.log.Log) [2018-03-06 23:46:44,270] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-8/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-8/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-8/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-8/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,271] INFO Recovering unflushed segment 0 in log __consumer_offsets-8. (kafka.log.Log) [2018-03-06 23:46:44,272] INFO Loading producer state from offset 0 for partition __consumer_offsets-8 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,272] INFO Completed load of log __consumer_offsets-8 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,275] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-24/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-24/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-24/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-24/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,277] INFO Recovering unflushed segment 0 in log __consumer_offsets-24. (kafka.log.Log) [2018-03-06 23:46:44,277] INFO Loading producer state from offset 0 for partition __consumer_offsets-24 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,278] INFO Completed load of log __consumer_offsets-24 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,282] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-43/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-43/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-43/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-43/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,283] INFO Recovering unflushed segment 0 in log __consumer_offsets-43. (kafka.log.Log) [2018-03-06 23:46:44,284] INFO Loading producer state from offset 0 for partition __consumer_offsets-43 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,284] INFO Completed load of log __consumer_offsets-43 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,288] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-5/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-5/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-5/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-5/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,289] INFO Recovering unflushed segment 0 in log __consumer_offsets-5. (kafka.log.Log) [2018-03-06 23:46:44,290] INFO Loading producer state from offset 0 for partition __consumer_offsets-5 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,290] INFO Completed load of log __consumer_offsets-5 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,294] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-21/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-21/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-21/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-21/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,295] INFO Recovering unflushed segment 0 in log __consumer_offsets-21. (kafka.log.Log) [2018-03-06 23:46:44,296] INFO Loading producer state from offset 0 for partition __consumer_offsets-21 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,296] INFO Completed load of log __consumer_offsets-21 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,301] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-2/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-2/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-2/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-2/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,302] INFO Recovering unflushed segment 0 in log __consumer_offsets-2. (kafka.log.Log) [2018-03-06 23:46:44,303] INFO Loading producer state from offset 0 for partition __consumer_offsets-2 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,303] INFO Completed load of log __consumer_offsets-2 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,306] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-40/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-40/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-40/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-40/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,308] INFO Recovering unflushed segment 0 in log __consumer_offsets-40. (kafka.log.Log) [2018-03-06 23:46:44,308] INFO Loading producer state from offset 0 for partition __consumer_offsets-40 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,309] INFO Completed load of log __consumer_offsets-40 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,312] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-37/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-37/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-37/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-37/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,313] INFO Recovering unflushed segment 0 in log __consumer_offsets-37. (kafka.log.Log) [2018-03-06 23:46:44,315] INFO Loading producer state from offset 0 for partition __consumer_offsets-37 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,315] INFO Completed load of log __consumer_offsets-37 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,320] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-18/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-18/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-18/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-18/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,321] INFO Recovering unflushed segment 0 in log __consumer_offsets-18. (kafka.log.Log) [2018-03-06 23:46:44,322] INFO Loading producer state from offset 0 for partition __consumer_offsets-18 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,323] INFO Completed load of log __consumer_offsets-18 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,327] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/totalstats-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/totalstats-0/00000000000000000000.timeindex, /tmp/kafka-logs/totalstats-0/00000000000000000000.index, and /tmp/kafka-logs/totalstats-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,328] INFO Recovering unflushed segment 0 in log totalstats-0. (kafka.log.Log) [2018-03-06 23:46:44,329] INFO Loading producer state from offset 0 for partition totalstats-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,329] INFO Completed load of log totalstats-0 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,333] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-34/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-34/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-34/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-34/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,334] INFO Recovering unflushed segment 0 in log __consumer_offsets-34. (kafka.log.Log) [2018-03-06 23:46:44,335] INFO Loading producer state from offset 0 for partition __consumer_offsets-34 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,335] INFO Completed load of log __consumer_offsets-34 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,338] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-15/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-15/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-15/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-15/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,340] INFO Recovering unflushed segment 0 in log __consumer_offsets-15. (kafka.log.Log) [2018-03-06 23:46:44,341] INFO Loading producer state from offset 0 for partition __consumer_offsets-15 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,341] INFO Completed load of log __consumer_offsets-15 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,345] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-12/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-12/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-12/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-12/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,345] INFO Recovering unflushed segment 0 in log __consumer_offsets-12. (kafka.log.Log) [2018-03-06 23:46:44,346] INFO Loading producer state from offset 0 for partition __consumer_offsets-12 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,347] INFO Completed load of log __consumer_offsets-12 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,353] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-31/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-31/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-31/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-31/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,354] INFO Recovering unflushed segment 0 in log __consumer_offsets-31. (kafka.log.Log) [2018-03-06 23:46:44,355] INFO Loading producer state from offset 0 for partition __consumer_offsets-31 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,356] INFO Completed load of log __consumer_offsets-31 with 1 log segments, log start offset 0 and log end offset 0 in 7 ms (kafka.log.Log) [2018-03-06 23:46:44,360] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/ssids-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/ssids-0/00000000000000000000.timeindex, /tmp/kafka-logs/ssids-0/00000000000000000000.index, and /tmp/kafka-logs/ssids-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,361] INFO Recovering unflushed segment 0 in log ssids-0. (kafka.log.Log) [2018-03-06 23:46:44,362] INFO Loading producer state from offset 0 for partition ssids-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,362] INFO Completed load of log ssids-0 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,366] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-9/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-9/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-9/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-9/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,366] INFO Recovering unflushed segment 0 in log __consumer_offsets-9. (kafka.log.Log) [2018-03-06 23:46:44,367] INFO Loading producer state from offset 0 for partition __consumer_offsets-9 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,367] INFO Completed load of log __consumer_offsets-9 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,370] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-47/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-47/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-47/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-47/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,371] INFO Recovering unflushed segment 0 in log __consumer_offsets-47. (kafka.log.Log) [2018-03-06 23:46:44,371] INFO Loading producer state from offset 0 for partition __consumer_offsets-47 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,371] INFO Completed load of log __consumer_offsets-47 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,374] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-19/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-19/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-19/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-19/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,384] INFO Recovering unflushed segment 0 in log __consumer_offsets-19. (kafka.log.Log) [2018-03-06 23:46:44,388] INFO Loading producer state from offset 91 for partition __consumer_offsets-19 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,389] INFO Loading producer state from snapshot file 00000000000000000091.snapshot for partition __consumer_offsets-19 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,390] INFO Completed load of log __consumer_offsets-19 with 1 log segments, log start offset 0 and log end offset 91 in 17 ms (kafka.log.Log) [2018-03-06 23:46:44,394] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-28/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-28/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-28/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-28/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,395] INFO Recovering unflushed segment 0 in log __consumer_offsets-28. (kafka.log.Log) [2018-03-06 23:46:44,396] INFO Loading producer state from offset 0 for partition __consumer_offsets-28 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,397] INFO Completed load of log __consumer_offsets-28 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,401] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-38/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-38/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-38/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-38/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,402] INFO Recovering unflushed segment 0 in log __consumer_offsets-38. (kafka.log.Log) [2018-03-06 23:46:44,403] INFO Loading producer state from offset 0 for partition __consumer_offsets-38 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,403] INFO Completed load of log __consumer_offsets-38 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,407] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/statistics-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/statistics-0/00000000000000000000.timeindex, /tmp/kafka-logs/statistics-0/00000000000000000000.index, and /tmp/kafka-logs/statistics-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,408] INFO Recovering unflushed segment 0 in log statistics-0. (kafka.log.Log) [2018-03-06 23:46:44,409] INFO Loading producer state from offset 0 for partition statistics-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,410] INFO Completed load of log statistics-0 with 1 log segments, log start offset 0 and log end offset 0 in 6 ms (kafka.log.Log) [2018-03-06 23:46:44,413] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-35/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-35/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-35/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-35/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,414] INFO Recovering unflushed segment 0 in log __consumer_offsets-35. (kafka.log.Log) [2018-03-06 23:46:44,414] INFO Loading producer state from offset 0 for partition __consumer_offsets-35 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,415] INFO Completed load of log __consumer_offsets-35 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,418] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-44/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-44/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-44/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-44/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,419] INFO Recovering unflushed segment 0 in log __consumer_offsets-44. (kafka.log.Log) [2018-03-06 23:46:44,420] INFO Loading producer state from offset 0 for partition __consumer_offsets-44 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,420] INFO Completed load of log __consumer_offsets-44 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,423] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-6/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-6/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-6/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-6/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,430] INFO Recovering unflushed segment 0 in log __consumer_offsets-6. (kafka.log.Log) [2018-03-06 23:46:44,432] INFO Loading producer state from offset 13 for partition __consumer_offsets-6 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,433] INFO Loading producer state from snapshot file 00000000000000000013.snapshot for partition __consumer_offsets-6 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,433] INFO Completed load of log __consumer_offsets-6 with 1 log segments, log start offset 0 and log end offset 13 in 12 ms (kafka.log.Log) [2018-03-06 23:46:44,436] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-25/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-25/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-25/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-25/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,437] INFO Recovering unflushed segment 0 in log __consumer_offsets-25. (kafka.log.Log) [2018-03-06 23:46:44,437] INFO Loading producer state from offset 0 for partition __consumer_offsets-25 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,438] INFO Completed load of log __consumer_offsets-25 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,441] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/cpes-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/cpes-0/00000000000000000000.timeindex, /tmp/kafka-logs/cpes-0/00000000000000000000.index, and /tmp/kafka-logs/cpes-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,441] INFO Recovering unflushed segment 0 in log cpes-0. (kafka.log.Log) [2018-03-06 23:46:44,442] INFO Loading producer state from offset 0 for partition cpes-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,442] INFO Completed load of log cpes-0 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,445] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-16/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-16/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-16/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-16/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,446] INFO Recovering unflushed segment 0 in log __consumer_offsets-16. (kafka.log.Log) [2018-03-06 23:46:44,446] INFO Loading producer state from offset 0 for partition __consumer_offsets-16 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,447] INFO Completed load of log __consumer_offsets-16 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,450] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-22/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-22/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-22/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-22/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,451] INFO Recovering unflushed segment 0 in log __consumer_offsets-22. (kafka.log.Log) [2018-03-06 23:46:44,451] INFO Loading producer state from offset 0 for partition __consumer_offsets-22 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,452] INFO Completed load of log __consumer_offsets-22 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,454] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-41/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-41/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-41/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-41/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,455] INFO Recovering unflushed segment 0 in log __consumer_offsets-41. (kafka.log.Log) [2018-03-06 23:46:44,456] INFO Loading producer state from offset 0 for partition __consumer_offsets-41 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,456] INFO Completed load of log __consumer_offsets-41 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,459] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-32/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-32/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-32/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-32/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,460] INFO Recovering unflushed segment 0 in log __consumer_offsets-32. (kafka.log.Log) [2018-03-06 23:46:44,460] INFO Loading producer state from offset 0 for partition __consumer_offsets-32 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,461] INFO Completed load of log __consumer_offsets-32 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,464] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-3/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-3/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-3/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-3/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,464] INFO Recovering unflushed segment 0 in log __consumer_offsets-3. (kafka.log.Log) [2018-03-06 23:46:44,465] INFO Loading producer state from offset 0 for partition __consumer_offsets-3 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,466] INFO Completed load of log __consumer_offsets-3 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,469] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__consumer_offsets-13/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__consumer_offsets-13/00000000000000000000.timeindex, /tmp/kafka-logs/__consumer_offsets-13/00000000000000000000.index, and /tmp/kafka-logs/__consumer_offsets-13/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,470] INFO Recovering unflushed segment 0 in log __consumer_offsets-13. (kafka.log.Log) [2018-03-06 23:46:44,471] INFO Loading producer state from offset 0 for partition __consumer_offsets-13 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,471] INFO Completed load of log __consumer_offsets-13 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,474] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/test1-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/test1-0/00000000000000000000.timeindex, /tmp/kafka-logs/test1-0/00000000000000000000.index, and /tmp/kafka-logs/test1-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,475] INFO Recovering unflushed segment 0 in log test1-0. (kafka.log.Log) [2018-03-06 23:46:44,476] INFO Loading producer state from offset 0 for partition test1-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,476] INFO Completed load of log test1-0 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,480] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/casa-cable_modem-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/casa-cable_modem-0/00000000000000000000.timeindex, /tmp/kafka-logs/casa-cable_modem-0/00000000000000000000.index, and /tmp/kafka-logs/casa-cable_modem-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,481] INFO Recovering unflushed segment 0 in log casa-cable_modem-0. (kafka.log.Log) [2018-03-06 23:46:44,483] INFO Loading producer state from offset 0 for partition casa-cable_modem-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,483] INFO Completed load of log casa-cable_modem-0 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,487] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/casa_cable_modem-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/casa_cable_modem-0/00000000000000000000.timeindex, /tmp/kafka-logs/casa_cable_modem-0/00000000000000000000.index, and /tmp/kafka-logs/casa_cable_modem-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,519] INFO Recovering unflushed segment 0 in log casa_cable_modem-0. (kafka.log.Log) [2018-03-06 23:46:44,525] INFO Loading producer state from offset 4 for partition casa_cable_modem-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,526] INFO Loading producer state from snapshot file 00000000000000000004.snapshot for partition casa_cable_modem-0 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,526] INFO Completed load of log casa_cable_modem-0 with 1 log segments, log start offset 0 and log end offset 4 in 41 ms (kafka.log.Log) [2018-03-06 23:46:44,530] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-25/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-25/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-25/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-25/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,531] INFO Recovering unflushed segment 0 in log __transaction_state-25. (kafka.log.Log) [2018-03-06 23:46:44,532] INFO Loading producer state from offset 0 for partition __transaction_state-25 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,532] INFO Completed load of log __transaction_state-25 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,535] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-44/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-44/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-44/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-44/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,536] INFO Recovering unflushed segment 0 in log __transaction_state-44. (kafka.log.Log) [2018-03-06 23:46:44,536] INFO Loading producer state from offset 0 for partition __transaction_state-44 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,537] INFO Completed load of log __transaction_state-44 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,539] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-6/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-6/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-6/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-6/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,540] INFO Recovering unflushed segment 0 in log __transaction_state-6. (kafka.log.Log) [2018-03-06 23:46:44,541] INFO Loading producer state from offset 0 for partition __transaction_state-6 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,541] INFO Completed load of log __transaction_state-6 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,545] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-41/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-41/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-41/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-41/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,547] INFO Recovering unflushed segment 0 in log __transaction_state-41. (kafka.log.Log) [2018-03-06 23:46:44,548] INFO Loading producer state from offset 0 for partition __transaction_state-41 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,549] INFO Completed load of log __transaction_state-41 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,552] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-3/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-3/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-3/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-3/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,553] INFO Recovering unflushed segment 0 in log __transaction_state-3. (kafka.log.Log) [2018-03-06 23:46:44,553] INFO Loading producer state from offset 0 for partition __transaction_state-3 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,554] INFO Completed load of log __transaction_state-3 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,558] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-22/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-22/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-22/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-22/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,559] INFO Recovering unflushed segment 0 in log __transaction_state-22. (kafka.log.Log) [2018-03-06 23:46:44,560] INFO Loading producer state from offset 0 for partition __transaction_state-22 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,561] INFO Completed load of log __transaction_state-22 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,564] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-0/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-0/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-0/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-0/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,565] INFO Recovering unflushed segment 0 in log __transaction_state-0. (kafka.log.Log) [2018-03-06 23:46:44,565] INFO Loading producer state from offset 0 for partition __transaction_state-0 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,566] INFO Completed load of log __transaction_state-0 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,568] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-38/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-38/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-38/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-38/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,569] INFO Recovering unflushed segment 0 in log __transaction_state-38. (kafka.log.Log) [2018-03-06 23:46:44,569] INFO Loading producer state from offset 0 for partition __transaction_state-38 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,570] INFO Completed load of log __transaction_state-38 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,572] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-19/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-19/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-19/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-19/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,573] INFO Recovering unflushed segment 0 in log __transaction_state-19. (kafka.log.Log) [2018-03-06 23:46:44,573] INFO Loading producer state from offset 0 for partition __transaction_state-19 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,573] INFO Completed load of log __transaction_state-19 with 1 log segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [2018-03-06 23:46:44,576] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-16/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-16/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-16/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-16/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,576] INFO Recovering unflushed segment 0 in log __transaction_state-16. (kafka.log.Log) [2018-03-06 23:46:44,577] INFO Loading producer state from offset 0 for partition __transaction_state-16 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,577] INFO Completed load of log __transaction_state-16 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,579] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-35/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-35/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-35/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-35/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,580] INFO Recovering unflushed segment 0 in log __transaction_state-35. (kafka.log.Log) [2018-03-06 23:46:44,580] INFO Loading producer state from offset 0 for partition __transaction_state-35 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,581] INFO Completed load of log __transaction_state-35 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,583] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-13/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-13/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-13/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-13/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,584] INFO Recovering unflushed segment 0 in log __transaction_state-13. (kafka.log.Log) [2018-03-06 23:46:44,585] INFO Loading producer state from offset 0 for partition __transaction_state-13 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,586] INFO Completed load of log __transaction_state-13 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,590] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-32/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-32/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-32/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-32/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,591] INFO Recovering unflushed segment 0 in log __transaction_state-32. (kafka.log.Log) [2018-03-06 23:46:44,591] INFO Loading producer state from offset 0 for partition __transaction_state-32 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,591] INFO Completed load of log __transaction_state-32 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,594] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-48/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-48/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-48/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-48/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,595] INFO Recovering unflushed segment 0 in log __transaction_state-48. (kafka.log.Log) [2018-03-06 23:46:44,595] INFO Loading producer state from offset 0 for partition __transaction_state-48 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,596] INFO Completed load of log __transaction_state-48 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,601] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-29/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-29/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-29/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-29/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,603] INFO Recovering unflushed segment 0 in log __transaction_state-29. (kafka.log.Log) [2018-03-06 23:46:44,604] INFO Loading producer state from offset 0 for partition __transaction_state-29 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,604] INFO Completed load of log __transaction_state-29 with 1 log segments, log start offset 0 and log end offset 0 in 7 ms (kafka.log.Log) [2018-03-06 23:46:44,611] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-10/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-10/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-10/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-10/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,612] INFO Recovering unflushed segment 0 in log __transaction_state-10. (kafka.log.Log) [2018-03-06 23:46:44,612] INFO Loading producer state from offset 0 for partition __transaction_state-10 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,612] INFO Completed load of log __transaction_state-10 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,615] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-7/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-7/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-7/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-7/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,616] INFO Recovering unflushed segment 0 in log __transaction_state-7. (kafka.log.Log) [2018-03-06 23:46:44,616] INFO Loading producer state from offset 0 for partition __transaction_state-7 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,617] INFO Completed load of log __transaction_state-7 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,619] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-26/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-26/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-26/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-26/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,620] INFO Recovering unflushed segment 0 in log __transaction_state-26. (kafka.log.Log) [2018-03-06 23:46:44,621] INFO Loading producer state from offset 0 for partition __transaction_state-26 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,621] INFO Completed load of log __transaction_state-26 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,624] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-45/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-45/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-45/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-45/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,627] INFO Recovering unflushed segment 0 in log __transaction_state-45. (kafka.log.Log) [2018-03-06 23:46:44,629] INFO Loading producer state from offset 1 for partition __transaction_state-45 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,630] INFO Loading producer state from snapshot file 00000000000000000001.snapshot for partition __transaction_state-45 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,631] INFO Completed load of log __transaction_state-45 with 1 log segments, log start offset 0 and log end offset 1 in 8 ms (kafka.log.Log) [2018-03-06 23:46:44,634] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-23/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-23/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-23/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-23/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,635] INFO Recovering unflushed segment 0 in log __transaction_state-23. (kafka.log.Log) [2018-03-06 23:46:44,636] INFO Loading producer state from offset 0 for partition __transaction_state-23 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,636] INFO Completed load of log __transaction_state-23 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,643] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-42/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-42/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-42/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-42/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,644] INFO Recovering unflushed segment 0 in log __transaction_state-42. (kafka.log.Log) [2018-03-06 23:46:44,644] INFO Loading producer state from offset 0 for partition __transaction_state-42 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,645] INFO Completed load of log __transaction_state-42 with 1 log segments, log start offset 0 and log end offset 0 in 7 ms (kafka.log.Log) [2018-03-06 23:46:44,649] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-4/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-4/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-4/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-4/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,650] INFO Recovering unflushed segment 0 in log __transaction_state-4. (kafka.log.Log) [2018-03-06 23:46:44,650] INFO Loading producer state from offset 0 for partition __transaction_state-4 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,651] INFO Completed load of log __transaction_state-4 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,654] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-39/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-39/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-39/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-39/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,656] INFO Recovering unflushed segment 0 in log __transaction_state-39. (kafka.log.Log) [2018-03-06 23:46:44,656] INFO Loading producer state from offset 0 for partition __transaction_state-39 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,657] INFO Completed load of log __transaction_state-39 with 1 log segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [2018-03-06 23:46:44,661] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-1/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-1/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-1/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-1/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,662] INFO Recovering unflushed segment 0 in log __transaction_state-1. (kafka.log.Log) [2018-03-06 23:46:44,662] INFO Loading producer state from offset 0 for partition __transaction_state-1 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,663] INFO Completed load of log __transaction_state-1 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,665] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-20/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-20/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-20/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-20/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,666] INFO Recovering unflushed segment 0 in log __transaction_state-20. (kafka.log.Log) [2018-03-06 23:46:44,667] INFO Loading producer state from offset 0 for partition __transaction_state-20 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,667] INFO Completed load of log __transaction_state-20 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,669] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-17/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-17/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-17/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-17/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,670] INFO Recovering unflushed segment 0 in log __transaction_state-17. (kafka.log.Log) [2018-03-06 23:46:44,671] INFO Loading producer state from offset 0 for partition __transaction_state-17 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,671] INFO Completed load of log __transaction_state-17 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,674] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-36/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-36/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-36/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-36/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,689] INFO Recovering unflushed segment 0 in log __transaction_state-36. (kafka.log.Log) [2018-03-06 23:46:44,690] INFO Loading producer state from offset 0 for partition __transaction_state-36 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,690] INFO Completed load of log __transaction_state-36 with 1 log segments, log start offset 0 and log end offset 0 in 18 ms (kafka.log.Log) [2018-03-06 23:46:44,693] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-33/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-33/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-33/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-33/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,694] INFO Recovering unflushed segment 0 in log __transaction_state-33. (kafka.log.Log) [2018-03-06 23:46:44,694] INFO Loading producer state from offset 0 for partition __transaction_state-33 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,695] INFO Completed load of log __transaction_state-33 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,697] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-14/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-14/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-14/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-14/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,698] INFO Recovering unflushed segment 0 in log __transaction_state-14. (kafka.log.Log) [2018-03-06 23:46:44,699] INFO Loading producer state from offset 0 for partition __transaction_state-14 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,699] INFO Completed load of log __transaction_state-14 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,702] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-30/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-30/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-30/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-30/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,706] INFO Recovering unflushed segment 0 in log __transaction_state-30. (kafka.log.Log) [2018-03-06 23:46:44,708] INFO Loading producer state from offset 1 for partition __transaction_state-30 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,708] INFO Loading producer state from snapshot file 00000000000000000001.snapshot for partition __transaction_state-30 (kafka.log.ProducerStateManager) [2018-03-06 23:46:44,709] INFO Completed load of log __transaction_state-30 with 1 log segments, log start offset 0 and log end offset 1 in 8 ms (kafka.log.Log) [2018-03-06 23:46:44,712] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-49/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-49/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-49/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-49/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,712] INFO Recovering unflushed segment 0 in log __transaction_state-49. (kafka.log.Log) [2018-03-06 23:46:44,713] INFO Loading producer state from offset 0 for partition __transaction_state-49 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,713] INFO Completed load of log __transaction_state-49 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,716] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-11/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-11/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-11/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-11/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,717] INFO Recovering unflushed segment 0 in log __transaction_state-11. (kafka.log.Log) [2018-03-06 23:46:44,717] INFO Loading producer state from offset 0 for partition __transaction_state-11 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,718] INFO Completed load of log __transaction_state-11 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,722] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-46/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-46/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-46/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-46/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,724] INFO Recovering unflushed segment 0 in log __transaction_state-46. (kafka.log.Log) [2018-03-06 23:46:44,725] INFO Loading producer state from offset 0 for partition __transaction_state-46 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,726] INFO Completed load of log __transaction_state-46 with 1 log segments, log start offset 0 and log end offset 0 in 6 ms (kafka.log.Log) [2018-03-06 23:46:44,731] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-18/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-18/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-18/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-18/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,732] INFO Recovering unflushed segment 0 in log __transaction_state-18. (kafka.log.Log) [2018-03-06 23:46:44,732] INFO Loading producer state from offset 0 for partition __transaction_state-18 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,732] INFO Completed load of log __transaction_state-18 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,735] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-8/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-8/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-8/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-8/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,736] INFO Recovering unflushed segment 0 in log __transaction_state-8. (kafka.log.Log) [2018-03-06 23:46:44,737] INFO Loading producer state from offset 0 for partition __transaction_state-8 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,737] INFO Completed load of log __transaction_state-8 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,740] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-27/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-27/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-27/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-27/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,741] INFO Recovering unflushed segment 0 in log __transaction_state-27. (kafka.log.Log) [2018-03-06 23:46:44,741] INFO Loading producer state from offset 0 for partition __transaction_state-27 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,742] INFO Completed load of log __transaction_state-27 with 1 log segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [2018-03-06 23:46:44,744] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-37/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-37/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-37/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-37/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,745] INFO Recovering unflushed segment 0 in log __transaction_state-37. (kafka.log.Log) [2018-03-06 23:46:44,745] INFO Loading producer state from offset 0 for partition __transaction_state-37 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,745] INFO Completed load of log __transaction_state-37 with 1 log segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [2018-03-06 23:46:44,748] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-5/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-5/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-5/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-5/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,748] INFO Recovering unflushed segment 0 in log __transaction_state-5. (kafka.log.Log) [2018-03-06 23:46:44,749] INFO Loading producer state from offset 0 for partition __transaction_state-5 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,749] INFO Completed load of log __transaction_state-5 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,751] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-15/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-15/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-15/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-15/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,752] INFO Recovering unflushed segment 0 in log __transaction_state-15. (kafka.log.Log) [2018-03-06 23:46:44,752] INFO Loading producer state from offset 0 for partition __transaction_state-15 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,753] INFO Completed load of log __transaction_state-15 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,755] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-34/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-34/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-34/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-34/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,755] INFO Recovering unflushed segment 0 in log __transaction_state-34. (kafka.log.Log) [2018-03-06 23:46:44,756] INFO Loading producer state from offset 0 for partition __transaction_state-34 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,756] INFO Completed load of log __transaction_state-34 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,759] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-24/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-24/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-24/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-24/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,759] INFO Recovering unflushed segment 0 in log __transaction_state-24. (kafka.log.Log) [2018-03-06 23:46:44,760] INFO Loading producer state from offset 0 for partition __transaction_state-24 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,760] INFO Completed load of log __transaction_state-24 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,762] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-43/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-43/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-43/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-43/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,763] INFO Recovering unflushed segment 0 in log __transaction_state-43. (kafka.log.Log) [2018-03-06 23:46:44,764] INFO Loading producer state from offset 0 for partition __transaction_state-43 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,764] INFO Completed load of log __transaction_state-43 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,766] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-40/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-40/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-40/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-40/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,767] INFO Recovering unflushed segment 0 in log __transaction_state-40. (kafka.log.Log) [2018-03-06 23:46:44,767] INFO Loading producer state from offset 0 for partition __transaction_state-40 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,767] INFO Completed load of log __transaction_state-40 with 1 log segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [2018-03-06 23:46:44,769] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-2/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-2/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-2/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-2/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,770] INFO Recovering unflushed segment 0 in log __transaction_state-2. (kafka.log.Log) [2018-03-06 23:46:44,770] INFO Loading producer state from offset 0 for partition __transaction_state-2 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,771] INFO Completed load of log __transaction_state-2 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,773] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-31/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-31/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-31/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-31/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,774] INFO Recovering unflushed segment 0 in log __transaction_state-31. (kafka.log.Log) [2018-03-06 23:46:44,774] INFO Loading producer state from offset 0 for partition __transaction_state-31 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,774] INFO Completed load of log __transaction_state-31 with 1 log segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [2018-03-06 23:46:44,776] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-21/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-21/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-21/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-21/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,777] INFO Recovering unflushed segment 0 in log __transaction_state-21. (kafka.log.Log) [2018-03-06 23:46:44,777] INFO Loading producer state from offset 0 for partition __transaction_state-21 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,778] INFO Completed load of log __transaction_state-21 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,780] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-12/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-12/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-12/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-12/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,780] INFO Recovering unflushed segment 0 in log __transaction_state-12. (kafka.log.Log) [2018-03-06 23:46:44,781] INFO Loading producer state from offset 0 for partition __transaction_state-12 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,781] INFO Completed load of log __transaction_state-12 with 1 log segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [2018-03-06 23:46:44,784] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-28/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-28/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-28/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-28/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,784] INFO Recovering unflushed segment 0 in log __transaction_state-28. (kafka.log.Log) [2018-03-06 23:46:44,785] INFO Loading producer state from offset 0 for partition __transaction_state-28 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,785] INFO Completed load of log __transaction_state-28 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,787] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-47/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-47/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-47/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-47/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,788] INFO Recovering unflushed segment 0 in log __transaction_state-47. (kafka.log.Log) [2018-03-06 23:46:44,788] INFO Loading producer state from offset 0 for partition __transaction_state-47 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,789] INFO Completed load of log __transaction_state-47 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,791] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (/tmp/kafka-logs/__transaction_state-9/00000000000000000000.index) has non-zero size but the last offset is 0 which is no larger than the base offset 0.}. deleting /tmp/kafka-logs/__transaction_state-9/00000000000000000000.timeindex, /tmp/kafka-logs/__transaction_state-9/00000000000000000000.index, and /tmp/kafka-logs/__transaction_state-9/00000000000000000000.txnindex and rebuilding index... (kafka.log.Log) [2018-03-06 23:46:44,792] INFO Recovering unflushed segment 0 in log __transaction_state-9. (kafka.log.Log) [2018-03-06 23:46:44,792] INFO Loading producer state from offset 0 for partition __transaction_state-9 with message format version 2 (kafka.log.Log) [2018-03-06 23:46:44,792] INFO Completed load of log __transaction_state-9 with 1 log segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [2018-03-06 23:46:44,794] INFO Logs loading complete in 935 ms. (kafka.log.LogManager) [2018-03-06 23:46:44,903] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) [2018-03-06 23:46:44,904] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) [2018-03-06 23:46:44,944] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor) [2018-03-06 23:46:44,947] INFO [Socket Server on Broker 0], Started 1 acceptor threads (kafka.network.SocketServer) [2018-03-06 23:46:44,961] INFO [ExpirationReaper-0-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2018-03-06 23:46:44,961] INFO [ExpirationReaper-0-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2018-03-06 23:46:44,962] INFO [ExpirationReaper-0-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2018-03-06 23:46:45,006] INFO [ExpirationReaper-0-topic]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2018-03-06 23:46:45,009] INFO [ExpirationReaper-0-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2018-03-06 23:46:45,009] INFO [ExpirationReaper-0-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2018-03-06 23:46:45,018] INFO Creating /controller (is it secure? false) (kafka.utils.ZKCheckedEphemeral) [2018-03-06 23:46:45,027] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral) [2018-03-06 23:46:45,082] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.group.GroupCoordinator) [2018-03-06 23:46:45,088] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.group.GroupCoordinator) [2018-03-06 23:46:45,090] INFO [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 3 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:45,121] INFO [ProducerId Manager 0]: Acquired new producerId block (brokerId:0,blockStartProducerId:16000,blockEndProducerId:16999) by writing to Zk with path version 17 (kafka.coordinator.transaction.ProducerIdManager) [2018-03-06 23:46:45,163] INFO [Transaction Coordinator 0]: Starting up. (kafka.coordinator.transaction.TransactionCoordinator) [2018-03-06 23:46:45,165] INFO [Transaction Marker Channel Manager 0]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2018-03-06 23:46:45,165] INFO [Transaction Coordinator 0]: Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) [2018-03-06 23:46:45,196] INFO Will not load MX4J, mx4j-tools.jar is not in the classpath (kafka.utils.Mx4jLoader$) [2018-03-06 23:46:45,316] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.utils.ZKCheckedEphemeral) [2018-03-06 23:46:45,321] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral) [2018-03-06 23:46:45,323] INFO Registered broker 0 at path /brokers/ids/0 with addresses: EndPoint(localhost,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.utils.ZkUtils) [2018-03-06 23:46:45,326] INFO Kafka version : 0.11.0.0 (org.apache.kafka.common.utils.AppInfoParser) [2018-03-06 23:46:45,326] INFO Kafka commitId : cb8625948210849f (org.apache.kafka.common.utils.AppInfoParser) [2018-03-06 23:46:45,327] INFO [Kafka Server 0], started (kafka.server.KafkaServer) [2018-03-06 23:46:46,284] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions __consumer_offsets-22,__transaction_state-42,__consumer_offsets-30,__transaction_state-31,__transaction_state-45,cpes-0,__transaction_state-15,__transaction_state-12,__consumer_offsets-8,__consumer_offsets-21,__consumer_offsets-4,__transaction_state-7,__transaction_state-46,__consumer_offsets-27,__consumer_offsets-7,casa_cable_modem-0,__transaction_state-48,__consumer_offsets-9,cablemodem-0,__transaction_state-49,__consumer_offsets-46,__consumer_offsets-25,__consumer_offsets-35,__transaction_state-28,__transaction_state-2,__transaction_state-20,getId-0,__transaction_state-24,__consumer_offsets-41,__consumer_offsets-33,__consumer_offsets-23,__transaction_state-13,__consumer_offsets-49,mac_addr-0,putId-0,__transaction_state-0,__consumer_offsets-47,__consumer_offsets-16,test-0,neighbour-ssids-0,__consumer_offsets-28,__transaction_state-37,__transaction_state-3,__consumer_offsets-31,__transaction_state-21,__consumer_offsets-36,__transaction_state-29,__consumer_offsets-42,__consumer_offsets-3,__consumer_offsets-18,__transaction_state-39,test1-0,__consumer_offsets-37,__transaction_state-38,totalstats-0,__consumer_offsets-15,__consumer_offsets-24,__transaction_state-6,statistics-0,ssids-0,__transaction_state-14,__transaction_state-10,__transaction_state-44,__transaction_state-9,__transaction_state-22,__transaction_state-43,__transaction_state-4,__transaction_state-30,__transaction_state-33,__consumer_offsets-38,__consumer_offsets-17,__transaction_state-32,__consumer_offsets-48,__transaction_state-25,__transaction_state-17,__consumer_offsets-19,__consumer_offsets-11,__transaction_state-23,__transaction_state-47,__consumer_offsets-13,__consumer_offsets-2,__consumer_offsets-43,__consumer_offsets-6,__consumer_offsets-14,__transaction_state-18,__transaction_state-26,__transaction_state-36,__transaction_state-5,__transaction_state-8,__consumer_offsets-20,__transaction_state-16,__consumer_offsets-0,__consumer_offsets-44,casa-cable_modem-0,__transaction_state-11,__consumer_offsets-39,__consumer_offsets-12,__transaction_state-40,__consumer_offsets-45,__consumer_offsets-1,__consumer_offsets-5,__consumer_offsets-26,__transaction_state-19,__transaction_state-27,__consumer_offsets-29,__transaction_state-41,__consumer_offsets-34,__transaction_state-1,__consumer_offsets-10,__consumer_offsets-32,__transaction_state-34,__transaction_state-35,__consumer_offsets-40 (kafka.server.ReplicaFetcherManager) [2018-03-06 23:46:46,295] INFO Partition [getId,0] on broker 0: getId-0 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,304] INFO Partition [__consumer_offsets,0] on broker 0: __consumer_offsets-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,310] INFO Partition [__consumer_offsets,48] on broker 0: __consumer_offsets-48 starts at Leader Epoch 15 from offset 16. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,314] INFO Partition [__consumer_offsets,29] on broker 0: __consumer_offsets-29 starts at Leader Epoch 15 from offset 6. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,318] INFO Partition [__transaction_state,25] on broker 0: __transaction_state-25 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,322] INFO Partition [__transaction_state,44] on broker 0: __transaction_state-44 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,326] INFO Partition [__transaction_state,6] on broker 0: __transaction_state-6 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,329] INFO Partition [__consumer_offsets,10] on broker 0: __consumer_offsets-10 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,332] INFO Partition [__consumer_offsets,45] on broker 0: __consumer_offsets-45 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,336] INFO Partition [__transaction_state,3] on broker 0: __transaction_state-3 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,340] INFO Partition [__transaction_state,41] on broker 0: __transaction_state-41 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,345] INFO Partition [__transaction_state,22] on broker 0: __transaction_state-22 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,348] INFO Partition [__consumer_offsets,26] on broker 0: __consumer_offsets-26 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,350] INFO Partition [test1,0] on broker 0: test1-0 starts at Leader Epoch 7 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,353] INFO Partition [__consumer_offsets,7] on broker 0: __consumer_offsets-7 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,357] INFO Partition [__consumer_offsets,42] on broker 0: __consumer_offsets-42 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,359] INFO Partition [casa_cable_modem,0] on broker 0: casa_cable_modem-0 starts at Leader Epoch 7 from offset 4. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,363] INFO Partition [__transaction_state,0] on broker 0: __transaction_state-0 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,367] INFO Partition [__transaction_state,38] on broker 0: __transaction_state-38 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,369] INFO Partition [mac_addr,0] on broker 0: mac_addr-0 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,372] INFO Partition [__consumer_offsets,4] on broker 0: __consumer_offsets-4 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,375] INFO Partition [__consumer_offsets,23] on broker 0: __consumer_offsets-23 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,380] INFO Partition [__transaction_state,19] on broker 0: __transaction_state-19 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,384] INFO Partition [__transaction_state,35] on broker 0: __transaction_state-35 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,388] INFO Partition [__transaction_state,16] on broker 0: __transaction_state-16 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,391] INFO Partition [__consumer_offsets,1] on broker 0: __consumer_offsets-1 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,395] INFO Partition [__consumer_offsets,39] on broker 0: __consumer_offsets-39 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,399] INFO Partition [__consumer_offsets,20] on broker 0: __consumer_offsets-20 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,401] INFO Partition [putId,0] on broker 0: putId-0 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,404] INFO Partition [__consumer_offsets,17] on broker 0: __consumer_offsets-17 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,407] INFO Partition [__consumer_offsets,36] on broker 0: __consumer_offsets-36 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,411] INFO Partition [__transaction_state,13] on broker 0: __transaction_state-13 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,415] INFO Partition [__transaction_state,32] on broker 0: __transaction_state-32 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,419] INFO Partition [__transaction_state,48] on broker 0: __transaction_state-48 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,423] INFO Partition [__consumer_offsets,14] on broker 0: __consumer_offsets-14 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,426] INFO Partition [__transaction_state,29] on broker 0: __transaction_state-29 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,430] INFO Partition [__transaction_state,10] on broker 0: __transaction_state-10 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,433] INFO Partition [__consumer_offsets,33] on broker 0: __consumer_offsets-33 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,438] INFO Partition [__transaction_state,7] on broker 0: __transaction_state-7 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,440] INFO Partition [cablemodem,0] on broker 0: cablemodem-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,443] INFO Partition [__transaction_state,45] on broker 0: __transaction_state-45 starts at Leader Epoch 5 from offset 1. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,445] INFO Partition [neighbour-ssids,0] on broker 0: neighbour-ssids-0 starts at Leader Epoch 13 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,448] INFO Partition [__transaction_state,26] on broker 0: __transaction_state-26 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,451] INFO Partition [__consumer_offsets,49] on broker 0: __consumer_offsets-49 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,455] INFO Partition [__consumer_offsets,11] on broker 0: __consumer_offsets-11 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,457] INFO Partition [__consumer_offsets,30] on broker 0: __consumer_offsets-30 starts at Leader Epoch 15 from offset 201. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,459] INFO Partition [test,0] on broker 0: test-0 starts at Leader Epoch 13 from offset 4. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,462] INFO Partition [__transaction_state,23] on broker 0: __transaction_state-23 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,464] INFO Partition [__consumer_offsets,46] on broker 0: __consumer_offsets-46 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,467] INFO Partition [__consumer_offsets,27] on broker 0: __consumer_offsets-27 starts at Leader Epoch 15 from offset 77. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,470] INFO Partition [__transaction_state,42] on broker 0: __transaction_state-42 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,474] INFO Partition [__transaction_state,4] on broker 0: __transaction_state-4 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,476] INFO Partition [__consumer_offsets,8] on broker 0: __consumer_offsets-8 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,480] INFO Partition [__consumer_offsets,24] on broker 0: __consumer_offsets-24 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,483] INFO Partition [__consumer_offsets,43] on broker 0: __consumer_offsets-43 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,485] INFO Partition [__transaction_state,1] on broker 0: __transaction_state-1 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,489] INFO Partition [__transaction_state,39] on broker 0: __transaction_state-39 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,492] INFO Partition [__consumer_offsets,5] on broker 0: __consumer_offsets-5 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,495] INFO Partition [__transaction_state,20] on broker 0: __transaction_state-20 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,498] INFO Partition [__transaction_state,17] on broker 0: __transaction_state-17 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,501] INFO Partition [__transaction_state,36] on broker 0: __transaction_state-36 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,518] INFO Partition [__consumer_offsets,21] on broker 0: __consumer_offsets-21 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,520] INFO Partition [__consumer_offsets,40] on broker 0: __consumer_offsets-40 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,522] INFO Partition [__consumer_offsets,2] on broker 0: __consumer_offsets-2 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,524] INFO Partition [__consumer_offsets,37] on broker 0: __consumer_offsets-37 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,527] INFO Partition [__transaction_state,33] on broker 0: __transaction_state-33 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,528] INFO Partition [__consumer_offsets,18] on broker 0: __consumer_offsets-18 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,531] INFO Partition [__transaction_state,14] on broker 0: __transaction_state-14 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,532] INFO Partition [totalstats,0] on broker 0: totalstats-0 starts at Leader Epoch 13 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,534] INFO Partition [__transaction_state,30] on broker 0: __transaction_state-30 starts at Leader Epoch 5 from offset 1. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,537] INFO Partition [__consumer_offsets,15] on broker 0: __consumer_offsets-15 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,538] INFO Partition [__consumer_offsets,34] on broker 0: __consumer_offsets-34 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,540] INFO Partition [__transaction_state,49] on broker 0: __transaction_state-49 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,543] INFO Partition [__transaction_state,11] on broker 0: __transaction_state-11 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,544] INFO Partition [__consumer_offsets,12] on broker 0: __consumer_offsets-12 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,546] INFO Partition [__transaction_state,46] on broker 0: __transaction_state-46 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,548] INFO Partition [__consumer_offsets,31] on broker 0: __consumer_offsets-31 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,550] INFO Partition [__transaction_state,18] on broker 0: __transaction_state-18 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,552] INFO Partition [__transaction_state,27] on broker 0: __transaction_state-27 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,554] INFO Partition [__transaction_state,8] on broker 0: __transaction_state-8 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,556] INFO Partition [casa-cable_modem,0] on broker 0: casa-cable_modem-0 starts at Leader Epoch 7 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,557] INFO Partition [__transaction_state,37] on broker 0: __transaction_state-37 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,559] INFO Partition [ssids,0] on broker 0: ssids-0 starts at Leader Epoch 13 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,560] INFO Partition [__consumer_offsets,9] on broker 0: __consumer_offsets-9 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,562] INFO Partition [__consumer_offsets,47] on broker 0: __consumer_offsets-47 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,564] INFO Partition [__consumer_offsets,19] on broker 0: __consumer_offsets-19 starts at Leader Epoch 15 from offset 91. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,566] INFO Partition [__transaction_state,5] on broker 0: __transaction_state-5 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,568] INFO Partition [__consumer_offsets,28] on broker 0: __consumer_offsets-28 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,570] INFO Partition [__transaction_state,15] on broker 0: __transaction_state-15 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,572] INFO Partition [statistics,0] on broker 0: statistics-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,574] INFO Partition [__transaction_state,34] on broker 0: __transaction_state-34 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,576] INFO Partition [__consumer_offsets,38] on broker 0: __consumer_offsets-38 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,580] INFO Partition [__transaction_state,43] on broker 0: __transaction_state-43 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,586] INFO Partition [__transaction_state,24] on broker 0: __transaction_state-24 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,589] INFO Partition [__consumer_offsets,35] on broker 0: __consumer_offsets-35 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,592] INFO Partition [__transaction_state,2] on broker 0: __transaction_state-2 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,595] INFO Partition [__transaction_state,40] on broker 0: __transaction_state-40 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,597] INFO Partition [__transaction_state,31] on broker 0: __transaction_state-31 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,599] INFO Partition [__consumer_offsets,44] on broker 0: __consumer_offsets-44 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,601] INFO Partition [__consumer_offsets,6] on broker 0: __consumer_offsets-6 starts at Leader Epoch 15 from offset 13. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,603] INFO Partition [__consumer_offsets,25] on broker 0: __consumer_offsets-25 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,604] INFO Partition [cpes,0] on broker 0: cpes-0 starts at Leader Epoch 13 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,607] INFO Partition [__transaction_state,12] on broker 0: __transaction_state-12 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,609] INFO Partition [__consumer_offsets,16] on broker 0: __consumer_offsets-16 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,611] INFO Partition [__transaction_state,21] on broker 0: __transaction_state-21 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,616] INFO Partition [__consumer_offsets,22] on broker 0: __consumer_offsets-22 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,618] INFO Partition [__consumer_offsets,41] on broker 0: __consumer_offsets-41 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,620] INFO Partition [__transaction_state,28] on broker 0: __transaction_state-28 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,622] INFO Partition [__consumer_offsets,32] on broker 0: __consumer_offsets-32 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,624] INFO Partition [__consumer_offsets,3] on broker 0: __consumer_offsets-3 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,627] INFO Partition [__transaction_state,9] on broker 0: __transaction_state-9 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,630] INFO Partition [__transaction_state,47] on broker 0: __transaction_state-47 starts at Leader Epoch 5 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,632] INFO Partition [__consumer_offsets,13] on broker 0: __consumer_offsets-13 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2018-03-06 23:46:46,640] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,641] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,641] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-37 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,641] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-43 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,648] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-25 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,649] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-31 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,649] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-37 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,649] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-43 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,654] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,654] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-49 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,655] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-4 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,660] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-10 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,665] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-16 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,671] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-22 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,676] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-28 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,681] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,682] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-34 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,682] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-44 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,687] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-5 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,691] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-11 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,697] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-17 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,702] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-23 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,707] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-29 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,712] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,712] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-35 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,712] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-1 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,717] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,717] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-41 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,717] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-7 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,721] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,721] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,722] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-13 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,722] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-47 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,732] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-24 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,738] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-30 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,744] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,749] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,751] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-19 in 29 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,751] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-2 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,751] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-8 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-14 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-20 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-26 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-32 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-38 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-3 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,755] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-9 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,758] INFO [Transaction State Manager 0]: Finished loading 1 transaction metadata from __transaction_state-30 in 19 milliseconds (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,758] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-36 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,758] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-42 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,758] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-48 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,763] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,763] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-43 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,763] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-15 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,768] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,768] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,768] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,768] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,768] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-21 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,768] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-49 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,773] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,774] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-0 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,777] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-27 in 9 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,777] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-33 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,777] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-39 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,777] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-45 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,779] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-6 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,784] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-12 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,788] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,789] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-18 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,789] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,789] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-34 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,789] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,789] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-22 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,789] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-28 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,789] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-34 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,789] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-40 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,809] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,809] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-1 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,809] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-46 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,814] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-7 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,819] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-13 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,824] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-19 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,829] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-25 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,833] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-31 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,838] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,838] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-37 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,839] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-41 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,843] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,843] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-2 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,844] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-47 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,848] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-8 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,853] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-14 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,858] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-20 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,863] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-26 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,868] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-32 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,873] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-38 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,878] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,878] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-44 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,878] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,878] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,878] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-10 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,878] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-4 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,878] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-16 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,886] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-21 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,891] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-27 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,895] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-33 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,900] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,900] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-39 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,900] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-5 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,904] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,904] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,904] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,904] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,904] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-45 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,904] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,905] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-11 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,905] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,905] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-17 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,905] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-23 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,907] INFO [Transaction State Manager 0]: Finished loading 1 transaction metadata from __transaction_state-45 in 3 milliseconds (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,907] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-29 in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,908] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-35 in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,908] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-0 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,910] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,910] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-40 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,910] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,912] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-6 in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,912] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-12 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,915] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,915] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-46 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,915] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,915] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,915] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-18 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,915] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,915] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,915] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-24 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,920] INFO [Group Metadata Manager on Broker 0]: Scheduling loading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,920] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-3 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,925] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-9 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,926] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-30 in 11 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,926] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-36 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,926] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-42 in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,929] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-15 (kafka.coordinator.transaction.TransactionStateManager) [2018-03-06 23:46:46,939] INFO [GroupCoordinator 0]: Loading group metadata for 0 with generation 2 (kafka.coordinator.group.GroupCoordinator) [2018-03-06 23:46:46,943] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets and group metadata from __consumer_offsets-48 in 17 milliseconds. (kafka.coordinator.group.GroupMetadataManager) [2018-03-06 23:46:46,950] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions __consumer_offsets-22,__transaction_state-42,__consumer_offsets-30,__transaction_state-31,__transaction_state-45,cpes-0,__transaction_state-15,__transaction_state-12,__consumer_offsets-8,__consumer_offsets-21,__consumer_offsets-4,__transaction_state-7,__transaction_state-46,__consumer_offsets-27,__consumer_offsets-7,casa_cable_modem-0,__transaction_state-48,__consumer_offsets-9,cablemodem-0,__transaction_state-49,__consumer_offsets-46,__consumer_offsets-25,__consumer_offsets-35,__transaction_state-28,__transaction_state-2,__transaction_state-20,getId-0,__transaction_state-24,__consumer_offsets-41,__consumer_offsets-33,__consumer_offsets-23,__transaction_state-13,__consumer_offsets-49,mac_addr-0,putId-0,__transaction_state-0,__consumer_offsets-47,__consumer_offsets-16,test-0,neighbour-ssids-0,__consumer_offsets-28,__transaction_state-37,__transaction_state-3,__consumer_offsets-31,__transaction_state-21,__consumer_offsets-36,__transaction_state-29,__consumer_offsets-42,__consumer_offsets-3,__consumer_offsets-18,__transaction_state-39,test1-0,__consumer_offsets-37,__transaction_state-38,totalstats-0,__consumer_offsets-15,__consumer_offsets-24,__transaction_state-6,statistics-0,ssids-0,__transaction_state-14,__transaction_state-10,__transaction_state-44,__transaction_state-9,__transaction_state-22,__transaction_state-43,__transaction_state-4,__transaction_state-30,__transaction_state-33,__consumer_offsets-38,__consumer_offsets-17,__transaction_state-32,__consumer_offsets-48,__transaction_state-25,__transaction_state-17,__consumer_offsets-19,__consumer_offsets-11,__transaction_state-23,__transaction_state-47,__consumer_offsets-13,__consumer_offsets-2,__consumer_offsets-43,__consumer_offsets-6,__consumer_offsets-14,__transaction_state-18,__transaction_state-26,__transaction_state-36,__transaction_state-5,__transaction_state-8,__consumer_offsets-20,__transaction_state-16,__consumer_offsets-0,__consumer_offsets-44,casa-cable_modem-0,__transaction_state-11,__consumer_offsets-39,__consumer_offsets-12,__transaction_state-40,__consumer_offsets-45,__consumer_offsets-1,__consumer_offsets-5,__consumer_offsets-26,__transaction_state-19,__transaction_state-27,__consumer_offsets-29,__transaction_state-41,__consumer_offsets-34,__transaction_state-1,__consumer_offsets-10,__consumer_offsets-32,__transaction_state-34,__transaction_state-35,__consumer_offsets-40 (kafka.server.ReplicaFetcherManager) [2018-03-06 23:46:46,950] INFO Partition [getId,0] on broker 0: getId-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14 (kafka.cluster.Partition) [2018-03-06 23:46:46,951] INFO Partition [__consumer_offsets,0] on broker 0: __consumer_offsets-0 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,951] INFO Partition [__consumer_offsets,48] on broker 0: __consumer_offsets-48 starts at Leader Epoch 16 from offset 16. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,951] INFO Partition [__consumer_offsets,29] on broker 0: __consumer_offsets-29 starts at Leader Epoch 16 from offset 6. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,951] INFO Partition [__transaction_state,25] on broker 0: __transaction_state-25 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,951] INFO Partition [__transaction_state,44] on broker 0: __transaction_state-44 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,951] INFO Partition [__transaction_state,6] on broker 0: __transaction_state-6 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,951] INFO Partition [__consumer_offsets,10] on broker 0: __consumer_offsets-10 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,951] INFO Partition [__consumer_offsets,45] on broker 0: __consumer_offsets-45 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [__transaction_state,3] on broker 0: __transaction_state-3 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [__transaction_state,41] on broker 0: __transaction_state-41 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [__transaction_state,22] on broker 0: __transaction_state-22 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [__consumer_offsets,26] on broker 0: __consumer_offsets-26 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [test1,0] on broker 0: test1-0 starts at Leader Epoch 8 from offset 0. Previous Leader Epoch was: 7 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [__consumer_offsets,7] on broker 0: __consumer_offsets-7 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [__consumer_offsets,42] on broker 0: __consumer_offsets-42 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [casa_cable_modem,0] on broker 0: casa_cable_modem-0 starts at Leader Epoch 8 from offset 4. Previous Leader Epoch was: 7 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [__transaction_state,0] on broker 0: __transaction_state-0 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [__transaction_state,38] on broker 0: __transaction_state-38 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,952] INFO Partition [mac_addr,0] on broker 0: mac_addr-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__consumer_offsets,4] on broker 0: __consumer_offsets-4 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__consumer_offsets,23] on broker 0: __consumer_offsets-23 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__transaction_state,19] on broker 0: __transaction_state-19 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__transaction_state,35] on broker 0: __transaction_state-35 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__transaction_state,16] on broker 0: __transaction_state-16 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__consumer_offsets,1] on broker 0: __consumer_offsets-1 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__consumer_offsets,39] on broker 0: __consumer_offsets-39 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__consumer_offsets,20] on broker 0: __consumer_offsets-20 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [putId,0] on broker 0: putId-0 starts at Leader Epoch 15 from offset 0. Previous Leader Epoch was: 14 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__consumer_offsets,17] on broker 0: __consumer_offsets-17 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,953] INFO Partition [__consumer_offsets,36] on broker 0: __consumer_offsets-36 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__transaction_state,13] on broker 0: __transaction_state-13 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__transaction_state,32] on broker 0: __transaction_state-32 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__transaction_state,48] on broker 0: __transaction_state-48 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__consumer_offsets,14] on broker 0: __consumer_offsets-14 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__transaction_state,29] on broker 0: __transaction_state-29 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__transaction_state,10] on broker 0: __transaction_state-10 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__consumer_offsets,33] on broker 0: __consumer_offsets-33 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__transaction_state,7] on broker 0: __transaction_state-7 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [cablemodem,0] on broker 0: cablemodem-0 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [__transaction_state,45] on broker 0: __transaction_state-45 starts at Leader Epoch 6 from offset 1. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,954] INFO Partition [neighbour-ssids,0] on broker 0: neighbour-ssids-0 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: 13 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__transaction_state,26] on broker 0: __transaction_state-26 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__consumer_offsets,49] on broker 0: __consumer_offsets-49 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__consumer_offsets,11] on broker 0: __consumer_offsets-11 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__consumer_offsets,30] on broker 0: __consumer_offsets-30 starts at Leader Epoch 16 from offset 201. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [test,0] on broker 0: test-0 starts at Leader Epoch 14 from offset 4. Previous Leader Epoch was: 13 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__transaction_state,23] on broker 0: __transaction_state-23 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__consumer_offsets,46] on broker 0: __consumer_offsets-46 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__consumer_offsets,27] on broker 0: __consumer_offsets-27 starts at Leader Epoch 16 from offset 77. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__transaction_state,42] on broker 0: __transaction_state-42 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,955] INFO Partition [__transaction_state,4] on broker 0: __transaction_state-4 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__consumer_offsets,8] on broker 0: __consumer_offsets-8 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__consumer_offsets,24] on broker 0: __consumer_offsets-24 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__consumer_offsets,43] on broker 0: __consumer_offsets-43 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__transaction_state,1] on broker 0: __transaction_state-1 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__transaction_state,39] on broker 0: __transaction_state-39 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__consumer_offsets,5] on broker 0: __consumer_offsets-5 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__transaction_state,20] on broker 0: __transaction_state-20 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__transaction_state,17] on broker 0: __transaction_state-17 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__transaction_state,36] on broker 0: __transaction_state-36 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__consumer_offsets,21] on broker 0: __consumer_offsets-21 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__consumer_offsets,40] on broker 0: __consumer_offsets-40 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__consumer_offsets,2] on broker 0: __consumer_offsets-2 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,956] INFO Partition [__consumer_offsets,37] on broker 0: __consumer_offsets-37 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__transaction_state,33] on broker 0: __transaction_state-33 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__consumer_offsets,18] on broker 0: __consumer_offsets-18 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__transaction_state,14] on broker 0: __transaction_state-14 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [totalstats,0] on broker 0: totalstats-0 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: 13 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__transaction_state,30] on broker 0: __transaction_state-30 starts at Leader Epoch 6 from offset 1. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__consumer_offsets,15] on broker 0: __consumer_offsets-15 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__consumer_offsets,34] on broker 0: __consumer_offsets-34 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__transaction_state,49] on broker 0: __transaction_state-49 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__transaction_state,11] on broker 0: __transaction_state-11 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__consumer_offsets,12] on broker 0: __consumer_offsets-12 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__transaction_state,46] on broker 0: __transaction_state-46 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,957] INFO Partition [__consumer_offsets,31] on broker 0: __consumer_offsets-31 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__transaction_state,18] on broker 0: __transaction_state-18 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__transaction_state,27] on broker 0: __transaction_state-27 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__transaction_state,8] on broker 0: __transaction_state-8 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [casa-cable_modem,0] on broker 0: casa-cable_modem-0 starts at Leader Epoch 8 from offset 0. Previous Leader Epoch was: 7 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__transaction_state,37] on broker 0: __transaction_state-37 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [ssids,0] on broker 0: ssids-0 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: 13 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__consumer_offsets,9] on broker 0: __consumer_offsets-9 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__consumer_offsets,47] on broker 0: __consumer_offsets-47 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__consumer_offsets,19] on broker 0: __consumer_offsets-19 starts at Leader Epoch 16 from offset 91. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__transaction_state,5] on broker 0: __transaction_state-5 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__consumer_offsets,28] on broker 0: __consumer_offsets-28 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [__transaction_state,15] on broker 0: __transaction_state-15 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,958] INFO Partition [statistics,0] on broker 0: statistics-0 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__transaction_state,34] on broker 0: __transaction_state-34 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__consumer_offsets,38] on broker 0: __consumer_offsets-38 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__transaction_state,43] on broker 0: __transaction_state-43 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__transaction_state,24] on broker 0: __transaction_state-24 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__consumer_offsets,35] on broker 0: __consumer_offsets-35 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__transaction_state,2] on broker 0: __transaction_state-2 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__transaction_state,40] on broker 0: __transaction_state-40 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__transaction_state,31] on broker 0: __transaction_state-31 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__consumer_offsets,44] on broker 0: __consumer_offsets-44 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__consumer_offsets,6] on broker 0: __consumer_offsets-6 starts at Leader Epoch 16 from offset 13. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,959] INFO Partition [__consumer_offsets,25] on broker 0: __consumer_offsets-25 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [cpes,0] on broker 0: cpes-0 starts at Leader Epoch 14 from offset 0. Previous Leader Epoch was: 13 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__transaction_state,12] on broker 0: __transaction_state-12 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__consumer_offsets,16] on broker 0: __consumer_offsets-16 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__transaction_state,21] on broker 0: __transaction_state-21 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__consumer_offsets,22] on broker 0: __consumer_offsets-22 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__consumer_offsets,41] on broker 0: __consumer_offsets-41 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__transaction_state,28] on broker 0: __transaction_state-28 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__consumer_offsets,32] on broker 0: __consumer_offsets-32 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__consumer_offsets,3] on broker 0: __consumer_offsets-3 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__transaction_state,9] on broker 0: __transaction_state-9 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__transaction_state,47] on broker 0: __transaction_state-47 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition) [2018-03-06 23:46:46,960] INFO Partition [__consumer_offsets,13] on broker 0: __consumer_offsets-13 starts at Leader Epoch 16 from offset 0. Previous Leader Epoch was: 15 (kafka.cluster.Partition) [2018-03-06 23:56:45,088] INFO [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager) It displaying like dis. ... View more