Support Questions

hemamoger · ‎03-07-2018

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.

Shelton · ‎03-07-2018

@hema moger

There are a couple of errors I can see from your ouput

advertised.listeners=PLAINTEXT://{kafka_server}:9092
log.dirs=/tmp/kafka-logs          (2 entries this is the correct value)
broker.id=1num.partitions=3        # At least 1
default.replication.factor=1       # best 3 
zookeeper.connect = localhost:2181 # Make sure your zookeepr is up

Please share your server.properties

View solution in original post

Shelton · ‎03-07-2018

@hema moger
Can you attach your server.properties?

Apart from that can you give a brief description of your setup, Number of Zookeepers,Brokers, Versions,OS etc

Shelton · ‎03-07-2018

@hema moger

There are a couple of errors I can see from your ouput

advertised.listeners=PLAINTEXT://{kafka_server}:9092
log.dirs=/tmp/kafka-logs          (2 entries this is the correct value)
broker.id=1num.partitions=3        # At least 1
default.replication.factor=1       # best 3 
zookeeper.connect = localhost:2181 # Make sure your zookeepr is up

Please share your server.properties

hemamoger · ‎03-08-2018

@Geoffrey Shelton Okot:

Thanks and its running fine

Shelton · ‎03-08-2018

@hema moger

Can you share what was the issue then?

hemamoger · ‎03-08-2018

Zookeeper was not running.

Shelton · ‎03-08-2018

@hema moger

Great ! Could you the 'Accept' the answer by Clicking on Accept button below, That would be great help to Community users to find solution quickly for this kind of error.

Support Questions

Kafka installation error