[2019-08-23 17:12:01,975] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:01,978] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = none bootstrap.servers = [localhost:57756] check.crcs = true client.dns.lookup = default client.id = streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-restore-consumer client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = null group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 100 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.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 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:01,993] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] Creating shared producer client (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:02,010] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:02,011] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:57756] check.crcs = true client.dns.lookup = default client.id = streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-consumer client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = streamsApp group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 100 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.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 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:02,024] WARN The configuration 'admin.retries' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:02,024] WARN The configuration 'admin.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:02,029] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] Creating restore consumer client (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:02,029] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = none bootstrap.servers = [localhost:57756] check.crcs = true client.dns.lookup = default client.id = streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-restore-consumer client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = null group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 100 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.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 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:02,030] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] Creating shared producer client (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:02,032] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] Creating consumer client (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:02,032] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:57756] check.crcs = true client.dns.lookup = default client.id = streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = streamsApp group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 100 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.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 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:02,034] WARN The configuration 'admin.retries' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:02,034] WARN The configuration 'admin.retry.backoff.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:05,500] INFO stream-client [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams) [2019-08-23 17:12:05,500] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:05,500] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] State transition from CREATED to STARTING (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:05,500] INFO [Consumer clientId=streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-consumer, groupId=streamsApp] Subscribed to pattern: 'input-topic' (org.apache.kafka.clients.consumer.KafkaConsumer) [2019-08-23 17:12:05,512] INFO Creating topic __consumer_offsets with configuration {segment.bytes=104857600, compression.type=producer, cleanup.policy=compact} and initial partition assignment Map(23 -> ArrayBuffer(0), 32 -> ArrayBuffer(0), 41 -> ArrayBuffer(0), 17 -> ArrayBuffer(0), 8 -> ArrayBuffer(0), 35 -> ArrayBuffer(0), 44 -> ArrayBuffer(0), 26 -> ArrayBuffer(0), 11 -> ArrayBuffer(0), 29 -> ArrayBuffer(0), 38 -> ArrayBuffer(0), 47 -> ArrayBuffer(0), 20 -> ArrayBuffer(0), 2 -> ArrayBuffer(0), 5 -> ArrayBuffer(0), 14 -> ArrayBuffer(0), 46 -> ArrayBuffer(0), 49 -> ArrayBuffer(0), 40 -> ArrayBuffer(0), 13 -> ArrayBuffer(0), 4 -> ArrayBuffer(0), 22 -> ArrayBuffer(0), 31 -> ArrayBuffer(0), 16 -> ArrayBuffer(0), 7 -> ArrayBuffer(0), 43 -> ArrayBuffer(0), 25 -> ArrayBuffer(0), 34 -> ArrayBuffer(0), 10 -> ArrayBuffer(0), 37 -> ArrayBuffer(0), 1 -> ArrayBuffer(0), 19 -> ArrayBuffer(0), 28 -> ArrayBuffer(0), 45 -> ArrayBuffer(0), 27 -> ArrayBuffer(0), 36 -> ArrayBuffer(0), 18 -> ArrayBuffer(0), 9 -> ArrayBuffer(0), 21 -> ArrayBuffer(0), 48 -> ArrayBuffer(0), 3 -> ArrayBuffer(0), 12 -> ArrayBuffer(0), 30 -> ArrayBuffer(0), 39 -> ArrayBuffer(0), 15 -> ArrayBuffer(0), 42 -> ArrayBuffer(0), 24 -> ArrayBuffer(0), 6 -> ArrayBuffer(0), 33 -> ArrayBuffer(0), 0 -> ArrayBuffer(0)) (kafka.zk.AdminZkClient) [2019-08-23 17:12:05,515] INFO [KafkaApi-0] Auto creation of topic __consumer_offsets with 50 partitions and replication factor 1 is successful (kafka.server.KafkaApis) [2019-08-23 17:12:05,517] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-22 -> Vector(0), __consumer_offsets-30 -> Vector(0), __consumer_offsets-8 -> Vector(0), __consumer_offsets-21 -> Vector(0), __consumer_offsets-4 -> Vector(0), __consumer_offsets-27 -> Vector(0), __consumer_offsets-7 -> Vector(0), __consumer_offsets-9 -> Vector(0), __consumer_offsets-46 -> Vector(0), __consumer_offsets-25 -> Vector(0), __consumer_offsets-35 -> Vector(0), __consumer_offsets-41 -> Vector(0), __consumer_offsets-33 -> Vector(0), __consumer_offsets-23 -> Vector(0), __consumer_offsets-49 -> Vector(0), __consumer_offsets-47 -> Vector(0), __consumer_offsets-16 -> Vector(0), __consumer_offsets-28 -> Vector(0), __consumer_offsets-31 -> Vector(0), __consumer_offsets-36 -> Vector(0), __consumer_offsets-42 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-18 -> Vector(0), __consumer_offsets-37 -> Vector(0), __consumer_offsets-15 -> Vector(0), __consumer_offsets-24 -> Vector(0), __consumer_offsets-38 -> Vector(0), __consumer_offsets-17 -> Vector(0), __consumer_offsets-48 -> Vector(0), __consumer_offsets-19 -> Vector(0), __consumer_offsets-11 -> Vector(0), __consumer_offsets-13 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-43 -> Vector(0), __consumer_offsets-6 -> Vector(0), __consumer_offsets-14 -> Vector(0), __consumer_offsets-20 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-44 -> Vector(0), __consumer_offsets-39 -> Vector(0), __consumer_offsets-12 -> Vector(0), __consumer_offsets-45 -> Vector(0), __consumer_offsets-1 -> Vector(0), __consumer_offsets-5 -> Vector(0), __consumer_offsets-26 -> Vector(0), __consumer_offsets-29 -> Vector(0), __consumer_offsets-34 -> Vector(0), __consumer_offsets-10 -> Vector(0), __consumer_offsets-32 -> Vector(0), __consumer_offsets-40 -> Vector(0))] (kafka.controller.KafkaController) [2019-08-23 17:12:05,518] INFO [Controller id=0] New partition creation callback for __consumer_offsets-22,__consumer_offsets-30,__consumer_offsets-8,__consumer_offsets-21,__consumer_offsets-4,__consumer_offsets-27,__consumer_offsets-7,__consumer_offsets-9,__consumer_offsets-46,__consumer_offsets-25,__consumer_offsets-35,__consumer_offsets-41,__consumer_offsets-33,__consumer_offsets-23,__consumer_offsets-49,__consumer_offsets-47,__consumer_offsets-16,__consumer_offsets-28,__consumer_offsets-31,__consumer_offsets-36,__consumer_offsets-42,__consumer_offsets-3,__consumer_offsets-18,__consumer_offsets-37,__consumer_offsets-15,__consumer_offsets-24,__consumer_offsets-38,__consumer_offsets-17,__consumer_offsets-48,__consumer_offsets-19,__consumer_offsets-11,__consumer_offsets-13,__consumer_offsets-2,__consumer_offsets-43,__consumer_offsets-6,__consumer_offsets-14,__consumer_offsets-20,__consumer_offsets-0,__consumer_offsets-44,__consumer_offsets-39,__consumer_offsets-12,__consumer_offsets-45,__consumer_offsets-1,__consumer_offsets-5,__consumer_offsets-26,__consumer_offsets-29,__consumer_offsets-34,__consumer_offsets-10,__consumer_offsets-32,__consumer_offsets-40 (kafka.controller.KafkaController) [2019-08-23 17:12:05,564] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(__consumer_offsets-22, __consumer_offsets-30, __consumer_offsets-8, __consumer_offsets-21, __consumer_offsets-4, __consumer_offsets-27, __consumer_offsets-7, __consumer_offsets-9, __consumer_offsets-46, __consumer_offsets-25, __consumer_offsets-35, __consumer_offsets-41, __consumer_offsets-33, __consumer_offsets-23, __consumer_offsets-49, __consumer_offsets-47, __consumer_offsets-16, __consumer_offsets-28, __consumer_offsets-31, __consumer_offsets-36, __consumer_offsets-42, __consumer_offsets-3, __consumer_offsets-18, __consumer_offsets-37, __consumer_offsets-15, __consumer_offsets-24, __consumer_offsets-38, __consumer_offsets-17, __consumer_offsets-48, __consumer_offsets-19, __consumer_offsets-11, __consumer_offsets-13, __consumer_offsets-2, __consumer_offsets-43, __consumer_offsets-6, __consumer_offsets-14, __consumer_offsets-20, __consumer_offsets-0, __consumer_offsets-44, __consumer_offsets-39, __consumer_offsets-12, __consumer_offsets-45, __consumer_offsets-1, __consumer_offsets-5, __consumer_offsets-26, __consumer_offsets-29, __consumer_offsets-34, __consumer_offsets-10, __consumer_offsets-32, __consumer_offsets-40) (kafka.server.ReplicaFetcherManager) [2019-08-23 17:12:05,567] INFO [Log partition=__consumer_offsets-0, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,568] INFO [Log partition=__consumer_offsets-0, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,568] INFO Created log for partition __consumer_offsets-0 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,568] INFO [Partition __consumer_offsets-0 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-0 (kafka.cluster.Partition) [2019-08-23 17:12:05,568] INFO [Partition __consumer_offsets-0 broker=0] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,568] INFO [Partition __consumer_offsets-0 broker=0] __consumer_offsets-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,571] INFO [Log partition=__consumer_offsets-29, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,571] INFO [Log partition=__consumer_offsets-29, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,571] INFO Created log for partition __consumer_offsets-29 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-29 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,571] INFO [Partition __consumer_offsets-29 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-29 (kafka.cluster.Partition) [2019-08-23 17:12:05,571] INFO [Partition __consumer_offsets-29 broker=0] Log loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,571] INFO [Partition __consumer_offsets-29 broker=0] __consumer_offsets-29 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,574] INFO [Log partition=__consumer_offsets-48, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,574] INFO [Log partition=__consumer_offsets-48, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,574] INFO Created log for partition __consumer_offsets-48 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-48 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,574] INFO [Partition __consumer_offsets-48 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-48 (kafka.cluster.Partition) [2019-08-23 17:12:05,574] INFO [Partition __consumer_offsets-48 broker=0] Log loaded for partition __consumer_offsets-48 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,574] INFO [Partition __consumer_offsets-48 broker=0] __consumer_offsets-48 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,577] INFO [Log partition=__consumer_offsets-10, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,577] INFO [Log partition=__consumer_offsets-10, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,577] INFO Created log for partition __consumer_offsets-10 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-10 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,577] INFO [Partition __consumer_offsets-10 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-10 (kafka.cluster.Partition) [2019-08-23 17:12:05,578] INFO [Partition __consumer_offsets-10 broker=0] Log loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,578] INFO [Partition __consumer_offsets-10 broker=0] __consumer_offsets-10 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,581] INFO [Log partition=__consumer_offsets-45, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,581] INFO [Log partition=__consumer_offsets-45, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,581] INFO Created log for partition __consumer_offsets-45 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-45 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,581] INFO [Partition __consumer_offsets-45 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-45 (kafka.cluster.Partition) [2019-08-23 17:12:05,581] INFO [Partition __consumer_offsets-45 broker=0] Log loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,581] INFO [Partition __consumer_offsets-45 broker=0] __consumer_offsets-45 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,584] INFO [Log partition=__consumer_offsets-26, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,584] INFO [Log partition=__consumer_offsets-26, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,584] INFO Created log for partition __consumer_offsets-26 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-26 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,584] INFO [Partition __consumer_offsets-26 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-26 (kafka.cluster.Partition) [2019-08-23 17:12:05,584] INFO [Partition __consumer_offsets-26 broker=0] Log loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,584] INFO [Partition __consumer_offsets-26 broker=0] __consumer_offsets-26 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,587] INFO [Log partition=__consumer_offsets-7, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,587] INFO [Log partition=__consumer_offsets-7, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,587] INFO Created log for partition __consumer_offsets-7 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-7 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,587] INFO [Partition __consumer_offsets-7 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-7 (kafka.cluster.Partition) [2019-08-23 17:12:05,587] INFO [Partition __consumer_offsets-7 broker=0] Log loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,587] INFO [Partition __consumer_offsets-7 broker=0] __consumer_offsets-7 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,590] INFO [Log partition=__consumer_offsets-42, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,590] INFO [Log partition=__consumer_offsets-42, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,590] INFO Created log for partition __consumer_offsets-42 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-42 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,590] INFO [Partition __consumer_offsets-42 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-42 (kafka.cluster.Partition) [2019-08-23 17:12:05,590] INFO [Partition __consumer_offsets-42 broker=0] Log loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,590] INFO [Partition __consumer_offsets-42 broker=0] __consumer_offsets-42 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,593] INFO [Log partition=__consumer_offsets-4, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,593] INFO [Log partition=__consumer_offsets-4, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,593] INFO Created log for partition __consumer_offsets-4 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-4 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,593] INFO [Partition __consumer_offsets-4 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-4 (kafka.cluster.Partition) [2019-08-23 17:12:05,593] INFO [Partition __consumer_offsets-4 broker=0] Log loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,593] INFO [Partition __consumer_offsets-4 broker=0] __consumer_offsets-4 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,596] INFO [Log partition=__consumer_offsets-23, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,596] INFO [Log partition=__consumer_offsets-23, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,596] INFO Created log for partition __consumer_offsets-23 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-23 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,596] INFO [Partition __consumer_offsets-23 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-23 (kafka.cluster.Partition) [2019-08-23 17:12:05,596] INFO [Partition __consumer_offsets-23 broker=0] Log loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,596] INFO [Partition __consumer_offsets-23 broker=0] __consumer_offsets-23 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,600] INFO [Log partition=__consumer_offsets-1, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,600] INFO [Log partition=__consumer_offsets-1, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,600] INFO Created log for partition __consumer_offsets-1 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,600] INFO [Partition __consumer_offsets-1 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-1 (kafka.cluster.Partition) [2019-08-23 17:12:05,600] INFO [Partition __consumer_offsets-1 broker=0] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,600] INFO [Partition __consumer_offsets-1 broker=0] __consumer_offsets-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,603] INFO [Log partition=__consumer_offsets-20, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,603] INFO [Log partition=__consumer_offsets-20, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,603] INFO Created log for partition __consumer_offsets-20 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-20 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,603] INFO [Partition __consumer_offsets-20 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-20 (kafka.cluster.Partition) [2019-08-23 17:12:05,603] INFO [Partition __consumer_offsets-20 broker=0] Log loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,603] INFO [Partition __consumer_offsets-20 broker=0] __consumer_offsets-20 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,606] INFO [Log partition=__consumer_offsets-39, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,606] INFO [Log partition=__consumer_offsets-39, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,606] INFO Created log for partition __consumer_offsets-39 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-39 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,606] INFO [Partition __consumer_offsets-39 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-39 (kafka.cluster.Partition) [2019-08-23 17:12:05,606] INFO [Partition __consumer_offsets-39 broker=0] Log loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,607] INFO [Partition __consumer_offsets-39 broker=0] __consumer_offsets-39 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,609] INFO [Log partition=__consumer_offsets-17, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,610] INFO [Log partition=__consumer_offsets-17, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,610] INFO Created log for partition __consumer_offsets-17 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-17 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,610] INFO [Partition __consumer_offsets-17 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-17 (kafka.cluster.Partition) [2019-08-23 17:12:05,610] INFO [Partition __consumer_offsets-17 broker=0] Log loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,610] INFO [Partition __consumer_offsets-17 broker=0] __consumer_offsets-17 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,612] INFO [Log partition=__consumer_offsets-36, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,613] INFO [Log partition=__consumer_offsets-36, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,613] INFO Created log for partition __consumer_offsets-36 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-36 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,613] INFO [Partition __consumer_offsets-36 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-36 (kafka.cluster.Partition) [2019-08-23 17:12:05,613] INFO [Partition __consumer_offsets-36 broker=0] Log loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,613] INFO [Partition __consumer_offsets-36 broker=0] __consumer_offsets-36 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,616] INFO [Log partition=__consumer_offsets-14, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,616] INFO [Log partition=__consumer_offsets-14, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,616] INFO Created log for partition __consumer_offsets-14 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-14 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,616] INFO [Partition __consumer_offsets-14 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-14 (kafka.cluster.Partition) [2019-08-23 17:12:05,616] INFO [Partition __consumer_offsets-14 broker=0] Log loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,616] INFO [Partition __consumer_offsets-14 broker=0] __consumer_offsets-14 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,618] INFO [Log partition=__consumer_offsets-33, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,619] INFO [Log partition=__consumer_offsets-33, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,619] INFO Created log for partition __consumer_offsets-33 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-33 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,619] INFO [Partition __consumer_offsets-33 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-33 (kafka.cluster.Partition) [2019-08-23 17:12:05,619] INFO [Partition __consumer_offsets-33 broker=0] Log loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,619] INFO [Partition __consumer_offsets-33 broker=0] __consumer_offsets-33 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,621] INFO [Log partition=__consumer_offsets-49, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,622] INFO [Log partition=__consumer_offsets-49, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,622] INFO Created log for partition __consumer_offsets-49 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-49 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,622] INFO [Partition __consumer_offsets-49 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-49 (kafka.cluster.Partition) [2019-08-23 17:12:05,622] INFO [Partition __consumer_offsets-49 broker=0] Log loaded for partition __consumer_offsets-49 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,622] INFO [Partition __consumer_offsets-49 broker=0] __consumer_offsets-49 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,624] INFO [Log partition=__consumer_offsets-11, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,625] INFO [Log partition=__consumer_offsets-11, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,625] INFO Created log for partition __consumer_offsets-11 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-11 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,625] INFO [Partition __consumer_offsets-11 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-11 (kafka.cluster.Partition) [2019-08-23 17:12:05,625] INFO [Partition __consumer_offsets-11 broker=0] Log loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,625] INFO [Partition __consumer_offsets-11 broker=0] __consumer_offsets-11 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,627] INFO [Log partition=__consumer_offsets-30, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,627] INFO [Log partition=__consumer_offsets-30, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,627] INFO Created log for partition __consumer_offsets-30 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-30 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,627] INFO [Partition __consumer_offsets-30 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-30 (kafka.cluster.Partition) [2019-08-23 17:12:05,627] INFO [Partition __consumer_offsets-30 broker=0] Log loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,627] INFO [Partition __consumer_offsets-30 broker=0] __consumer_offsets-30 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,630] INFO [Log partition=__consumer_offsets-46, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,630] INFO [Log partition=__consumer_offsets-46, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,630] INFO Created log for partition __consumer_offsets-46 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-46 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,630] INFO [Partition __consumer_offsets-46 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-46 (kafka.cluster.Partition) [2019-08-23 17:12:05,630] INFO [Partition __consumer_offsets-46 broker=0] Log loaded for partition __consumer_offsets-46 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,630] INFO [Partition __consumer_offsets-46 broker=0] __consumer_offsets-46 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,632] INFO [Log partition=__consumer_offsets-27, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,632] INFO [Log partition=__consumer_offsets-27, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,633] INFO Created log for partition __consumer_offsets-27 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-27 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,633] INFO [Partition __consumer_offsets-27 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-27 (kafka.cluster.Partition) [2019-08-23 17:12:05,633] INFO [Partition __consumer_offsets-27 broker=0] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,633] INFO [Partition __consumer_offsets-27 broker=0] __consumer_offsets-27 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,635] INFO [Log partition=__consumer_offsets-8, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,635] INFO [Log partition=__consumer_offsets-8, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,636] INFO Created log for partition __consumer_offsets-8 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-8 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,636] INFO [Partition __consumer_offsets-8 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-8 (kafka.cluster.Partition) [2019-08-23 17:12:05,636] INFO [Partition __consumer_offsets-8 broker=0] Log loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,636] INFO [Partition __consumer_offsets-8 broker=0] __consumer_offsets-8 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,638] INFO [Log partition=__consumer_offsets-24, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,638] INFO [Log partition=__consumer_offsets-24, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,638] INFO Created log for partition __consumer_offsets-24 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-24 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,638] INFO [Partition __consumer_offsets-24 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-24 (kafka.cluster.Partition) [2019-08-23 17:12:05,638] INFO [Partition __consumer_offsets-24 broker=0] Log loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,638] INFO [Partition __consumer_offsets-24 broker=0] __consumer_offsets-24 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,640] INFO [Log partition=__consumer_offsets-43, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,641] INFO [Log partition=__consumer_offsets-43, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,641] INFO Created log for partition __consumer_offsets-43 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-43 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,641] INFO [Partition __consumer_offsets-43 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-43 (kafka.cluster.Partition) [2019-08-23 17:12:05,641] INFO [Partition __consumer_offsets-43 broker=0] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,641] INFO [Partition __consumer_offsets-43 broker=0] __consumer_offsets-43 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,644] INFO [Log partition=__consumer_offsets-5, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,644] INFO [Log partition=__consumer_offsets-5, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,644] INFO Created log for partition __consumer_offsets-5 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-5 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,644] INFO [Partition __consumer_offsets-5 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-5 (kafka.cluster.Partition) [2019-08-23 17:12:05,644] INFO [Partition __consumer_offsets-5 broker=0] Log loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,644] INFO [Partition __consumer_offsets-5 broker=0] __consumer_offsets-5 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,647] INFO [Log partition=__consumer_offsets-21, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,647] INFO [Log partition=__consumer_offsets-21, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,647] INFO Created log for partition __consumer_offsets-21 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-21 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,647] INFO [Partition __consumer_offsets-21 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-21 (kafka.cluster.Partition) [2019-08-23 17:12:05,647] INFO [Partition __consumer_offsets-21 broker=0] Log loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,647] INFO [Partition __consumer_offsets-21 broker=0] __consumer_offsets-21 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,650] INFO [Log partition=__consumer_offsets-2, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,650] INFO [Log partition=__consumer_offsets-2, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,650] INFO Created log for partition __consumer_offsets-2 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,650] INFO [Partition __consumer_offsets-2 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-2 (kafka.cluster.Partition) [2019-08-23 17:12:05,650] INFO [Partition __consumer_offsets-2 broker=0] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,650] INFO [Partition __consumer_offsets-2 broker=0] __consumer_offsets-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,653] INFO [Log partition=__consumer_offsets-40, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,654] INFO [Log partition=__consumer_offsets-40, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,654] INFO Created log for partition __consumer_offsets-40 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-40 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,654] INFO [Partition __consumer_offsets-40 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-40 (kafka.cluster.Partition) [2019-08-23 17:12:05,654] INFO [Partition __consumer_offsets-40 broker=0] Log loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,654] INFO [Partition __consumer_offsets-40 broker=0] __consumer_offsets-40 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,656] INFO [Log partition=__consumer_offsets-37, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,657] INFO [Log partition=__consumer_offsets-37, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,657] INFO Created log for partition __consumer_offsets-37 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-37 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,657] INFO [Partition __consumer_offsets-37 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-37 (kafka.cluster.Partition) [2019-08-23 17:12:05,657] INFO [Partition __consumer_offsets-37 broker=0] Log loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,657] INFO [Partition __consumer_offsets-37 broker=0] __consumer_offsets-37 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,660] INFO [Log partition=__consumer_offsets-18, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,661] INFO [Log partition=__consumer_offsets-18, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,661] INFO Created log for partition __consumer_offsets-18 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-18 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,661] INFO [Partition __consumer_offsets-18 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-18 (kafka.cluster.Partition) [2019-08-23 17:12:05,661] INFO [Partition __consumer_offsets-18 broker=0] Log loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,661] INFO [Partition __consumer_offsets-18 broker=0] __consumer_offsets-18 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,665] INFO [Log partition=__consumer_offsets-34, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,665] INFO [Log partition=__consumer_offsets-34, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,666] INFO Created log for partition __consumer_offsets-34 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-34 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,666] INFO [Partition __consumer_offsets-34 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-34 (kafka.cluster.Partition) [2019-08-23 17:12:05,666] INFO [Partition __consumer_offsets-34 broker=0] Log loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,666] INFO [Partition __consumer_offsets-34 broker=0] __consumer_offsets-34 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,668] INFO [Log partition=__consumer_offsets-15, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,669] INFO [Log partition=__consumer_offsets-15, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,669] INFO Created log for partition __consumer_offsets-15 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-15 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,669] INFO [Partition __consumer_offsets-15 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-15 (kafka.cluster.Partition) [2019-08-23 17:12:05,669] INFO [Partition __consumer_offsets-15 broker=0] Log loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,669] INFO [Partition __consumer_offsets-15 broker=0] __consumer_offsets-15 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,671] INFO [Log partition=__consumer_offsets-12, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,672] INFO [Log partition=__consumer_offsets-12, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,672] INFO Created log for partition __consumer_offsets-12 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-12 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,672] INFO [Partition __consumer_offsets-12 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-12 (kafka.cluster.Partition) [2019-08-23 17:12:05,672] INFO [Partition __consumer_offsets-12 broker=0] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,672] INFO [Partition __consumer_offsets-12 broker=0] __consumer_offsets-12 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,674] INFO [Log partition=__consumer_offsets-31, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,674] INFO [Log partition=__consumer_offsets-31, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,675] INFO Created log for partition __consumer_offsets-31 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-31 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,675] INFO [Partition __consumer_offsets-31 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-31 (kafka.cluster.Partition) [2019-08-23 17:12:05,675] INFO [Partition __consumer_offsets-31 broker=0] Log loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,675] INFO [Partition __consumer_offsets-31 broker=0] __consumer_offsets-31 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,677] INFO [Log partition=__consumer_offsets-9, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,677] INFO [Log partition=__consumer_offsets-9, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,677] INFO Created log for partition __consumer_offsets-9 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-9 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,677] INFO [Partition __consumer_offsets-9 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-9 (kafka.cluster.Partition) [2019-08-23 17:12:05,678] INFO [Partition __consumer_offsets-9 broker=0] Log loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,678] INFO [Partition __consumer_offsets-9 broker=0] __consumer_offsets-9 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,680] INFO [Log partition=__consumer_offsets-47, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,681] INFO [Log partition=__consumer_offsets-47, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,681] INFO Created log for partition __consumer_offsets-47 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-47 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,681] INFO [Partition __consumer_offsets-47 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-47 (kafka.cluster.Partition) [2019-08-23 17:12:05,681] INFO [Partition __consumer_offsets-47 broker=0] Log loaded for partition __consumer_offsets-47 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,681] INFO [Partition __consumer_offsets-47 broker=0] __consumer_offsets-47 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,684] INFO [Log partition=__consumer_offsets-19, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,684] INFO [Log partition=__consumer_offsets-19, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,684] INFO Created log for partition __consumer_offsets-19 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-19 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,685] INFO [Partition __consumer_offsets-19 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-19 (kafka.cluster.Partition) [2019-08-23 17:12:05,685] INFO [Partition __consumer_offsets-19 broker=0] Log loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,685] INFO [Partition __consumer_offsets-19 broker=0] __consumer_offsets-19 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,688] INFO [Log partition=__consumer_offsets-28, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,688] INFO [Log partition=__consumer_offsets-28, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,689] INFO Created log for partition __consumer_offsets-28 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-28 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,689] INFO [Partition __consumer_offsets-28 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-28 (kafka.cluster.Partition) [2019-08-23 17:12:05,689] INFO [Partition __consumer_offsets-28 broker=0] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,689] INFO [Partition __consumer_offsets-28 broker=0] __consumer_offsets-28 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,691] INFO [Log partition=__consumer_offsets-38, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,692] INFO [Log partition=__consumer_offsets-38, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,692] INFO Created log for partition __consumer_offsets-38 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-38 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,692] INFO [Partition __consumer_offsets-38 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-38 (kafka.cluster.Partition) [2019-08-23 17:12:05,692] INFO [Partition __consumer_offsets-38 broker=0] Log loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,692] INFO [Partition __consumer_offsets-38 broker=0] __consumer_offsets-38 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,695] INFO [Log partition=__consumer_offsets-35, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,696] INFO [Log partition=__consumer_offsets-35, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,696] INFO Created log for partition __consumer_offsets-35 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-35 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,696] INFO [Partition __consumer_offsets-35 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-35 (kafka.cluster.Partition) [2019-08-23 17:12:05,696] INFO [Partition __consumer_offsets-35 broker=0] Log loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,696] INFO [Partition __consumer_offsets-35 broker=0] __consumer_offsets-35 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,698] INFO [Log partition=__consumer_offsets-44, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,699] INFO [Log partition=__consumer_offsets-44, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,699] INFO Created log for partition __consumer_offsets-44 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-44 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,699] INFO [Partition __consumer_offsets-44 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-44 (kafka.cluster.Partition) [2019-08-23 17:12:05,699] INFO [Partition __consumer_offsets-44 broker=0] Log loaded for partition __consumer_offsets-44 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,699] INFO [Partition __consumer_offsets-44 broker=0] __consumer_offsets-44 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,702] INFO [Log partition=__consumer_offsets-6, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,702] INFO [Log partition=__consumer_offsets-6, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,703] INFO Created log for partition __consumer_offsets-6 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-6 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,703] INFO [Partition __consumer_offsets-6 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-6 (kafka.cluster.Partition) [2019-08-23 17:12:05,703] INFO [Partition __consumer_offsets-6 broker=0] Log loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,703] INFO [Partition __consumer_offsets-6 broker=0] __consumer_offsets-6 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,706] INFO [Log partition=__consumer_offsets-25, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,706] INFO [Log partition=__consumer_offsets-25, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,707] INFO Created log for partition __consumer_offsets-25 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-25 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,707] INFO [Partition __consumer_offsets-25 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-25 (kafka.cluster.Partition) [2019-08-23 17:12:05,707] INFO [Partition __consumer_offsets-25 broker=0] Log loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,707] INFO [Partition __consumer_offsets-25 broker=0] __consumer_offsets-25 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,710] INFO [Log partition=__consumer_offsets-16, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,711] INFO [Log partition=__consumer_offsets-16, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,711] INFO Created log for partition __consumer_offsets-16 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-16 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,711] INFO [Partition __consumer_offsets-16 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-16 (kafka.cluster.Partition) [2019-08-23 17:12:05,711] INFO [Partition __consumer_offsets-16 broker=0] Log loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,711] INFO [Partition __consumer_offsets-16 broker=0] __consumer_offsets-16 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,715] INFO [Log partition=__consumer_offsets-22, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,715] INFO [Log partition=__consumer_offsets-22, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,715] INFO Created log for partition __consumer_offsets-22 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-22 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,715] INFO [Partition __consumer_offsets-22 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-22 (kafka.cluster.Partition) [2019-08-23 17:12:05,715] INFO [Partition __consumer_offsets-22 broker=0] Log loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,715] INFO [Partition __consumer_offsets-22 broker=0] __consumer_offsets-22 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,719] INFO [Log partition=__consumer_offsets-41, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,719] INFO [Log partition=__consumer_offsets-41, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,719] INFO Created log for partition __consumer_offsets-41 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-41 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,719] INFO [Partition __consumer_offsets-41 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-41 (kafka.cluster.Partition) [2019-08-23 17:12:05,720] INFO [Partition __consumer_offsets-41 broker=0] Log loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,720] INFO [Partition __consumer_offsets-41 broker=0] __consumer_offsets-41 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,723] INFO [Log partition=__consumer_offsets-32, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,723] INFO [Log partition=__consumer_offsets-32, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,724] INFO Created log for partition __consumer_offsets-32 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-32 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,724] INFO [Partition __consumer_offsets-32 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-32 (kafka.cluster.Partition) [2019-08-23 17:12:05,724] INFO [Partition __consumer_offsets-32 broker=0] Log loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,724] INFO [Partition __consumer_offsets-32 broker=0] __consumer_offsets-32 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,727] INFO [Log partition=__consumer_offsets-3, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,728] INFO [Log partition=__consumer_offsets-3, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,728] INFO Created log for partition __consumer_offsets-3 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-3 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,728] INFO [Partition __consumer_offsets-3 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-3 (kafka.cluster.Partition) [2019-08-23 17:12:05,728] INFO [Partition __consumer_offsets-3 broker=0] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,728] INFO [Partition __consumer_offsets-3 broker=0] __consumer_offsets-3 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,731] INFO [Log partition=__consumer_offsets-13, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [2019-08-23 17:12:05,732] INFO [Log partition=__consumer_offsets-13, dir=/var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 0 ms (kafka.log.Log) [2019-08-23 17:12:05,732] INFO Created log for partition __consumer_offsets-13 in /var/folders/jq/ybhfplxd48xc40q696mdj66m0000gp/T/junit3075285003139948223/junit1766814557825492466/__consumer_offsets-13 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.bytes -> 104857600, retention.ms -> 604800000, flush.messages -> 9223372036854775807, message.format.version -> 2.3-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [2019-08-23 17:12:05,732] INFO [Partition __consumer_offsets-13 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-13 (kafka.cluster.Partition) [2019-08-23 17:12:05,732] INFO [Partition __consumer_offsets-13 broker=0] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition) [2019-08-23 17:12:05,732] INFO [Partition __consumer_offsets-13 broker=0] __consumer_offsets-13 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [2019-08-23 17:12:05,753] INFO stream-client [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams) [2019-08-23 17:12:05,753] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] Starting (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:05,753] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] State transition from CREATED to STARTING (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:05,753] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Subscribed to pattern: 'input-topic' (org.apache.kafka.clients.consumer.KafkaConsumer) [2019-08-23 17:12:05,754] INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:57756] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = true exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = consumerApp group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.IntegerDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.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 value.deserializer = class org.apache.kafka.common.serialization.IntegerDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2019-08-23 17:12:05,756] INFO [Consumer clientId=consumer-1, groupId=consumerApp] Subscribed to topic(s): output-topic (org.apache.kafka.clients.consumer.KafkaConsumer) [2019-08-23 17:12:05,757] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Discovered group coordinator localhost:57756 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,760] INFO [Consumer clientId=consumer-1, groupId=consumerApp] Discovered group coordinator localhost:57756 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,760] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,761] INFO [Consumer clientId=consumer-1, groupId=consumerApp] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,781] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,781] INFO [Consumer clientId=consumer-1, groupId=consumerApp] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,788] INFO [GroupCoordinator 0]: Preparing to rebalance group streamsApp in state PreparingRebalance with old generation 0 (__consumer_offsets-6) (reason: Adding new member streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer-35501476-e96b-48b9-90d2-e98716e7be56 with group instanceid None) (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:05,788] INFO [GroupCoordinator 0]: Preparing to rebalance group consumerApp in state PreparingRebalance with old generation 0 (__consumer_offsets-5) (reason: Adding new member consumer-1-afda303e-7b9b-43e3-97a2-e689c10b7fad with group instanceid None) (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:05,793] INFO [GroupCoordinator 0]: Stabilized group streamsApp generation 1 (__consumer_offsets-6) (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:05,795] INFO [GroupCoordinator 0]: Stabilized group consumerApp generation 1 (__consumer_offsets-5) (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:05,798] WARN Unable to assign 1 of 1 standby tasks for task [0_0]. There is not enough available capacity. You should increase the number of threads and/or application instances to maintain the requested number of standby replicas. (org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor) [2019-08-23 17:12:05,798] WARN Unable to assign 1 of 1 standby tasks for task [0_1]. There is not enough available capacity. You should increase the number of threads and/or application instances to maintain the requested number of standby replicas. (org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor) [2019-08-23 17:12:05,798] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer] Assigned tasks to clients as {581aeca8-9139-4575-8b05-a72a128e2645=[activeTasks: ([0_0, 0_1]) standbyTasks: ([]) assignedTasks: ([0_0, 0_1]) prevActiveTasks: ([]) prevStandbyTasks: ([]) prevAssignedTasks: ([]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2019-08-23 17:12:05,799] INFO [GroupCoordinator 0]: Assignment received from leader for group consumerApp for generation 1 (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:05,800] INFO [GroupCoordinator 0]: Assignment received from leader for group streamsApp for generation 1 (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:05,815] INFO [Consumer clientId=streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-consumer, groupId=streamsApp] Discovered group coordinator localhost:57756 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,817] INFO [Consumer clientId=consumer-1, groupId=consumerApp] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,817] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Successfully joined group with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,817] INFO [Consumer clientId=streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-consumer, groupId=streamsApp] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,821] INFO [Consumer clientId=streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-consumer, groupId=streamsApp] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:05,823] INFO [GroupCoordinator 0]: Preparing to rebalance group streamsApp in state PreparingRebalance with old generation 1 (__consumer_offsets-6) (reason: Adding new member streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-consumer-887ce0e4-fc16-4287-b0ce-cc6ab1301d97 with group instanceid None) (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:05,824] INFO [Consumer clientId=consumer-1, groupId=consumerApp] Adding newly assigned partitions: output-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:05,824] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Adding newly assigned partitions: input-topic-0, input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:05,824] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:05,836] INFO [Consumer clientId=consumer-1, groupId=consumerApp] Found no committed offset for partition output-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:05,839] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] partition assignment took 15 ms. current active tasks: [0_0, 0_1] current standby tasks: [] previous active tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:05,840] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Found no committed offset for partition input-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:05,840] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Found no committed offset for partition input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:05,851] INFO [Consumer clientId=consumer-1, groupId=consumerApp] Resetting offset for partition output-topic-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2019-08-23 17:12:05,851] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Resetting offset for partition input-topic-0 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2019-08-23 17:12:05,851] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Resetting offset for partition input-topic-1 to offset 0. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2019-08-23 17:12:05,854] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Found no committed offset for partition input-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:05,944] INFO Opening store source-table in regular mode (org.apache.kafka.streams.state.internals.RocksDBTimestampedStore) [2019-08-23 17:12:05,948] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Found no committed offset for partition input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:05,960] INFO Opening store source-table in regular mode (org.apache.kafka.streams.state.internals.RocksDBTimestampedStore) [2019-08-23 17:12:05,967] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer) [2019-08-23 17:12:05,972] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer) [2019-08-23 17:12:05,972] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:05,972] INFO stream-client [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams) (1, 0) (1, 1) (1, 2) (1, 3) (1, 4) (1, 5) (1, 6) (1, 7) (1, 8) (1, 9) (1, 10) (1, 11) (1, 12) (1, 13) (1, 14) (1, 15) (1, 16) (1, 17) (1, 18) (1, 19) (1, 20) (1, 21) (1, 22) (1, 23) (1, 24) (1, 25) (1, 26) (1, 27) (1, 28) (1, 29) (1, 30) (1, 31) (1, 32) (1, 33) (1, 34) (1, 35) (1, 36) (1, 37) (1, 38) (1, 39) (1, 40) (1, 41) (1, 42) (1, 43) (1, 44) (1, 45) (1, 46) (1, 47) (1, 48) (1, 49) (1, 50) (1, 51) (1, 52) (1, 53) (1, 54) (1, 55) (1, 56) (1, 57) (1, 58) (1, 59) (1, 60) (1, 61) (1, 62) (1, 63) (1, 64) (1, 65) (1, 66) (1, 67) (1, 68) (1, 69) (1, 70) (1, 71) (1, 72) (1, 73) (1, 74) (1, 75) (1, 76) (1, 77) (1, 78) (1, 79) (1, 80) (1, 81) (1, 82) (1, 83) (1, 84) (1, 85) (1, 86) (1, 87) (1, 88) (1, 89) (1, 90) (1, 91) (1, 92) (1, 93) (1, 94) (1, 95) (1, 96) (1, 97) (1, 98) (1, 99) [2019-08-23 17:12:06,633] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController) (1, 100) (1, 101) (1, 102) (1, 103) (1, 104) (1, 105) (1, 106) (1, 107) (1, 108) (1, 109) (1, 110) (1, 111) (1, 112) (1, 113) (1, 114) (1, 115) (1, 116) (1, 117) (1, 118) (1, 119) (1, 120) (1, 121) (1, 122) (1, 123) (1, 124) (1, 125) (1, 126) (1, 127) (1, 128) (1, 129) (1, 130) (1, 131) (1, 132) (1, 133) (1, 134) (1, 135) (1, 136) (1, 137) (1, 138) (1, 139) (1, 140) (1, 141) (1, 142) (1, 143) (1, 144) (1, 145) (1, 146) (1, 147) (1, 148) (1, 149) (1, 150) (1, 151) (1, 152) (1, 153) (1, 154) (1, 155) (1, 156) (1, 157) (1, 158) (1, 159) (1, 160) (1, 161) (1, 162) (1, 163) (1, 164) (1, 165) (1, 166) (1, 167) (1, 168) (1, 169) (1, 170) (1, 171) (1, 172) (1, 173) (1, 174) (1, 175) (1, 176) (1, 177) (1, 178) (1, 179) (1, 180) (1, 181) (1, 182) [2019-08-23 17:12:07,151] INFO [Consumer clientId=consumer-1, groupId=consumerApp] Revoke previously assigned partitions output-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:07,151] INFO [Consumer clientId=consumer-1, groupId=consumerApp] Member consumer-1-afda303e-7b9b-43e3-97a2-e689c10b7fad sending LeaveGroup request to coordinator localhost:57756 (id: 2147483647 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) (1, 183) [2019-08-23 17:12:07,154] INFO [GroupCoordinator 0]: Member[group.instance.id None, member.id consumer-1-afda303e-7b9b-43e3-97a2-e689c10b7fad] in group consumerApp has left, removing it from the group (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:07,155] INFO [GroupCoordinator 0]: Preparing to rebalance group consumerApp in state PreparingRebalance with old generation 1 (__consumer_offsets-5) (reason: removing member consumer-1-afda303e-7b9b-43e3-97a2-e689c10b7fad on LeaveGroup) (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:07,155] INFO [GroupCoordinator 0]: Group consumerApp with generation 2 is now empty (__consumer_offsets-5) (kafka.coordinator.group.GroupCoordinator) (1, 184) [2019-08-23 17:12:07,158] INFO stream-client [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca] State transition from REBALANCING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams) [2019-08-23 17:12:07,159] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:07,159] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] State transition from STARTING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread) (1, 185) (1, 186) (1, 187) (1, 188) (1, 189) (1, 190) (1, 191) (1, 192) (1, 193) (1, 194) (1, 195) (1, 196) (1, 197) (1, 198) [2019-08-23 17:12:07,240] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] Shutting down (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:07,240] INFO [Consumer clientId=streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer) (1, 199) (1, 200) (1, 201) (1, 202) (1, 203) (1, 204) (1, 205) (1, 206) (1, 207) (1, 208) (1, 209) (1, 210) (1, 211) (1, 212) (1, 213) (1, 214) (1, 215) (1, 216) (1, 217) (1, 218) (1, 219) (1, 220) (1, 221) (1, 222) (1, 223) (1, 224) (1, 225) (1, 226) (1, 227) (1, 228) (1, 229) (1, 230) (1, 231) (1, 232) (1, 233) (1, 234) (1, 235) (1, 236) (1, 237) (1, 238) (1, 239) (1, 240) (1, 241) (1, 242) (1, 243) (1, 244) (1, 245) (1, 246) (1, 247) (1, 248) (1, 249) (1, 250) (1, 251) (1, 252) (1, 253) (1, 254) (1, 255) (1, 256) (1, 257) (1, 258) (1, 259) (1, 260) (1, 261) (1, 262) (1, 263) (1, 264) (1, 265) (1, 266) (1, 267) (1, 268) (1, 269) (1, 270) (1, 271) (1, 272) (1, 273) (1, 274) (1, 275) (1, 276) (1, 277) (1, 278) (1, 279) (1, 280) (1, 281) (1, 282) (1, 283) (1, 284) (1, 285) (1, 286) (1, 287) (1, 288) (1, 289) (1, 290) (1, 291) (1, 292) (1, 293) (1, 294) (1, 295) (1, 296) (1, 297) (1, 298) (1, 299) (1, 300) (1, 301) (1, 302) (1, 303) (1, 304) (1, 305) (1, 306) (1, 307) (1, 308) (1, 309) (1, 310) (1, 311) (1, 312) (1, 313) (1, 314) (1, 315) (1, 316) (1, 317) (1, 318) (1, 319) (1, 320) (1, 321) (1, 322) (1, 323) (1, 324) (1, 325) (1, 326) (1, 327) (1, 328) (1, 329) (1, 330) (1, 331) (1, 332) (1, 333) (1, 334) (1, 335) (1, 336) (1, 337) (1, 338) (1, 339) (1, 340) (1, 341) (1, 342) (1, 343) (1, 344) (1, 345) (1, 346) (1, 347) (1, 348) (1, 349) (1, 350) (1, 351) (1, 352) (1, 353) (1, 354) (1, 355) (1, 356) (1, 357) (1, 358) (1, 359) (1, 360) (1, 361) (1, 362) (1, 363) (1, 364) (1, 365) (1, 366) (1, 367) (1, 368) (1, 369) (1, 370) (1, 371) (1, 372) (1, 373) (1, 374) (1, 375) (1, 376) (1, 377) (1, 378) (1, 379) (1, 380) (1, 381) (1, 382) (1, 383) (1, 384) (1, 385) (1, 386) (1, 387) (1, 388) (1, 389) (1, 390) (1, 391) (1, 392) (1, 393) (1, 394) (1, 395) (1, 396) (1, 397) (1, 398) (1, 399) (1, 400) (1, 401) (1, 402) (1, 403) (1, 404) (1, 405) (1, 406) (1, 407) (1, 408) (1, 409) (1, 410) (1, 411) (1, 412) (1, 413) (1, 414) (1, 415) (1, 416) (1, 417) (1, 418) (1, 419) (1, 420) (1, 421) (1, 422) (1, 423) (1, 424) (1, 425) (1, 426) (1, 427) (1, 428) (1, 429) (1, 430) (1, 431) (1, 432) (1, 433) (1, 434) (1, 435) (1, 436) (1, 437) (1, 438) (1, 439) (1, 440) (1, 441) (1, 442) (1, 443) (1, 444) (1, 445) (1, 446) (1, 447) (1, 448) (1, 449) (1, 450) (1, 451) (1, 452) (1, 453) (1, 454) (1, 455) (1, 456) (1, 457) (1, 458) (1, 459) (1, 460) (1, 461) (1, 462) (1, 463) (1, 464) (1, 465) (1, 466) (1, 467) (1, 468) (1, 469) (1, 470) (1, 471) (1, 472) (1, 473) (1, 474) (1, 475) (1, 476) (1, 477) [2019-08-23 17:12:08,954] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) (1, 478) (1, 479) (1, 480) (1, 481) (1, 482) (1, 483) (1, 484) (1, 485) (1, 486) (1, 487) (1, 488) (1, 489) (1, 490) (1, 491) (1, 492) (1, 493) (1, 494) (1, 495) (1, 496) (1, 497) (1, 498) (1, 499) [2019-08-23 17:12:09,088] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Revoke previously assigned partitions input-topic-0, input-topic-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:09,088] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,088] INFO stream-client [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645] State transition from RUNNING to REBALANCING (org.apache.kafka.streams.KafkaStreams) [2019-08-23 17:12:09,093] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer) [2019-08-23 17:12:09,093] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] partition revocation took 5 ms. suspended active tasks: [0_0, 0_1] suspended standby tasks: [] (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,093] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:09,095] INFO [GroupCoordinator 0]: Stabilized group streamsApp generation 2 (__consumer_offsets-6) (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:09,096] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer] Assigned tasks to clients as {1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca=[activeTasks: ([0_1]) standbyTasks: ([0_0]) assignedTasks: ([0_0, 0_1]) prevActiveTasks: ([]) prevStandbyTasks: ([]) prevAssignedTasks: ([]) capacity: 1], 581aeca8-9139-4575-8b05-a72a128e2645=[activeTasks: ([0_0]) standbyTasks: ([0_1]) assignedTasks: ([0_0, 0_1]) prevActiveTasks: ([0_0, 0_1]) prevStandbyTasks: ([]) prevAssignedTasks: ([0_0, 0_1]) capacity: 1]}. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2019-08-23 17:12:09,097] INFO [GroupCoordinator 0]: Assignment received from leader for group streamsApp for generation 2 (kafka.coordinator.group.GroupCoordinator) [2019-08-23 17:12:09,098] INFO [Consumer clientId=streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1-consumer, groupId=streamsApp] Successfully joined group with generation 2 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:09,098] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Successfully joined group with generation 2 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2019-08-23 17:12:09,099] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Adding newly assigned partitions: input-topic-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:09,099] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] State transition from PARTITIONS_REVOKED to PARTITIONS_ASSIGNED (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,099] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,099] INFO stream-thread [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,100] INFO stream-client [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca] State transition from PENDING_SHUTDOWN to NOT_RUNNING (org.apache.kafka.streams.KafkaStreams) [2019-08-23 17:12:09,101] INFO stream-client [streamsApp-1e4ee8e2-e5fb-4571-a25a-0084b3c0a4ca] Streams client stopped completely (org.apache.kafka.streams.KafkaStreams) [2019-08-23 17:12:09,101] INFO stream-client [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645] State transition from REBALANCING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams) [2019-08-23 17:12:09,101] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,101] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] State transition from PARTITIONS_ASSIGNED to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,105] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] partition assignment took 6 ms. current active tasks: [0_0] current standby tasks: [0_1] previous active tasks: [0_0, 0_1] (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,106] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-consumer, groupId=streamsApp] Setting offset for partition input-topic-0 to the committed offset FetchPosition{offset=500, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=localhost:57756 (id: 0 rack: null), epoch=0}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2019-08-23 17:12:09,187] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] Shutting down (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,191] INFO [Consumer clientId=streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer) [2019-08-23 17:12:09,193] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,193] INFO stream-thread [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread) [2019-08-23 17:12:09,193] INFO stream-client [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645] State transition from PENDING_SHUTDOWN to NOT_RUNNING (org.apache.kafka.streams.KafkaStreams) [2019-08-23 17:12:09,193] INFO stream-client [streamsApp-581aeca8-9139-4575-8b05-a72a128e2645] Streams client stopped completely (org.apache.kafka.streams.KafkaStreams)