[2021-06-17 15:31:24,302] INFO [main] StreamsConfig values: acceptable.recovery.lag = 10000 application.id = wordcount-lambda-example application.server = bootstrap.servers = [localhost:9092] buffered.records.per.partition = 1000 built.in.metrics.version = latest cache.max.bytes.buffering = 0 client.id = wordcount-lambda-example-client commit.interval.ms = 10000 connections.max.idle.ms = 540000 default.deserialization.exception.handler = class org.apache.kafka.streams.errors.LogAndFailExceptionHandler default.key.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde default.production.exception.handler = class org.apache.kafka.streams.errors.DefaultProductionExceptionHandler default.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp default.value.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde default.windowed.key.serde.inner = null default.windowed.value.serde.inner = null max.task.idle.ms = 0 max.warmup.replicas = 2 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 num.standby.replicas = 2 num.stream.threads = 4 partition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper poll.ms = 100 probing.rebalance.interval.ms = 600000 processing.guarantee = at_least_once receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 replication.factor = 1 request.timeout.ms = 40000 retries = 0 retry.backoff.ms = 100 rocksdb.config.setter = null security.protocol = PLAINTEXT send.buffer.bytes = 131072 state.cleanup.delay.ms = 600000 state.dir = /var/folders/t1/_165jr6j6lv6n4d2z66hpr8w0000gn/T/confluent15465369150579959026 task.timeout.ms = 300000 topology.optimization = none upgrade.from = null window.size.ms = null windowstore.changelog.additional.retention.ms = 86400000 (org.apache.kafka.streams.StreamsConfig) [2021-06-17 15:31:24,319] WARN [main] Using an OS temp directory in the state.dir property can cause failures with writing the checkpoint file due to the fact that this directory can be cleared by the OS. Resolved state.dir: [/var/folders/t1/_165jr6j6lv6n4d2z66hpr8w0000gn/T/confluent15465369150579959026] (org.apache.kafka.streams.processor.internals.StateDirectory) [2021-06-17 15:31:24,427] INFO [main] No process id found on disk, got fresh process id c34dcb8a-40de-4e0b-afc7-13c0c7f55426 (org.apache.kafka.streams.processor.internals.StateDirectory) [2021-06-17 15:31:24,463] INFO [main] AdminClientConfig values: bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-admin connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 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 security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [2021-06-17 15:31:24,606] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,606] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,606] INFO [main] Kafka startTimeMs: 1623907884603 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,610] INFO [main] stream-client [wordcount-lambda-example-client] Kafka Streams version: 6.2.0-ccs (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:24,611] INFO [main] stream-client [wordcount-lambda-example-client] Kafka Streams commit ID: 1a5755cf9401c84f (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:24,626] INFO [main] ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = none bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-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 internal.throw.on.fetch.stable.offset.unsupported = 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 = 1000 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null 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) [2021-06-17 15:31:24,652] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,652] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,652] INFO [main] Kafka startTimeMs: 1623907884652 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,661] INFO [main] ProducerConfig values: acks = 1 batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-1-producer compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] internal.auto.downgrade.txn.commit = false key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 100 max.block.ms = 60000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 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 security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [2021-06-17 15:31:24,683] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,683] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,683] INFO [main] Kafka startTimeMs: 1623907884683 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,689] INFO [main] ConsumerConfig values: allow.auto.create.topics = false auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-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 = wordcount-lambda-example group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = false internal.throw.on.fetch.stable.offset.unsupported = 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 = 1000 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null 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) [2021-06-17 15:31:24,698] INFO [main] stream-thread [wordcount-lambda-example-client-StreamThread-1-consumer] Cooperative rebalancing enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration) [2021-06-17 15:31:24,711] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,711] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,711] INFO [main] Kafka startTimeMs: 1623907884711 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,715] INFO [main] ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = none bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-2-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 internal.throw.on.fetch.stable.offset.unsupported = 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 = 1000 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null 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) [2021-06-17 15:31:24,720] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,720] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,720] INFO [main] Kafka startTimeMs: 1623907884719 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,720] INFO [main] ProducerConfig values: acks = 1 batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-2-producer compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] internal.auto.downgrade.txn.commit = false key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 100 max.block.ms = 60000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 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 security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [2021-06-17 15:31:24,724] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,724] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,724] INFO [main] Kafka startTimeMs: 1623907884724 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,725] INFO [main] ConsumerConfig values: allow.auto.create.topics = false auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-2-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 = wordcount-lambda-example group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = false internal.throw.on.fetch.stable.offset.unsupported = 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 = 1000 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null 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) [2021-06-17 15:31:24,729] INFO [main] stream-thread [wordcount-lambda-example-client-StreamThread-2-consumer] Cooperative rebalancing enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration) [2021-06-17 15:31:24,731] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,731] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,731] INFO [main] Kafka startTimeMs: 1623907884731 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,732] INFO [main] ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = none bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-3-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 internal.throw.on.fetch.stable.offset.unsupported = 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 = 1000 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null 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) [2021-06-17 15:31:24,735] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,735] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,735] INFO [main] Kafka startTimeMs: 1623907884735 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,736] INFO [main] ProducerConfig values: acks = 1 batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-3-producer compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] internal.auto.downgrade.txn.commit = false key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 100 max.block.ms = 60000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 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 security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [2021-06-17 15:31:24,739] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,739] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,739] INFO [main] Kafka startTimeMs: 1623907884739 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,740] INFO [main] ConsumerConfig values: allow.auto.create.topics = false auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-3-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 = wordcount-lambda-example group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = false internal.throw.on.fetch.stable.offset.unsupported = 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 = 1000 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null 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) [2021-06-17 15:31:24,742] INFO [main] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Cooperative rebalancing enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration) [2021-06-17 15:31:24,744] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,744] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,744] INFO [main] Kafka startTimeMs: 1623907884744 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,745] INFO [main] ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = none bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-4-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 internal.throw.on.fetch.stable.offset.unsupported = 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 = 1000 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null 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) [2021-06-17 15:31:24,747] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,747] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,747] INFO [main] Kafka startTimeMs: 1623907884747 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,748] INFO [main] ProducerConfig values: acks = 1 batch.size = 16384 bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-4-producer compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] internal.auto.downgrade.txn.commit = false key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 100 max.block.ms = 60000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 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 security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [2021-06-17 15:31:24,750] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,750] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,751] INFO [main] Kafka startTimeMs: 1623907884750 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,751] INFO [main] ConsumerConfig values: allow.auto.create.topics = false auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = wordcount-lambda-example-client-StreamThread-4-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 = wordcount-lambda-example group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = false internal.throw.on.fetch.stable.offset.unsupported = 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 = 1000 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 security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null 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) [2021-06-17 15:31:24,754] INFO [main] stream-thread [wordcount-lambda-example-client-StreamThread-4-consumer] Cooperative rebalancing enabled now (org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration) [2021-06-17 15:31:24,755] INFO [main] Kafka version: 6.2.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,755] INFO [main] Kafka commitId: 1a5755cf9401c84f (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,755] INFO [main] Kafka startTimeMs: 1623907884755 (org.apache.kafka.common.utils.AppInfoParser) [2021-06-17 15:31:24,761] INFO [main] stream-client [wordcount-lambda-example-client] State transition from CREATED to REBALANCING (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:24,763] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Subscribed to topic(s): streams-plaintext-input, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:24,763] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Subscribed to topic(s): streams-plaintext-input, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:24,763] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Subscribed to topic(s): streams-plaintext-input, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:24,763] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Subscribed to topic(s): streams-plaintext-input, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:24,871] INFO [kafka-producer-network-thread | wordcount-lambda-example-client-StreamThread-1-producer] [Producer clientId=wordcount-lambda-example-client-StreamThread-1-producer] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:24,871] INFO [kafka-producer-network-thread | wordcount-lambda-example-client-StreamThread-3-producer] [Producer clientId=wordcount-lambda-example-client-StreamThread-3-producer] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:24,871] INFO [kafka-producer-network-thread | wordcount-lambda-example-client-StreamThread-4-producer] [Producer clientId=wordcount-lambda-example-client-StreamThread-4-producer] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:24,871] INFO [kafka-producer-network-thread | wordcount-lambda-example-client-StreamThread-2-producer] [Producer clientId=wordcount-lambda-example-client-StreamThread-2-producer] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:24,873] WARN [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 2 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:24,873] WARN [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 2 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:24,873] WARN [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 2 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:24,873] WARN [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 2 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:24,876] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:24,876] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:24,876] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:24,876] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:24,877] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Discovered group coordinator localhost:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,877] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Discovered group coordinator localhost:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,877] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Discovered group coordinator localhost:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,877] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Discovered group coordinator localhost:9092 (id: 2147483647 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,878] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,878] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,878] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,879] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,891] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,891] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,891] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,891] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,894] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=1, memberId='wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,894] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=1, memberId='wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,894] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=1, memberId='wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,894] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=1, memberId='wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:24,981] WARN [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 7 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:24,981] WARN [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 8 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:24,981] WARN [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 8 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:24,981] WARN [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 8 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:25,082] WARN [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 9 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:25,082] WARN [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 9 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:25,082] WARN [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 9 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:25,183] WARN [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 10 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:25,183] WARN [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 10 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:25,183] WARN [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Error while fetching metadata with correlation id 10 : {wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2021-06-17 15:31:25,460] WARN [wordcount-lambda-example-client-StreamThread-3] Unable to assign 2 of 2 standby tasks for task [1_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.HighAvailabilityTaskAssignor) [2021-06-17 15:31:25,460] WARN [wordcount-lambda-example-client-StreamThread-3] Unable to assign 2 of 2 standby tasks for task [1_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.HighAvailabilityTaskAssignor) [2021-06-17 15:31:25,465] INFO [wordcount-lambda-example-client-StreamThread-3] Decided on assignment: {c34dcb8a-40de-4e0b-afc7-13c0c7f55426=[activeTasks: ([0_0, 0_1, 1_0, 1_1]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([1_0=0, 1_1=0]) capacity: 4 assigned: 4]} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor) [2021-06-17 15:31:25,467] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Assigned tasks [0_0, 0_1, 1_0, 1_1] including stateful [1_0, 1_1] to clients as: c34dcb8a-40de-4e0b-afc7-13c0c7f55426=[activeTasks: ([0_0, 0_1, 1_0, 1_1]) standbyTasks: ([])]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:25,472] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Client c34dcb8a-40de-4e0b-afc7-13c0c7f55426 per-consumer assignment: prev owned active {} prev owned standby {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[], wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=[], wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=[]} assigned active {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[1_0], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[1_1], wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=[0_0], wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=[0_1]} revoking active {} assigned standby {} (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:25,472] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:25,473] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Finished assignment for group at generation 1: {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0], userDataSize=48), wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=Assignment(partitions=[streams-plaintext-input-0], userDataSize=48), wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1], userDataSize=48), wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=Assignment(partitions=[streams-plaintext-input-1], userDataSize=48)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,477] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Requesting to re-join the group and trigger rebalance since the assignment metadata has changed from (version3: {streams-plaintext-input=2}) to (version4: {streams-plaintext-input=2, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=2}) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,477] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Requesting to re-join the group and trigger rebalance since the assignment metadata has changed from (version3: {streams-plaintext-input=2}) to (version4: {streams-plaintext-input=2, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=2}) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,478] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=1, memberId='wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:25,478] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=1, memberId='wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:25,478] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=1, memberId='wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:25,478] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=1, memberId='wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:25,479] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Requesting to re-join the group and trigger rebalance since the assignment metadata has changed from (version3: {streams-plaintext-input=2}) to (version4: {streams-plaintext-input=2, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=2}) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,479] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0] Current owned partitions: [] Added partitions (assigned - owned): [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,479] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Requesting to re-join the group and trigger rebalance since the assignment metadata has changed from (version3: {streams-plaintext-input=2}) to (version4: {streams-plaintext-input=2, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=2}) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,479] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1] Current owned partitions: [] Added partitions (assigned - owned): [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,479] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [streams-plaintext-input-1] Current owned partitions: [] Added partitions (assigned - owned): [streams-plaintext-input-1] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,480] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [streams-plaintext-input-0] Current owned partitions: [] Added partitions (assigned - owned): [streams-plaintext-input-0] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,480] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[streams-plaintext-input-0], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,480] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,479] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,480] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[streams-plaintext-input-1], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,481] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:25,481] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:25,481] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:25,481] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:25,483] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] Handle new assignment with: New active tasks: [0_1] New standby tasks: [] Existing active tasks: [] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:25,483] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] Handle new assignment with: New active tasks: [0_0] New standby tasks: [] Existing active tasks: [] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:25,483] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2] Handle new assignment with: New active tasks: [1_1] New standby tasks: [] Existing active tasks: [] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:25,483] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] Handle new assignment with: New active tasks: [1_0] New standby tasks: [] Existing active tasks: [] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:25,502] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,502] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: streams-plaintext-input-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,502] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,502] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: streams-plaintext-input-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,503] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Requesting to re-join the group and trigger rebalance since the assignment metadata has changed from (version3: {streams-plaintext-input=2}) to (version4: {streams-plaintext-input=2, wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition=2}) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,504] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:25,511] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:25,513] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition streams-plaintext-input-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,517] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] task [0_1] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:25,522] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition streams-plaintext-input-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,528] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Resetting offset for partition streams-plaintext-input-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:25,580] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] task [0_0] Initialized (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:25,580] INFO [kafka-coordinator-heartbeat-thread | wordcount-lambda-example] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,584] INFO [kafka-coordinator-heartbeat-thread | wordcount-lambda-example] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:25,989] INFO [wordcount-lambda-example-client-StreamThread-2] Opening store KSTREAM-AGGREGATE-STATE-STORE-0000000003 in regular mode (org.apache.kafka.streams.state.internals.RocksDBTimestampedStore) [2021-06-17 15:31:25,989] INFO [wordcount-lambda-example-client-StreamThread-1] Opening store KSTREAM-AGGREGATE-STATE-STORE-0000000003 in regular mode (org.apache.kafka.streams.state.internals.RocksDBTimestampedStore) [2021-06-17 15:31:25,992] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2] task [1_1] State store KSTREAM-AGGREGATE-STATE-STORE-0000000003 did not find checkpoint offset, hence would default to the starting offset at changelog wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-1 (org.apache.kafka.streams.processor.internals.ProcessorStateManager) [2021-06-17 15:31:25,992] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2] task [1_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:25,992] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] task [1_0] State store KSTREAM-AGGREGATE-STATE-STORE-0000000003 did not find checkpoint offset, hence would default to the starting offset at changelog wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-0 (org.apache.kafka.streams.processor.internals.ProcessorStateManager) [2021-06-17 15:31:25,993] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] task [1_0] Initialized (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:25,999] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-restore-consumer, groupId=null] Subscribed to partition(s): wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-1 (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:25,999] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-restore-consumer, groupId=null] Subscribed to partition(s): wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:26,000] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-restore-consumer, groupId=null] Seeking to EARLIEST offset of partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:26,000] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-restore-consumer, groupId=null] Seeking to EARLIEST offset of partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:26,004] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-restore-consumer, groupId=null] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:26,004] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-restore-consumer, groupId=null] Cluster ID: yO9eJzpGRG6RCRYDz4MoIw (org.apache.kafka.clients.Metadata) [2021-06-17 15:31:26,007] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:26,007] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-restore-consumer, groupId=null] Resetting offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:26,111] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] Finished restoring changelog wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-0 to store KSTREAM-AGGREGATE-STATE-STORE-0000000003 with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader) [2021-06-17 15:31:26,111] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2] Finished restoring changelog wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-1 to store KSTREAM-AGGREGATE-STATE-STORE-0000000003 with a total number of 0 records (org.apache.kafka.streams.processor.internals.StoreChangelogReader) [2021-06-17 15:31:26,113] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Resetting offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:26,113] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Resetting offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:26,114] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:26,114] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:26,117] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2] task [1_1] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:26,117] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] task [1_0] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:27,898] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,898] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,898] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,898] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,898] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,898] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,901] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=2, memberId='wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,901] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=2, memberId='wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,901] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=2, memberId='wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,902] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=2, memberId='wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,908] WARN [wordcount-lambda-example-client-StreamThread-3] Unable to assign 2 of 2 standby tasks for task [1_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.HighAvailabilityTaskAssignor) [2021-06-17 15:31:27,908] WARN [wordcount-lambda-example-client-StreamThread-3] Unable to assign 2 of 2 standby tasks for task [1_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.HighAvailabilityTaskAssignor) [2021-06-17 15:31:27,908] INFO [wordcount-lambda-example-client-StreamThread-3] Decided on assignment: {c34dcb8a-40de-4e0b-afc7-13c0c7f55426=[activeTasks: ([0_0, 0_1, 1_0, 1_1]) standbyTasks: ([]) prevActiveTasks: ([0_0, 0_1, 1_0, 1_1]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([1_0=-2, 1_1=-2]) taskLagTotals: ([1_0=-2, 1_1=-2]) capacity: 4 assigned: 4]} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor) [2021-06-17 15:31:27,908] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Assigned tasks [0_0, 0_1, 1_0, 1_1] including stateful [1_0, 1_1] to clients as: c34dcb8a-40de-4e0b-afc7-13c0c7f55426=[activeTasks: ([0_0, 0_1, 1_0, 1_1]) standbyTasks: ([])]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:27,909] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Client c34dcb8a-40de-4e0b-afc7-13c0c7f55426 per-consumer assignment: prev owned active {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[1_0], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[1_1], wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=[0_0], wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=[0_1]} prev owned standby {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[], wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=[], wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=[]} assigned active {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[1_0], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[1_1], wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=[0_0], wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=[0_1]} revoking active {} assigned standby {} (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:27,909] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:27,909] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Finished assignment for group at generation 2: {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0], userDataSize=48), wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=Assignment(partitions=[streams-plaintext-input-0], userDataSize=48), wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1], userDataSize=48), wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=Assignment(partitions=[streams-plaintext-input-1], userDataSize=48)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,909] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition streams-plaintext-input-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,910] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] task [0_0] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:27,910] INFO [wordcount-lambda-example-client-StreamThread-3] stream-client [wordcount-lambda-example-client] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:27,910] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=2, memberId='wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,910] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=2, memberId='wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,910] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=2, memberId='wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,910] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [streams-plaintext-input-1] Current owned partitions: [streams-plaintext-input-1] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,910] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=2, memberId='wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0] Current owned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[streams-plaintext-input-1], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,910] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1] Current owned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:27,912] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2] Handle new assignment with: New active tasks: [1_1] New standby tasks: [] Existing active tasks: [1_1] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] Handle new assignment with: New active tasks: [1_0] New standby tasks: [] Existing active tasks: [1_0] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:27,911] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [streams-plaintext-input-0] Current owned partitions: [streams-plaintext-input-0] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,912] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[streams-plaintext-input-0], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,912] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:27,912] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,912] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,912] INFO [wordcount-lambda-example-client-StreamThread-1] stream-client [wordcount-lambda-example-client] State transition from RUNNING to REBALANCING (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:27,912] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] Handle new assignment with: New active tasks: [0_1] New standby tasks: [] Existing active tasks: [0_1] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:27,912] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] Handle new assignment with: New active tasks: [0_0] New standby tasks: [] Existing active tasks: [0_0] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:27,913] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,913] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,913] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition streams-plaintext-input-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:27,914] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Resetting offset for partition streams-plaintext-input-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:28,013] INFO [wordcount-lambda-example-client-StreamThread-3] stream-client [wordcount-lambda-example-client] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:36,909] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,909] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,909] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,909] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,913] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,913] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,913] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,913] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,915] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=3, memberId='wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,916] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=3, memberId='wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,915] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=3, memberId='wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,916] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=3, memberId='wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,920] WARN [wordcount-lambda-example-client-StreamThread-3] Unable to assign 1 of 2 standby tasks for task [1_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.HighAvailabilityTaskAssignor) [2021-06-17 15:31:36,920] WARN [wordcount-lambda-example-client-StreamThread-3] Unable to assign 1 of 2 standby tasks for task [1_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.HighAvailabilityTaskAssignor) [2021-06-17 15:31:36,921] INFO [wordcount-lambda-example-client-StreamThread-3] Decided on assignment: {ae1e0fef-92c1-4431-800b-8aa4ad7567fa=[activeTasks: ([0_0, 1_0]) standbyTasks: ([1_1]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([1_0=0, 1_1=0]) capacity: 4 assigned: 3], c34dcb8a-40de-4e0b-afc7-13c0c7f55426=[activeTasks: ([0_1, 1_1]) standbyTasks: ([1_0]) prevActiveTasks: ([0_0, 0_1, 1_0, 1_1]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([1_0=-2, 1_1=-2]) taskLagTotals: ([1_0=-2, 1_1=-2]) capacity: 4 assigned: 3]} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor) [2021-06-17 15:31:36,921] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Assigned tasks [0_0, 0_1, 1_0, 1_1] including stateful [1_0, 1_1] to clients as: ae1e0fef-92c1-4431-800b-8aa4ad7567fa=[activeTasks: ([0_0, 1_0]) standbyTasks: ([1_1])] c34dcb8a-40de-4e0b-afc7-13c0c7f55426=[activeTasks: ([0_1, 1_1]) standbyTasks: ([1_0])]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,921] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Removing task 1_0 from wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7 active assignment until it is safely revoked in followup rebalance (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,921] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Adding removed stateful active task 1_0 as a standby for wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7 before it is revoked in followup rebalance (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,921] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Requesting followup rebalance be scheduled immediately by wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7 due to tasks changing ownership. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,921] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Removing task 0_0 from wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d active assignment until it is safely revoked in followup rebalance (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,922] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Requesting followup rebalance be scheduled immediately by wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d due to tasks changing ownership. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,922] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Client ae1e0fef-92c1-4431-800b-8aa4ad7567fa per-consumer assignment: prev owned active {} prev owned standby {wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=[], wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d=[], wordcount-lambda-example-client-StreamThread-3-consumer-7c861acb-38f0-44f3-ac83-1826329bb24c=[], wordcount-lambda-example-client-StreamThread-4-consumer-d2b60749-e522-4602-9eed-ff33b0c868a1=[]} assigned active {wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=[1_0], wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d=[0_0]} revoking active {wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=[1_0], wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d=[0_0]} assigned standby {wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=[1_0, 1_1]} (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,922] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Removing task 0_1 from wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b active assignment until it is safely revoked in followup rebalance (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,922] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Requesting followup rebalance be scheduled immediately by wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b due to tasks changing ownership. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,922] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Client c34dcb8a-40de-4e0b-afc7-13c0c7f55426 per-consumer assignment: prev owned active {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[1_0], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[1_1], wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=[0_0], wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=[0_1]} prev owned standby {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[], wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=[], wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=[]} assigned active {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[0_1], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[1_1]} revoking active {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[0_1]} assigned standby {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[1_0]} (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,922] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Finished unstable assignment of tasks, a followup rebalance will be scheduled. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,922] WARN [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] The following subscribed topics are not assigned to any members: [streams-plaintext-input] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,922] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Finished assignment for group at generation 3: {wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d=Assignment(partitions=[], userDataSize=40), wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=Assignment(partitions=[], userDataSize=135), wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=Assignment(partitions=[], userDataSize=40), wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=Assignment(partitions=[], userDataSize=230), wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1], userDataSize=48), wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=Assignment(partitions=[], userDataSize=40), wordcount-lambda-example-client-StreamThread-4-consumer-d2b60749-e522-4602-9eed-ff33b0c868a1=Assignment(partitions=[], userDataSize=40), wordcount-lambda-example-client-StreamThread-3-consumer-7c861acb-38f0-44f3-ac83-1826329bb24c=Assignment(partitions=[], userDataSize=40)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,923] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=3, memberId='wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,923] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=3, memberId='wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,923] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=3, memberId='wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,924] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1] Current owned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,924] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [] Current owned partitions: [streams-plaintext-input-1] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [streams-plaintext-input-1] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,924] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [] Current owned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,923] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=3, memberId='wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,924] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Revoke previously assigned partitions wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,924] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Revoke previously assigned partitions streams-plaintext-input-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,924] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,924] INFO [wordcount-lambda-example-client-StreamThread-1] stream-client [wordcount-lambda-example-client] State transition from RUNNING to REBALANCING (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:36,924] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [] Current owned partitions: [streams-plaintext-input-0] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [streams-plaintext-input-0] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,925] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,925] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Revoke previously assigned partitions streams-plaintext-input-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,925] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2] Handle new assignment with: New active tasks: [1_1] New standby tasks: [] Existing active tasks: [1_1] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:36,925] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] task [0_1] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] task [0_0] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Need to revoke partitions [streams-plaintext-input-1] and re-join the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Need to revoke partitions [streams-plaintext-input-0] and re-join the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[], userDataSize=40) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[], userDataSize=40) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] Handle new assignment with: New active tasks: [] New standby tasks: [] Existing active tasks: [0_0] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,926] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] Handle new assignment with: New active tasks: [] New standby tasks: [] Existing active tasks: [0_1] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:36,929] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:36,929] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:36,930] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] task [1_0] Suspended running (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:36,930] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Need to revoke partitions [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0] and re-join the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,930] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[], userDataSize=135) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,930] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1-consumer] Requested to schedule immediate rebalance for new tasks to be safely revoked from current owner. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:36,930] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] Handle new assignment with: New active tasks: [] New standby tasks: [1_0] Existing active tasks: [1_0] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:36,930] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] task [0_1] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl) [2021-06-17 15:31:36,930] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] task [0_0] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl) [2021-06-17 15:31:36,931] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] task [0_1] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:36,931] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] task [0_0] Closed clean (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:36,931] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,931] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,931] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,931] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,932] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:36,932] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] task [1_0] Closing record collector clean (org.apache.kafka.streams.processor.internals.RecordCollectorImpl) [2021-06-17 15:31:36,932] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] task [1_0] Closed clean and recycled state (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:36,933] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:36,933] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:36,935] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] standby-task [1_0] Initialized (org.apache.kafka.streams.processor.internals.StandbyTask) [2021-06-17 15:31:36,936] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-restore-consumer, groupId=null] Subscribed to partition(s): wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-0 (org.apache.kafka.clients.consumer.KafkaConsumer) [2021-06-17 15:31:36,936] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-restore-consumer, groupId=null] Seeking to EARLIEST offset of partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:36,958] INFO [wordcount-lambda-example-client-StreamThread-3] stream-client [wordcount-lambda-example-client] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:37,147] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-restore-consumer, groupId=null] Resetting offset for partition wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-changelog-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:39,917] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Attempt to heartbeat failed since group is rebalancing (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,917] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,924] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=4, memberId='wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,924] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=4, memberId='wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,924] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=4, memberId='wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,924] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Successfully joined group with generation Generation{generationId=4, memberId='wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,929] WARN [wordcount-lambda-example-client-StreamThread-3] Unable to assign 1 of 2 standby tasks for task [1_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.HighAvailabilityTaskAssignor) [2021-06-17 15:31:39,929] WARN [wordcount-lambda-example-client-StreamThread-3] Unable to assign 1 of 2 standby tasks for task [1_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.HighAvailabilityTaskAssignor) [2021-06-17 15:31:39,929] INFO [wordcount-lambda-example-client-StreamThread-3] Decided on assignment: {ae1e0fef-92c1-4431-800b-8aa4ad7567fa=[activeTasks: ([0_0, 1_0]) standbyTasks: ([1_1]) prevActiveTasks: ([]) prevStandbyTasks: ([1_0, 1_1]) changelogOffsetTotalsByTask: ([1_0=0, 1_1=0]) taskLagTotals: ([1_0=0, 1_1=0]) capacity: 4 assigned: 3], c34dcb8a-40de-4e0b-afc7-13c0c7f55426=[activeTasks: ([0_1, 1_1]) standbyTasks: ([1_0]) prevActiveTasks: ([1_1]) prevStandbyTasks: ([1_0]) changelogOffsetTotalsByTask: ([1_0=0, 1_1=-2]) taskLagTotals: ([1_0=0, 1_1=-2]) capacity: 4 assigned: 3]} with no followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor) [2021-06-17 15:31:39,929] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Assigned tasks [0_0, 0_1, 1_0, 1_1] including stateful [1_0, 1_1] to clients as: ae1e0fef-92c1-4431-800b-8aa4ad7567fa=[activeTasks: ([0_0, 1_0]) standbyTasks: ([1_1])] c34dcb8a-40de-4e0b-afc7-13c0c7f55426=[activeTasks: ([0_1, 1_1]) standbyTasks: ([1_0])]. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:39,930] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Client ae1e0fef-92c1-4431-800b-8aa4ad7567fa per-consumer assignment: prev owned active {} prev owned standby {wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=[1_0, 1_1], wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d=[], wordcount-lambda-example-client-StreamThread-3-consumer-7c861acb-38f0-44f3-ac83-1826329bb24c=[], wordcount-lambda-example-client-StreamThread-4-consumer-d2b60749-e522-4602-9eed-ff33b0c868a1=[]} assigned active {wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=[1_0], wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d=[0_0]} revoking active {} assigned standby {wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=[1_1]} (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:39,930] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Client c34dcb8a-40de-4e0b-afc7-13c0c7f55426 per-consumer assignment: prev owned active {wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[1_1]} prev owned standby {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[1_0], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[], wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=[], wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=[]} assigned active {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[0_1], wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=[1_1]} revoking active {} assigned standby {wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=[1_0]} (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:39,930] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] Finished stable assignment of tasks, no followup rebalances required. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:39,930] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Finished assignment for group at generation 4: {wordcount-lambda-example-client-StreamThread-2-consumer-2a0bbdef-8575-472c-a1ce-dc6581d3358d=Assignment(partitions=[streams-plaintext-input-0], userDataSize=48), wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b=Assignment(partitions=[streams-plaintext-input-1], userDataSize=143), wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33=Assignment(partitions=[], userDataSize=40), wordcount-lambda-example-client-StreamThread-1-consumer-4b620d17-81e2-4aee-a417-3c57c6afcff7=Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-0], userDataSize=143), wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a=Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1], userDataSize=48), wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097=Assignment(partitions=[], userDataSize=40), wordcount-lambda-example-client-StreamThread-4-consumer-d2b60749-e522-4602-9eed-ff33b0c868a1=Assignment(partitions=[], userDataSize=40), wordcount-lambda-example-client-StreamThread-3-consumer-7c861acb-38f0-44f3-ac83-1826329bb24c=Assignment(partitions=[], userDataSize=40)} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,932] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=4, memberId='wordcount-lambda-example-client-StreamThread-1-consumer-c54c79e8-18a1-4680-a2b5-2f1ffe47363b', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,932] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=4, memberId='wordcount-lambda-example-client-StreamThread-4-consumer-49737233-c0b4-4674-b246-d47a58fa2097', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,932] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=4, memberId='wordcount-lambda-example-client-StreamThread-2-consumer-9b1217ee-2929-480a-b36b-76cfa3279f5a', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,932] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Successfully synced group in generation Generation{generationId=4, memberId='wordcount-lambda-example-client-StreamThread-3-consumer-62a83315-55fc-4825-bdef-e34e4697ec33', protocol='stream'} (org.apache.kafka.clients.consumer.internals.AbstractCoordinator) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [] Current owned partitions: [] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1] Current owned partitions: [wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [] Current owned partitions: [] Added partitions (assigned - owned): [] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,932] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Updating assignment with Assigned partitions: [streams-plaintext-input-1] Current owned partitions: [] Added partitions (assigned - owned): [streams-plaintext-input-1] Revoked partitions (owned - assigned): [] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[], userDataSize=40) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[wordcount-lambda-example-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition-1], userDataSize=48) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[], userDataSize=40) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Notifying assignor about the new Assignment(partitions=[streams-plaintext-input-1], userDataSize=143) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-3] stream-thread [wordcount-lambda-example-client-StreamThread-3] Handle new assignment with: New active tasks: [] New standby tasks: [] Existing active tasks: [] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:39,934] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-2] stream-thread [wordcount-lambda-example-client-StreamThread-2] Handle new assignment with: New active tasks: [1_1] New standby tasks: [] Existing active tasks: [1_1] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:39,934] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] Handle new assignment with: New active tasks: [0_1] New standby tasks: [1_0] Existing active tasks: [] Existing standby tasks: [1_0] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:39,933] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4-consumer] No followup rebalance was requested, resetting the rebalance schedule. (org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor) [2021-06-17 15:31:39,934] INFO [wordcount-lambda-example-client-StreamThread-2] [Consumer clientId=wordcount-lambda-example-client-StreamThread-2-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,934] INFO [wordcount-lambda-example-client-StreamThread-2] stream-client [wordcount-lambda-example-client] State transition from RUNNING to REBALANCING (org.apache.kafka.streams.KafkaStreams) [2021-06-17 15:31:39,934] INFO [wordcount-lambda-example-client-StreamThread-3] [Consumer clientId=wordcount-lambda-example-client-StreamThread-3-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,934] INFO [wordcount-lambda-example-client-StreamThread-4] stream-thread [wordcount-lambda-example-client-StreamThread-4] Handle new assignment with: New active tasks: [] New standby tasks: [] Existing active tasks: [] Existing standby tasks: [] (org.apache.kafka.streams.processor.internals.TaskManager) [2021-06-17 15:31:39,934] INFO [wordcount-lambda-example-client-StreamThread-4] [Consumer clientId=wordcount-lambda-example-client-StreamThread-4-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,935] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Adding newly assigned partitions: streams-plaintext-input-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,936] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] task [0_1] Initialized (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:39,936] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition streams-plaintext-input-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,937] INFO [wordcount-lambda-example-client-StreamThread-1] stream-thread [wordcount-lambda-example-client-StreamThread-1] task [0_1] Restored and ready to run (org.apache.kafka.streams.processor.internals.StreamTask) [2021-06-17 15:31:39,938] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Found no committed offset for partition streams-plaintext-input-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2021-06-17 15:31:39,938] INFO [wordcount-lambda-example-client-StreamThread-1] [Consumer clientId=wordcount-lambda-example-client-StreamThread-1-consumer, groupId=wordcount-lambda-example] Resetting offset for partition streams-plaintext-input-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [2021-06-17 15:31:40,017] INFO [wordcount-lambda-example-client-StreamThread-2] stream-client [wordcount-lambda-example-client] State transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams)