2023-07-26 21:27:13 DEBUG InternalStreamsBuilder:315 - Adding nodes to topology StreamsGraphNode{nodeName='root', buildPriority=null, hasWrittenToTopology=false, keyChangingOperation=false, valueChangingOperation=false, mergeNode=false, parentNodes=[]} child nodes [StreamSourceNode{topicNames=[input-topic], topicPattern=null, consumedInternal=org.apache.kafka.streams.kstream.internals.ConsumedInternal@31e7a322} StreamsGraphNode{nodeName='KSTREAM-SOURCE-0000000000', buildPriority=0, hasWrittenToTopology=false, keyChangingOperation=false, valueChangingOperation=false, mergeNode=false, parentNodes=[root]}] 2023-07-26 21:27:13 DEBUG InternalStreamsBuilder:315 - Adding nodes to topology StreamSourceNode{topicNames=[input-topic], topicPattern=null, consumedInternal=org.apache.kafka.streams.kstream.internals.ConsumedInternal@31e7a322} StreamsGraphNode{nodeName='KSTREAM-SOURCE-0000000000', buildPriority=0, hasWrittenToTopology=false, keyChangingOperation=false, valueChangingOperation=false, mergeNode=false, parentNodes=[root]} child nodes [ProcessorNode{processorParameters=ProcessorParameters{processor supplier class=null, fixed key processor supplier class=class org.apache.kafka.streams.kstream.internals.KStreamMapValues, processor name='KSTREAM-MAPVALUES-0000000001'}} StreamsGraphNode{nodeName='KSTREAM-MAPVALUES-0000000001', buildPriority=1, hasWrittenToTopology=false, keyChangingOperation=false, valueChangingOperation=true, mergeNode=false, parentNodes=[KSTREAM-SOURCE-0000000000]}] 2023-07-26 21:27:13 DEBUG InternalStreamsBuilder:315 - Adding nodes to topology ProcessorNode{processorParameters=ProcessorParameters{processor supplier class=null, fixed key processor supplier class=class org.apache.kafka.streams.kstream.internals.KStreamMapValues, processor name='KSTREAM-MAPVALUES-0000000001'}} StreamsGraphNode{nodeName='KSTREAM-MAPVALUES-0000000001', buildPriority=1, hasWrittenToTopology=false, keyChangingOperation=false, valueChangingOperation=true, mergeNode=false, parentNodes=[KSTREAM-SOURCE-0000000000]} child nodes [StreamSinkNode{topicNameExtractor=StaticTopicNameExtractor(output-topic), producedInternal=org.apache.kafka.streams.kstream.internals.ProducedInternal@b6e835a9} StreamsGraphNode{nodeName='KSTREAM-SINK-0000000002', buildPriority=2, hasWrittenToTopology=false, keyChangingOperation=false, valueChangingOperation=false, mergeNode=false, parentNodes=[KSTREAM-MAPVALUES-0000000001]}] 2023-07-26 21:27:13 DEBUG InternalStreamsBuilder:315 - Adding nodes to topology StreamSinkNode{topicNameExtractor=StaticTopicNameExtractor(output-topic), producedInternal=org.apache.kafka.streams.kstream.internals.ProducedInternal@b6e835a9} StreamsGraphNode{nodeName='KSTREAM-SINK-0000000002', buildPriority=2, hasWrittenToTopology=false, keyChangingOperation=false, valueChangingOperation=false, mergeNode=false, parentNodes=[KSTREAM-MAPVALUES-0000000001]} child nodes [] 2023-07-26 21:27:13 DEBUG StreamsConfig:1371 - Using commit.interval.ms default value of 100 as exactly once is enabled. 2023-07-26 21:27:13 INFO StreamsConfig:369 - StreamsConfig values: acceptable.recovery.lag = 10000 application.id = java-kafka-streams application.server = auto.include.jmx.reporter = true bootstrap.servers = [ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094] buffered.records.per.partition = 1000 built.in.metrics.version = latest cache.max.bytes.buffering = 10485760 client.id = commit.interval.ms = 100 connections.max.idle.ms = 540000 default.client.supplier = class org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier default.deserialization.exception.handler = class org.apache.kafka.streams.errors.LogAndFailExceptionHandler default.dsl.store = rocksDB default.key.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde default.list.key.serde.inner = null default.list.key.serde.type = null default.list.value.serde.inner = null default.list.value.serde.type = null default.production.exception.handler = class io.strimzi.kafka.streams.Reproducer$ContinueProductionExceptionHandler default.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp default.value.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde 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 = 0 num.stream.threads = 1 poll.ms = 100 probing.rebalance.interval.ms = 600000 processing.guarantee = exactly_once rack.aware.assignment.tags = [] receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 repartition.purge.interval.ms = 30000 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 = /tmp/kafka-streams statestore.cache.max.bytes = 10485760 task.timeout.ms = 300000 topology.optimization = none upgrade.from = null window.size.ms = null windowed.inner.class.serde = null windowstore.changelog.additional.retention.ms = 86400000 2023-07-26 21:27:13 WARN StreamsConfig:1330 - Configuration parameter `exactly_once` is deprecated and will be removed in the 4.0.0 release. Please use `exactly_once_v2` instead. Note that this requires broker version 2.5+ so you should prepare to upgrade your brokers if necessary. 2023-07-26 21:27:13 DEBUG InternalTopologyBuilder:1441 - No source topics using pattern subscription found, initializing consumer's subscription collection. 2023-07-26 21:27:13 INFO AdminClientConfig:369 - AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094] client.dns.lookup = use_all_dns_ips client.id = java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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 2023-07-26 21:27:13 DEBUG AdminMetadataManager:245 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Setting bootstrap cluster metadata Cluster(id = null, nodes = [ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null)], partitions = [], controller = null). 2023-07-26 21:27:13 INFO AppInfoParser:119 - Kafka version: 3.5.1 2023-07-26 21:27:13 INFO AppInfoParser:120 - Kafka commitId: 2c6fb6c54472e90a 2023-07-26 21:27:13 INFO AppInfoParser:121 - Kafka startTimeMs: 1690374433732 2023-07-26 21:27:13 DEBUG KafkaAdminClient:603 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Kafka admin client initialized 2023-07-26 21:27:13 INFO KafkaStreams:903 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] Kafka Streams version: 3.5.1 2023-07-26 21:27:13 INFO KafkaStreams:904 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] Kafka Streams commit ID: 2c6fb6c54472e90a 2023-07-26 21:27:13 DEBUG KafkaAdminClient:1342 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Thread starting 2023-07-26 21:27:13 DEBUG ClientUtils:113 - Resolved host ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com as 35.74.85.81,52.196.181.90,54.95.250.40 2023-07-26 21:27:13 DEBUG NetworkClient:1031 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Initiating connection to node ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null) using address ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com/35.74.85.81 2023-07-26 21:27:13 INFO StreamThread:356 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Creating restore consumer client 2023-07-26 21:27:13 INFO ConsumerConfig:369 - ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = none bootstrap.servers = [ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-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_committed 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, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 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 2023-07-26 21:27:13 DEBUG KafkaConsumer:702 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-restore-consumer, groupId=null] Initializing the Kafka consumer 2023-07-26 21:27:13 DEBUG Selector:531 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2023-07-26 21:27:13 INFO AppInfoParser:119 - Kafka version: 3.5.1 2023-07-26 21:27:13 INFO AppInfoParser:120 - Kafka commitId: 2c6fb6c54472e90a 2023-07-26 21:27:13 INFO AppInfoParser:121 - Kafka startTimeMs: 1690374433954 2023-07-26 21:27:13 DEBUG KafkaConsumer:829 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-restore-consumer, groupId=null] Kafka consumer initialized 2023-07-26 21:27:14 INFO StreamThread:411 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Creating consumer client 2023-07-26 21:27:14 INFO ConsumerConfig:369 - ConsumerConfig values: allow.auto.create.topics = false auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-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 = java-kafka-streams 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_committed 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 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 2023-07-26 21:27:14 DEBUG KafkaConsumer:702 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Initializing the Kafka consumer 2023-07-26 21:27:14 DEBUG InternalTopicManager:101 - stream-thread [main] Configs: replication.factor = -1 windowstore.changelog.additional.retention.ms = 86400000 2023-07-26 21:27:14 INFO AssignorConfiguration:137 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Cooperative rebalancing protocol is enabled now 2023-07-26 21:27:14 INFO AppInfoParser:119 - Kafka version: 3.5.1 2023-07-26 21:27:14 INFO AppInfoParser:120 - Kafka commitId: 2c6fb6c54472e90a 2023-07-26 21:27:14 INFO AppInfoParser:121 - Kafka startTimeMs: 1690374434249 2023-07-26 21:27:14 DEBUG KafkaConsumer:829 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Kafka consumer initialized 2023-07-26 21:27:14 INFO KafkaStreams:340 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] State transition from CREATED to REBALANCING 2023-07-26 21:27:14 DEBUG KafkaStreams:1294 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] Starting Streams client 2023-07-26 21:27:14 INFO StreamThread:572 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Starting 2023-07-26 21:27:14 INFO StreamThread:239 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] State transition from CREATED to STARTING 2023-07-26 21:27:14 INFO KafkaStreams:1302 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] Started 1 stream threads 2023-07-26 21:27:14 INFO KafkaConsumer:980 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Subscribed to topic(s): input-topic 2023-07-26 21:27:14 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:14 DEBUG ConsumerCoordinator:874 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending FindCoordinator request to broker ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null) 2023-07-26 21:27:14 DEBUG NetworkClient:993 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Completed connection to node -1. Fetching API versions. 2023-07-26 21:27:14 DEBUG NetworkClient:1007 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Initiating API versions fetch from node -1. 2023-07-26 21:27:14 DEBUG ClientUtils:113 - Resolved host ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com as 35.74.85.81,52.196.181.90,54.95.250.40 2023-07-26 21:27:14 DEBUG NetworkClient:1031 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Initiating connection to node ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null) using address ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com/35.74.85.81 2023-07-26 21:27:14 DEBUG NetworkClient:532 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin, correlationId=0, headerVersion=2) and timeout 3600000 to node -1: ApiVersionsRequestData(clientSoftwareName='apache-kafka-java', clientSoftwareVersion='3.5.1') 2023-07-26 21:27:14 DEBUG Selector:531 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2023-07-26 21:27:14 DEBUG NetworkClient:993 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Completed connection to node -1. Fetching API versions. 2023-07-26 21:27:14 DEBUG NetworkClient:1007 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Initiating API versions fetch from node -1. 2023-07-26 21:27:14 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=1, headerVersion=2) and timeout 30000 to node -1: ApiVersionsRequestData(clientSoftwareName='apache-kafka-java', clientSoftwareVersion='3.5.1') 2023-07-26 21:27:14 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 429 ms and fetched 0 records from partitions [] 2023-07-26 21:27:14 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:14 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:14 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:14 INFO StreamThread:881 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Processed 0 total records, ran 0 punctuators, and committed 0 total tasks since the last update 2023-07-26 21:27:14 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:14 DEBUG NetworkClient:918 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Received API_VERSIONS response from node -1 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin, correlationId=0, headerVersion=2): ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0, minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=13), ApiVersion(apiKey=2, minVersion=0, maxVersion=7), ApiVersion(apiKey=3, minVersion=0, maxVersion=12), ApiVersion(apiKey=4, minVersion=0, maxVersion=6), ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6, minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3), ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9, minVersion=0, maxVersion=8), ApiVersion(apiKey=10, minVersion=0, maxVersion=4), ApiVersion(apiKey=11, minVersion=0, maxVersion=9), ApiVersion(apiKey=12, minVersion=0, maxVersion=4), ApiVersion(apiKey=13, minVersion=0, maxVersion=5), ApiVersion(apiKey=14, minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5), ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17, minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3), ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20, minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2), ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23, minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3), ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26, minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1), ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29, minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2), ApiVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32, minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2), ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35, minVersion=0, maxVersion=3), ApiVersion(apiKey=36, minVersion=0, maxVersion=2), ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38, minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2), ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41, minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2), ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44, minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0), ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47, minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1), ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVersion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0), ApiVersion(apiKey=56, minVersion=0, maxVersion=1), ApiVersion(apiKey=57, minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0), ApiVersion(apiKey=61, minVersion=0, maxVersion=0), ApiVersion(apiKey=65, minVersion=0, maxVersion=0), ApiVersion(apiKey=66, minVersion=0, maxVersion=0), ApiVersion(apiKey=67, minVersion=0, maxVersion=0)], throttleTimeMs=0, supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[], zkMigrationReady=false) 2023-07-26 21:27:14 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received API_VERSIONS response from node -1 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=1, headerVersion=2): ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0, minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=13), ApiVersion(apiKey=2, minVersion=0, maxVersion=7), ApiVersion(apiKey=3, minVersion=0, maxVersion=12), ApiVersion(apiKey=4, minVersion=0, maxVersion=6), ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6, minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3), ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9, minVersion=0, maxVersion=8), ApiVersion(apiKey=10, minVersion=0, maxVersion=4), ApiVersion(apiKey=11, minVersion=0, maxVersion=9), ApiVersion(apiKey=12, minVersion=0, maxVersion=4), ApiVersion(apiKey=13, minVersion=0, maxVersion=5), ApiVersion(apiKey=14, minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5), ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17, minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3), ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20, minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2), ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23, minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3), ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26, minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1), ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29, minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2), ApiVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32, minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2), ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35, minVersion=0, maxVersion=3), ApiVersion(apiKey=36, minVersion=0, maxVersion=2), ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38, minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2), ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41, minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2), ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44, minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0), ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47, minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1), ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVersion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0), ApiVersion(apiKey=56, minVersion=0, maxVersion=1), ApiVersion(apiKey=57, minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0), ApiVersion(apiKey=61, minVersion=0, maxVersion=0), ApiVersion(apiKey=65, minVersion=0, maxVersion=0), ApiVersion(apiKey=66, minVersion=0, maxVersion=0), ApiVersion(apiKey=67, minVersion=0, maxVersion=0)], throttleTimeMs=0, supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[], zkMigrationReady=false) 2023-07-26 21:27:15 DEBUG NetworkClient:963 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Node -1 has finalized features epoch: 0, finalized features: [], supported features: [], ZK migration ready: false, API versions: (Produce(0): 0 to 9 [usable: 9], Fetch(1): 0 to 13 [usable: 13], ListOffsets(2): 0 to 7 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 6 [usable: 6], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 8 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 3 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 1 [usable: 1], UpdateFeatures(57): 0 [usable: 0], Envelope(58): UNSUPPORTED, DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], ConsumerGroupHeartbeat(68): UNSUPPORTED). 2023-07-26 21:27:15 DEBUG NetworkClient:963 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Node -1 has finalized features epoch: 0, finalized features: [], supported features: [], ZK migration ready: false, API versions: (Produce(0): 0 to 9 [usable: 9], Fetch(1): 0 to 13 [usable: 13], ListOffsets(2): 0 to 7 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 6 [usable: 6], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 8 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 3 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 1 [usable: 1], UpdateFeatures(57): 0 [usable: 0], Envelope(58): UNSUPPORTED, DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], ConsumerGroupHeartbeat(68): UNSUPPORTED). 2023-07-26 21:27:15 DEBUG KafkaAdminClient:1186 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Sending MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null). correlationId=1, timeoutMs=28700 2023-07-26 21:27:15 DEBUG NetworkClient:1185 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(topicId=AAAAAAAAAAAAAAAAAAAAAA, name='input-topic')], allowAutoTopicCreation=false, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null) 2023-07-26 21:27:15 DEBUG NetworkClient:532 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin, correlationId=1, headerVersion=2) and timeout 28700 to node -1: MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) 2023-07-26 21:27:15 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=2, headerVersion=2) and timeout 30000 to node -1: MetadataRequestData(topics=[MetadataRequestTopic(topicId=AAAAAAAAAAAAAAAAAAAAAA, name='input-topic')], allowAutoTopicCreation=false, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) 2023-07-26 21:27:15 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending FIND_COORDINATOR request with header RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=0, headerVersion=2) and timeout 30000 to node -1: FindCoordinatorRequestData(key='', keyType=0, coordinatorKeys=[java-kafka-streams]) 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 313 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:15 DEBUG NetworkClient:918 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Received METADATA response from node -1 for request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin, correlationId=1, headerVersion=2): MetadataResponseData(throttleTimeMs=0, brokers=[MetadataResponseBroker(nodeId=0, host='a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=2, host='aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=1, host='a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null)], clusterId='cvnYABPTTUWaswr-J8RUuA', controllerId=2, topics=[], clusterAuthorizedOperations=-2147483648) 2023-07-26 21:27:15 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received METADATA response from node -1 for request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=2, headerVersion=2): MetadataResponseData(throttleTimeMs=0, brokers=[MetadataResponseBroker(nodeId=0, host='a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=2, host='aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=1, host='a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null)], clusterId='cvnYABPTTUWaswr-J8RUuA', controllerId=2, topics=[MetadataResponseTopic(errorCode=0, name='input-topic', topicId=Xdsk7Q5ITWuJQQj6SGLmjA, isInternal=false, partitions=[MetadataResponsePartition(errorCode=0, partitionIndex=0, leaderId=2, leaderEpoch=0, replicaNodes=[2], isrNodes=[2], offlineReplicas=[])], topicAuthorizedOperations=-2147483648)], clusterAuthorizedOperations=-2147483648) 2023-07-26 21:27:15 DEBUG AdminMetadataManager:247 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Updating cluster metadata to Cluster(id = cvnYABPTTUWaswr-J8RUuA, nodes = [a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com:9094 (id: 0 rack: null), a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com:9094 (id: 1 rack: null), aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)], partitions = [], controller = aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)) 2023-07-26 21:27:15 DEBUG Metadata:399 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Setting the last seen epoch of partition input-topic-0 to 0 since the last known epoch was undefined. 2023-07-26 21:27:15 INFO Metadata:287 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Cluster ID: cvnYABPTTUWaswr-J8RUuA 2023-07-26 21:27:15 DEBUG Metadata:291 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='cvnYABPTTUWaswr-J8RUuA', nodes={0=a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com:9094 (id: 0 rack: null), 1=a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com:9094 (id: 1 rack: null), 2=aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)}, partitions=[PartitionMetadata(error=NONE, partition=input-topic-0, leader=Optional[2], leaderEpoch=Optional[0], replicas=2, isr=2, offlineReplicas=)], controller=aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)} 2023-07-26 21:27:15 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received FIND_COORDINATOR response from node -1 for request with header RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=0, headerVersion=2): FindCoordinatorResponseData(throttleTimeMs=0, errorCode=0, errorMessage='', nodeId=0, host='', port=0, coordinators=[Coordinator(key='java-kafka-streams', nodeId=2, host='aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com', port=9094, errorCode=0, errorMessage='')]) 2023-07-26 21:27:15 DEBUG ConsumerCoordinator:887 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received FindCoordinator response ClientResponse(receivedTimeMs=1690374435103, latencyMs=473, disconnected=false, timedOut=false, requestHeader=RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=0, headerVersion=2), responseBody=FindCoordinatorResponseData(throttleTimeMs=0, errorCode=0, errorMessage='', nodeId=0, host='', port=0, coordinators=[Coordinator(key='java-kafka-streams', nodeId=2, host='aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com', port=9094, errorCode=0, errorMessage='')])) 2023-07-26 21:27:15 INFO ConsumerCoordinator:906 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Discovered group coordinator aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2147483645 rack: null) 2023-07-26 21:27:15 DEBUG ClientUtils:113 - Resolved host aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com as 52.192.119.151,52.198.83.252,3.115.103.113 2023-07-26 21:27:15 DEBUG NetworkClient:1031 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Initiating connection to node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2147483645 rack: null) using address aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com/52.192.119.151 2023-07-26 21:27:15 DEBUG ConsumerCoordinator:760 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Executing onJoinPrepare with generation -1 and memberId 2023-07-26 21:27:15 DEBUG ConsumerCoordinator:1441 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Heartbeat thread started 2023-07-26 21:27:15 INFO ConsumerCoordinator:576 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] (Re-)joining group 2023-07-26 21:27:15 DEBUG ConsumerCoordinator:244 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Joining group with current subscription: [input-topic] 2023-07-26 21:27:15 DEBUG ConsumerCoordinator:589 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending JoinGroup (JoinGroupRequestData(groupId='java-kafka-streams', sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, memberId='', groupInstanceId=null, protocolType='consumer', protocols=[JoinGroupRequestProtocol(name='stream', metadata=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 41, 0, 0, 0, 11, 0, 0, 0, 11, -29, 24, 124, -7, 83, 55, 65, 85, -89, -51, -3, 78, 66, 107, -120, -99, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, -1, -1, -1, -1, -1, -1])], reason='')) to coordinator aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2147483645 rack: null) 2023-07-26 21:27:15 DEBUG Selector:531 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147483645 2023-07-26 21:27:15 DEBUG NetworkClient:993 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Completed connection to node 2147483645. Fetching API versions. 2023-07-26 21:27:15 DEBUG NetworkClient:1007 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Initiating API versions fetch from node 2147483645. 2023-07-26 21:27:15 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=4, headerVersion=2) and timeout 30000 to node 2147483645: ApiVersionsRequestData(clientSoftwareName='apache-kafka-java', clientSoftwareVersion='3.5.1') 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:15 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received API_VERSIONS response from node 2147483645 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=4, headerVersion=2): ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0, minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=13), ApiVersion(apiKey=2, minVersion=0, maxVersion=7), ApiVersion(apiKey=3, minVersion=0, maxVersion=12), ApiVersion(apiKey=4, minVersion=0, maxVersion=6), ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6, minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3), ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9, minVersion=0, maxVersion=8), ApiVersion(apiKey=10, minVersion=0, maxVersion=4), ApiVersion(apiKey=11, minVersion=0, maxVersion=9), ApiVersion(apiKey=12, minVersion=0, maxVersion=4), ApiVersion(apiKey=13, minVersion=0, maxVersion=5), ApiVersion(apiKey=14, minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5), ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17, minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3), ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20, minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2), ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23, minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3), ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26, minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1), ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29, minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2), ApiVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32, minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2), ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35, minVersion=0, maxVersion=3), ApiVersion(apiKey=36, minVersion=0, maxVersion=2), ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38, minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2), ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41, minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2), ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44, minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0), ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47, minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1), ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVersion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0), ApiVersion(apiKey=56, minVersion=0, maxVersion=1), ApiVersion(apiKey=57, minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0), ApiVersion(apiKey=61, minVersion=0, maxVersion=0), ApiVersion(apiKey=65, minVersion=0, maxVersion=0), ApiVersion(apiKey=66, minVersion=0, maxVersion=0), ApiVersion(apiKey=67, minVersion=0, maxVersion=0)], throttleTimeMs=0, supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[], zkMigrationReady=false) 2023-07-26 21:27:15 DEBUG NetworkClient:963 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Node 2147483645 has finalized features epoch: 0, finalized features: [], supported features: [], ZK migration ready: false, API versions: (Produce(0): 0 to 9 [usable: 9], Fetch(1): 0 to 13 [usable: 13], ListOffsets(2): 0 to 7 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 6 [usable: 6], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 8 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 3 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 1 [usable: 1], UpdateFeatures(57): 0 [usable: 0], Envelope(58): UNSUPPORTED, DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], ConsumerGroupHeartbeat(68): UNSUPPORTED). 2023-07-26 21:27:15 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending JOIN_GROUP request with header RequestHeader(apiKey=JOIN_GROUP, apiVersion=9, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=3, headerVersion=2) and timeout 305000 to node 2147483645: JoinGroupRequestData(groupId='java-kafka-streams', sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, memberId='', groupInstanceId=null, protocolType='consumer', protocols=[JoinGroupRequestProtocol(name='stream', metadata=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 41, 0, 0, 0, 11, 0, 0, 0, 11, -29, 24, 124, -7, 83, 55, 65, 85, -89, -51, -3, 78, 66, 107, -120, -99, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, -1, -1, -1, -1, -1, -1])], reason='') 2023-07-26 21:27:15 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received JOIN_GROUP response from node 2147483645 for request with header RequestHeader(apiKey=JOIN_GROUP, apiVersion=9, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=3, headerVersion=2): JoinGroupResponseData(throttleTimeMs=0, errorCode=79, generationId=-1, protocolType=null, protocolName=null, leader='', skipAssignment=false, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', members=[]) 2023-07-26 21:27:15 DEBUG ConsumerCoordinator:696 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] JoinGroup failed due to non-fatal error: MEMBER_ID_REQUIRED. Will set the member id as java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125 and then rejoin. Sent generation was Generation{generationId=-1, memberId='', protocol='null'} 2023-07-26 21:27:15 INFO ConsumerCoordinator:1072 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Request joining group due to: need to re-join with the given member-id: java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125 2023-07-26 21:27:15 INFO ConsumerCoordinator:1072 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) 2023-07-26 21:27:15 INFO ConsumerCoordinator:576 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] (Re-)joining group 2023-07-26 21:27:15 DEBUG ConsumerCoordinator:244 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Joining group with current subscription: [input-topic] 2023-07-26 21:27:15 DEBUG ConsumerCoordinator:589 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending JoinGroup (JoinGroupRequestData(groupId='java-kafka-streams', sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, protocolType='consumer', protocols=[JoinGroupRequestProtocol(name='stream', metadata=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 41, 0, 0, 0, 11, 0, 0, 0, 11, -29, 24, 124, -7, 83, 55, 65, 85, -89, -51, -3, 78, 66, 107, -120, -99, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, -1, -1, -1, -1, -1, -1])], reason='rebalance failed due to MemberIdRequiredException')) to coordinator aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2147483645 rack: null) 2023-07-26 21:27:15 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending JOIN_GROUP request with header RequestHeader(apiKey=JOIN_GROUP, apiVersion=9, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=5, headerVersion=2) and timeout 305000 to node 2147483645: JoinGroupRequestData(groupId='java-kafka-streams', sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, protocolType='consumer', protocols=[JoinGroupRequestProtocol(name='stream', metadata=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 41, 0, 0, 0, 11, 0, 0, 0, 11, -29, 24, 124, -7, 83, 55, 65, 85, -89, -51, -3, 78, 66, 107, -120, -99, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, -1, -1, -1, -1, -1, -1])], reason='rebalance failed due to MemberIdRequiredException') 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 100 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:15 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:15 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:15 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:15 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:15 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 103 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:16 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:16 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:16 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:16 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:16 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 100 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 101 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:17 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 100 ms and fetched 0 records from partitions [] 2023-07-26 21:27:17 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:17 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:17 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:17 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:18 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 100 ms and fetched 0 records from partitions [] 2023-07-26 21:27:18 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:18 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:18 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:18 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:18 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 102 ms and fetched 0 records from partitions [] 2023-07-26 21:27:18 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:18 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:18 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:18 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received JOIN_GROUP response from node 2147483645 for request with header RequestHeader(apiKey=JOIN_GROUP, apiVersion=9, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=5, headerVersion=2): JoinGroupResponseData(throttleTimeMs=0, errorCode=0, generationId=18, protocolType='consumer', protocolName='stream', leader='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', skipAssignment=false, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', members=[JoinGroupResponseMember(memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, metadata=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 41, 0, 0, 0, 11, 0, 0, 0, 11, -29, 24, 124, -7, 83, 55, 65, 85, -89, -51, -3, 78, 66, 107, -120, -99, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, -1, -1, -1, -1, -1, -1])]) 2023-07-26 21:27:18 DEBUG ConsumerCoordinator:617 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received successful JoinGroup response: JoinGroupResponseData(throttleTimeMs=0, errorCode=0, generationId=18, protocolType='consumer', protocolName='stream', leader='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', skipAssignment=false, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', members=[JoinGroupResponseMember(memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, metadata=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 41, 0, 0, 0, 11, 0, 0, 0, 11, -29, 24, 124, -7, 83, 55, 65, 85, -89, -51, -3, 78, 66, 107, -120, -99, 0, 0, 0, 0, 0, 0, 0, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, -1, -1, -1, -1, -1, -1])]) 2023-07-26 21:27:18 DEBUG ConsumerCoordinator:1409 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Enabling heartbeat thread 2023-07-26 21:27:18 INFO ConsumerCoordinator:637 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Successfully joined group with generation Generation{generationId=18, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', protocol='stream'} 2023-07-26 21:27:18 DEBUG ConsumerCoordinator:696 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Performing assignment using strategy stream with subscriptions {java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125=Subscription(topics=[input-topic], userDataSize=41, ownedPartitions=[], groupInstanceId=null, generationId=-1, rackId=null)} 2023-07-26 21:27:18 DEBUG StreamsPartitionAssignor:1454 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Current minimum supported version remains at 11, last seen supported version was 11 2023-07-26 21:27:18 DEBUG StreamsPartitionAssignor:376 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Constructed client metadata {e3187cf9-5337-4155-a7cd-fd4e426b889d=ClientMetadata{hostInfo=null, consumers=[java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125], state=[activeTasks: ([]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([]) clientTags: ([]) capacity: 1 assigned: 0]}} from the member subscriptions. 2023-07-26 21:27:18 INFO RepartitionTopics:75 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Skipping the repartition topic validation since there are no repartition topics. 2023-07-26 21:27:18 DEBUG StreamsPartitionAssignor:391 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Created repartition topics [] from the parsed topology. 2023-07-26 21:27:18 DEBUG InternalTopicManager:423 - stream-thread [main] Starting to validate internal topics {} in partition assignor. 2023-07-26 21:27:18 DEBUG InternalTopicManager:536 - stream-thread [main] Completed validating internal topics and created [] 2023-07-26 21:27:18 DEBUG ChangelogTopics:98 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Created state changelog topics [] from the parsed topology. 2023-07-26 21:27:18 DEBUG KafkaAdminClient:1443 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Queueing Call(callName=metadata, deadlineMs=1690374498255, tries=0, nextAllowedTryMs=0) with a timeout 30000 ms from now. 2023-07-26 21:27:18 DEBUG ClientUtils:113 - Resolved host aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com as 52.192.119.151,52.198.83.252,3.115.103.113 2023-07-26 21:27:18 DEBUG NetworkClient:1031 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Initiating connection to node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) using address aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com/52.192.119.151 2023-07-26 21:27:18 INFO StreamsPartitionAssignor:621 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] 1 members participating in this rebalance: e3187cf9-5337-4155-a7cd-fd4e426b889d: [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125]. 2023-07-26 21:27:18 DEBUG StreamsPartitionAssignor:631 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Assigning tasks [0_0] including stateful [] to clients {e3187cf9-5337-4155-a7cd-fd4e426b889d=[activeTasks: ([]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([]) clientTags: ([]) capacity: 1 assigned: 0]} with number of replicas 0 2023-07-26 21:27:18 DEBUG Selector:531 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 2023-07-26 21:27:18 DEBUG NetworkClient:993 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Completed connection to node 2. Fetching API versions. 2023-07-26 21:27:18 DEBUG NetworkClient:1007 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Initiating API versions fetch from node 2. 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin, correlationId=2, headerVersion=2) and timeout 3600000 to node 2: ApiVersionsRequestData(clientSoftwareName='apache-kafka-java', clientSoftwareVersion='3.5.1') 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Received API_VERSIONS response from node 2 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin, correlationId=2, headerVersion=2): ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0, minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=13), ApiVersion(apiKey=2, minVersion=0, maxVersion=7), ApiVersion(apiKey=3, minVersion=0, maxVersion=12), ApiVersion(apiKey=4, minVersion=0, maxVersion=6), ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6, minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3), ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9, minVersion=0, maxVersion=8), ApiVersion(apiKey=10, minVersion=0, maxVersion=4), ApiVersion(apiKey=11, minVersion=0, maxVersion=9), ApiVersion(apiKey=12, minVersion=0, maxVersion=4), ApiVersion(apiKey=13, minVersion=0, maxVersion=5), ApiVersion(apiKey=14, minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5), ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17, minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3), ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20, minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2), ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23, minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3), ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26, minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1), ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29, minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2), ApiVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32, minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2), ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35, minVersion=0, maxVersion=3), ApiVersion(apiKey=36, minVersion=0, maxVersion=2), ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38, minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2), ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41, minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2), ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44, minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0), ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47, minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1), ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVersion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0), ApiVersion(apiKey=56, minVersion=0, maxVersion=1), ApiVersion(apiKey=57, minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0), ApiVersion(apiKey=61, minVersion=0, maxVersion=0), ApiVersion(apiKey=65, minVersion=0, maxVersion=0), ApiVersion(apiKey=66, minVersion=0, maxVersion=0), ApiVersion(apiKey=67, minVersion=0, maxVersion=0)], throttleTimeMs=0, supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[], zkMigrationReady=false) 2023-07-26 21:27:18 DEBUG NetworkClient:963 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Node 2 has finalized features epoch: 0, finalized features: [], supported features: [], ZK migration ready: false, API versions: (Produce(0): 0 to 9 [usable: 9], Fetch(1): 0 to 13 [usable: 13], ListOffsets(2): 0 to 7 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 6 [usable: 6], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 8 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 3 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 1 [usable: 1], UpdateFeatures(57): 0 [usable: 0], Envelope(58): UNSUPPORTED, DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], ConsumerGroupHeartbeat(68): UNSUPPORTED). 2023-07-26 21:27:18 INFO HighAvailabilityTaskAssignor:101 - Decided on assignment: {e3187cf9-5337-4155-a7cd-fd4e426b889d=[activeTasks: ([0_0]) standbyTasks: ([]) prevActiveTasks: ([]) prevStandbyTasks: ([]) changelogOffsetTotalsByTask: ([]) taskLagTotals: ([]) clientTags: ([]) capacity: 1 assigned: 1]} with no followup probing rebalance. 2023-07-26 21:27:18 DEBUG KafkaAdminClient:1186 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Sending MetadataRequestData(topics=[], allowAutoTopicCreation=false, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null). correlationId=3, timeoutMs=29968 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin, correlationId=3, headerVersion=2) and timeout 29968 to node 2: MetadataRequestData(topics=[], allowAutoTopicCreation=false, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) 2023-07-26 21:27:18 INFO StreamsPartitionAssignor:641 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] 1 assigned tasks [0_0] including stateful [] to 1 clients as: e3187cf9-5337-4155-a7cd-fd4e426b889d=[activeTasks: ([0_0]) standbyTasks: ([])]. 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Received METADATA response from node 2 for request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin, correlationId=3, headerVersion=2): MetadataResponseData(throttleTimeMs=0, brokers=[MetadataResponseBroker(nodeId=0, host='a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=2, host='aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=1, host='a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null)], clusterId='cvnYABPTTUWaswr-J8RUuA', controllerId=2, topics=[], clusterAuthorizedOperations=-2147483648) 2023-07-26 21:27:18 INFO StreamsPartitionAssignor:878 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Client e3187cf9-5337-4155-a7cd-fd4e426b889d per-consumer assignment: prev owned active {} prev owned standby {java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125=[]} assigned active {java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125=[0_0]} revoking active {} assigned standby {} 2023-07-26 21:27:18 INFO StreamsPartitionAssignor:897 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] Finished stable assignment of tasks, no followup rebalances required. 2023-07-26 21:27:18 INFO ConsumerCoordinator:712 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Finished assignment for group at generation 18: {java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125=Assignment(partitions=[input-topic-0], userDataSize=52)} 2023-07-26 21:27:18 DEBUG ConsumerCoordinator:762 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending leader SyncGroup to coordinator aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2147483645 rack: null): SyncGroupRequestData(groupId='java-kafka-streams', generationId=18, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, protocolType='consumer', protocolName='stream', assignments=[SyncGroupRequestAssignment(memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', assignment=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 52, 0, 0, 0, 11, 0, 0, 0, 11, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 127, -1, -1, -1, -1, -1, -1, -1])]) 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending SYNC_GROUP request with header RequestHeader(apiKey=SYNC_GROUP, apiVersion=5, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=6, headerVersion=2) and timeout 30000 to node 2147483645: SyncGroupRequestData(groupId='java-kafka-streams', generationId=18, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, protocolType='consumer', protocolName='stream', assignments=[SyncGroupRequestAssignment(memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', assignment=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 52, 0, 0, 0, 11, 0, 0, 0, 11, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 127, -1, -1, -1, -1, -1, -1, -1])]) 2023-07-26 21:27:18 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 234 ms and fetched 0 records from partitions [] 2023-07-26 21:27:18 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state STARTING 2023-07-26 21:27:18 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:18 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:18 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received SYNC_GROUP response from node 2147483645 for request with header RequestHeader(apiKey=SYNC_GROUP, apiVersion=5, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=6, headerVersion=2): SyncGroupResponseData(throttleTimeMs=0, errorCode=0, protocolType='consumer', protocolName='stream', assignment=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 52, 0, 0, 0, 11, 0, 0, 0, 11, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 127, -1, -1, -1, -1, -1, -1, -1]) 2023-07-26 21:27:18 DEBUG ConsumerCoordinator:796 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received successful SyncGroup response: SyncGroupResponseData(throttleTimeMs=0, errorCode=0, protocolType='consumer', protocolName='stream', assignment=[0, 3, 0, 0, 0, 1, 0, 11, 105, 110, 112, 117, 116, 45, 116, 111, 112, 105, 99, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 52, 0, 0, 0, 11, 0, 0, 0, 11, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 127, -1, -1, -1, -1, -1, -1, -1]) 2023-07-26 21:27:18 INFO ConsumerCoordinator:812 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Successfully synced group in generation Generation{generationId=18, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', protocol='stream'} 2023-07-26 21:27:18 DEBUG ConsumerCoordinator:388 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Executing onJoinComplete with generation 18 and memberId java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125 2023-07-26 21:27:18 INFO ConsumerCoordinator:435 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Updating assignment with Assigned partitions: [input-topic-0] Current owned partitions: [] Added partitions (assigned - owned): [input-topic-0] Revoked partitions (owned - assigned): [] 2023-07-26 21:27:18 INFO ConsumerCoordinator:307 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Notifying assignor about the new Assignment(partitions=[input-topic-0], userDataSize=52) 2023-07-26 21:27:18 INFO StreamsPartitionAssignor:1375 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer] No followup rebalance was requested, resetting the rebalance schedule. 2023-07-26 21:27:18 INFO TaskManager:309 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Handle new assignment with: New active tasks: [0_0] New standby tasks: [] Existing active tasks: [] Existing standby tasks: [] 2023-07-26 21:27:18 DEBUG ProcessorStateManager:208 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] stream-task [0_0] Created state store manager for task 0_0 2023-07-26 21:27:18 INFO StreamThread:191 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Creating producer client for task 0_0 2023-07-26 21:27:18 INFO ProducerConfig:369 - ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = true interceptor.classes = [] 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.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false 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.connect.timeout.ms = null sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null 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 = 10000 transactional.id = java-kafka-streams-0_0 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer 2023-07-26 21:27:18 INFO KafkaProducer:594 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Instantiated a transactional producer. 2023-07-26 21:27:18 INFO ProducerConfig:378 - These configurations '[internal.auto.downgrade.txn.commit]' were supplied but are not used yet. 2023-07-26 21:27:18 DEBUG Sender:238 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Starting Kafka producer I/O thread. 2023-07-26 21:27:18 INFO AppInfoParser:119 - Kafka version: 3.5.1 2023-07-26 21:27:18 INFO AppInfoParser:120 - Kafka commitId: 2c6fb6c54472e90a 2023-07-26 21:27:18 INFO AppInfoParser:121 - Kafka startTimeMs: 1690374438541 2023-07-26 21:27:18 DEBUG NetworkClient:1202 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Initialize connection to node ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null) for sending metadata request 2023-07-26 21:27:18 DEBUG ClientUtils:113 - Resolved host ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com as 35.74.85.81,52.196.181.90,54.95.250.40 2023-07-26 21:27:18 DEBUG KafkaProducer:460 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Kafka producer started 2023-07-26 21:27:18 DEBUG NetworkClient:1031 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Initiating connection to node ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null) using address ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com/35.74.85.81 2023-07-26 21:27:18 DEBUG Selector:531 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2023-07-26 21:27:18 DEBUG NetworkClient:993 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Completed connection to node -1. Fetching API versions. 2023-07-26 21:27:18 DEBUG NetworkClient:1007 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Initiating API versions fetch from node -1. 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=0, headerVersion=2) and timeout 30000 to node -1: ApiVersionsRequestData(clientSoftwareName='apache-kafka-java', clientSoftwareVersion='3.5.1') 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Received API_VERSIONS response from node -1 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=0, headerVersion=2): ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0, minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=13), ApiVersion(apiKey=2, minVersion=0, maxVersion=7), ApiVersion(apiKey=3, minVersion=0, maxVersion=12), ApiVersion(apiKey=4, minVersion=0, maxVersion=6), ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6, minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3), ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9, minVersion=0, maxVersion=8), ApiVersion(apiKey=10, minVersion=0, maxVersion=4), ApiVersion(apiKey=11, minVersion=0, maxVersion=9), ApiVersion(apiKey=12, minVersion=0, maxVersion=4), ApiVersion(apiKey=13, minVersion=0, maxVersion=5), ApiVersion(apiKey=14, minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5), ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17, minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3), ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20, minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2), ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23, minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3), ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26, minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1), ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29, minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2), ApiVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32, minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2), ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35, minVersion=0, maxVersion=3), ApiVersion(apiKey=36, minVersion=0, maxVersion=2), ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38, minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2), ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41, minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2), ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44, minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0), ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47, minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1), ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVersion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0), ApiVersion(apiKey=56, minVersion=0, maxVersion=1), ApiVersion(apiKey=57, minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0), ApiVersion(apiKey=61, minVersion=0, maxVersion=0), ApiVersion(apiKey=65, minVersion=0, maxVersion=0), ApiVersion(apiKey=66, minVersion=0, maxVersion=0), ApiVersion(apiKey=67, minVersion=0, maxVersion=0)], throttleTimeMs=0, supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[], zkMigrationReady=false) 2023-07-26 21:27:18 DEBUG NetworkClient:963 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Node -1 has finalized features epoch: 0, finalized features: [], supported features: [], ZK migration ready: false, API versions: (Produce(0): 0 to 9 [usable: 9], Fetch(1): 0 to 13 [usable: 13], ListOffsets(2): 0 to 7 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 6 [usable: 6], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 8 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 3 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 1 [usable: 1], UpdateFeatures(57): 0 [usable: 0], Envelope(58): UNSUPPORTED, DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], ConsumerGroupHeartbeat(68): UNSUPPORTED). 2023-07-26 21:27:18 DEBUG NetworkClient:1185 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending metadata request MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node ab4f03d378c2e494f8e7ecd99b349536-265567194.ap-northeast-1.elb.amazonaws.com:9094 (id: -1 rack: null) 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=1, headerVersion=2) and timeout 30000 to node -1: MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Received METADATA response from node -1 for request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=1, headerVersion=2): MetadataResponseData(throttleTimeMs=0, brokers=[MetadataResponseBroker(nodeId=0, host='a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=2, host='aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=1, host='a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null)], clusterId='cvnYABPTTUWaswr-J8RUuA', controllerId=2, topics=[], clusterAuthorizedOperations=-2147483648) 2023-07-26 21:27:18 INFO Metadata:287 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Cluster ID: cvnYABPTTUWaswr-J8RUuA 2023-07-26 21:27:18 DEBUG Metadata:291 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='cvnYABPTTUWaswr-J8RUuA', nodes={0=a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com:9094 (id: 0 rack: null), 1=a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com:9094 (id: 1 rack: null), 2=aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)}, partitions=[], controller=aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)} 2023-07-26 21:27:18 DEBUG ProcessorStateManager:226 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] stream-task [0_0] Register global stores [] 2023-07-26 21:27:18 INFO ConsumerCoordinator:319 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Adding newly assigned partitions: input-topic-0 2023-07-26 21:27:18 INFO StreamThread:239 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] State transition from STARTING to PARTITIONS_ASSIGNED 2023-07-26 21:27:18 DEBUG KafkaConsumer:2066 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Pausing partitions [input-topic-0] 2023-07-26 21:27:18 DEBUG ConsumerCoordinator:1477 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Fetching committed offsets for partitions: [input-topic-0] 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending OFFSET_FETCH request with header RequestHeader(apiKey=OFFSET_FETCH, apiVersion=8, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=7, headerVersion=2) and timeout 30000 to node 2147483645: OffsetFetchRequestData(groupId='', topics=[], groups=[OffsetFetchRequestGroup(groupId='java-kafka-streams', topics=[OffsetFetchRequestTopics(name='input-topic', partitionIndexes=[0])])], requireStable=true) 2023-07-26 21:27:18 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 409 ms and fetched 0 records from partitions [] 2023-07-26 21:27:18 DEBUG StreamThread:899 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] State is PARTITIONS_ASSIGNED; initializing tasks if necessary 2023-07-26 21:27:18 DEBUG TransactionManager:988 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Transition from state UNINITIALIZED to INITIALIZING 2023-07-26 21:27:18 INFO TransactionManager:234 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Invoking InitProducerId for the first time in order to acquire a producer ID 2023-07-26 21:27:18 DEBUG TransactionManager:1028 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Enqueuing transactional request InitProducerIdRequestData(transactionalId='java-kafka-streams-0_0', transactionTimeoutMs=10000, producerId=-1, producerEpoch=-1) 2023-07-26 21:27:18 DEBUG TransactionManager:1028 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Enqueuing transactional request FindCoordinatorRequestData(key='java-kafka-streams-0_0', keyType=1, coordinatorKeys=[]) 2023-07-26 21:27:18 DEBUG TransactionManager:1028 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Enqueuing transactional request InitProducerIdRequestData(transactionalId='java-kafka-streams-0_0', transactionTimeoutMs=10000, producerId=-1, producerEpoch=-1) 2023-07-26 21:27:18 DEBUG ClientUtils:113 - Resolved host aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com as 52.192.119.151,52.198.83.252,3.115.103.113 2023-07-26 21:27:18 DEBUG NetworkClient:1031 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Initiating connection to node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) using address aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com/52.192.119.151 2023-07-26 21:27:18 DEBUG Selector:531 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 2023-07-26 21:27:18 DEBUG NetworkClient:993 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Completed connection to node 2. Fetching API versions. 2023-07-26 21:27:18 DEBUG NetworkClient:1007 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Initiating API versions fetch from node 2. 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=2, headerVersion=2) and timeout 30000 to node 2: ApiVersionsRequestData(clientSoftwareName='apache-kafka-java', clientSoftwareVersion='3.5.1') 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Received API_VERSIONS response from node 2 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=2, headerVersion=2): ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0, minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=13), ApiVersion(apiKey=2, minVersion=0, maxVersion=7), ApiVersion(apiKey=3, minVersion=0, maxVersion=12), ApiVersion(apiKey=4, minVersion=0, maxVersion=6), ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6, minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3), ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9, minVersion=0, maxVersion=8), ApiVersion(apiKey=10, minVersion=0, maxVersion=4), ApiVersion(apiKey=11, minVersion=0, maxVersion=9), ApiVersion(apiKey=12, minVersion=0, maxVersion=4), ApiVersion(apiKey=13, minVersion=0, maxVersion=5), ApiVersion(apiKey=14, minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5), ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17, minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3), ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20, minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2), ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23, minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3), ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26, minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1), ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29, minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2), ApiVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32, minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2), ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35, minVersion=0, maxVersion=3), ApiVersion(apiKey=36, minVersion=0, maxVersion=2), ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38, minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2), ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41, minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2), ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44, minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0), ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47, minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1), ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVersion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0), ApiVersion(apiKey=56, minVersion=0, maxVersion=1), ApiVersion(apiKey=57, minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0), ApiVersion(apiKey=61, minVersion=0, maxVersion=0), ApiVersion(apiKey=65, minVersion=0, maxVersion=0), ApiVersion(apiKey=66, minVersion=0, maxVersion=0), ApiVersion(apiKey=67, minVersion=0, maxVersion=0)], throttleTimeMs=0, supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[], zkMigrationReady=false) 2023-07-26 21:27:18 DEBUG NetworkClient:963 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Node 2 has finalized features epoch: 0, finalized features: [], supported features: [], ZK migration ready: false, API versions: (Produce(0): 0 to 9 [usable: 9], Fetch(1): 0 to 13 [usable: 13], ListOffsets(2): 0 to 7 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 6 [usable: 6], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 8 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 3 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 1 [usable: 1], UpdateFeatures(57): 0 [usable: 0], Envelope(58): UNSUPPORTED, DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], ConsumerGroupHeartbeat(68): UNSUPPORTED). 2023-07-26 21:27:18 DEBUG Sender:477 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending transactional request FindCoordinatorRequestData(key='java-kafka-streams-0_0', keyType=1, coordinatorKeys=[]) to node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) with correlation ID 3 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending FIND_COORDINATOR request with header RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=3, headerVersion=2) and timeout 30000 to node 2: FindCoordinatorRequestData(key='', keyType=1, coordinatorKeys=[java-kafka-streams-0_0]) 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Received FIND_COORDINATOR response from node 2 for request with header RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=3, headerVersion=2): FindCoordinatorResponseData(throttleTimeMs=0, errorCode=0, errorMessage='', nodeId=0, host='', port=0, coordinators=[Coordinator(key='java-kafka-streams-0_0', nodeId=0, host='a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com', port=9094, errorCode=0, errorMessage='')]) 2023-07-26 21:27:18 INFO TransactionManager:1469 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Discovered transaction coordinator a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com:9094 (id: 0 rack: null) 2023-07-26 21:27:18 DEBUG ClientUtils:113 - Resolved host a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com as 52.192.174.220,52.192.47.142,3.113.86.92 2023-07-26 21:27:18 DEBUG NetworkClient:1031 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Initiating connection to node a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com:9094 (id: 0 rack: null) using address a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com/52.192.174.220 2023-07-26 21:27:18 DEBUG Selector:531 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 2023-07-26 21:27:18 DEBUG NetworkClient:993 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Completed connection to node 0. Fetching API versions. 2023-07-26 21:27:18 DEBUG NetworkClient:1007 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Initiating API versions fetch from node 0. 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=4, headerVersion=2) and timeout 30000 to node 0: ApiVersionsRequestData(clientSoftwareName='apache-kafka-java', clientSoftwareVersion='3.5.1') 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Received API_VERSIONS response from node 0 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=4, headerVersion=2): ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0, minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=13), ApiVersion(apiKey=2, minVersion=0, maxVersion=7), ApiVersion(apiKey=3, minVersion=0, maxVersion=12), ApiVersion(apiKey=4, minVersion=0, maxVersion=6), ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6, minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3), ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9, minVersion=0, maxVersion=8), ApiVersion(apiKey=10, minVersion=0, maxVersion=4), ApiVersion(apiKey=11, minVersion=0, maxVersion=9), ApiVersion(apiKey=12, minVersion=0, maxVersion=4), ApiVersion(apiKey=13, minVersion=0, maxVersion=5), ApiVersion(apiKey=14, minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5), ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17, minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3), ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20, minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2), ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23, minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3), ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26, minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1), ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29, minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2), ApiVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32, minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2), ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35, minVersion=0, maxVersion=3), ApiVersion(apiKey=36, minVersion=0, maxVersion=2), ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38, minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2), ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41, minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2), ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44, minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0), ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47, minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1), ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVersion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0), ApiVersion(apiKey=56, minVersion=0, maxVersion=1), ApiVersion(apiKey=57, minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0), ApiVersion(apiKey=61, minVersion=0, maxVersion=0), ApiVersion(apiKey=65, minVersion=0, maxVersion=0), ApiVersion(apiKey=66, minVersion=0, maxVersion=0), ApiVersion(apiKey=67, minVersion=0, maxVersion=0)], throttleTimeMs=0, supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[], zkMigrationReady=false) 2023-07-26 21:27:18 DEBUG NetworkClient:963 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Node 0 has finalized features epoch: 0, finalized features: [], supported features: [], ZK migration ready: false, API versions: (Produce(0): 0 to 9 [usable: 9], Fetch(1): 0 to 13 [usable: 13], ListOffsets(2): 0 to 7 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 6 [usable: 6], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 8 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 3 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 1 [usable: 1], UpdateFeatures(57): 0 [usable: 0], Envelope(58): UNSUPPORTED, DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], ConsumerGroupHeartbeat(68): UNSUPPORTED). 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received OFFSET_FETCH response from node 2147483645 for request with header RequestHeader(apiKey=OFFSET_FETCH, apiVersion=8, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=7, headerVersion=2): OffsetFetchResponseData(throttleTimeMs=0, topics=[], errorCode=0, groups=[OffsetFetchResponseGroup(groupId='java-kafka-streams', topics=[OffsetFetchResponseTopics(name='input-topic', partitions=[OffsetFetchResponsePartitions(partitionIndex=0, committedOffset=628, committedLeaderEpoch=-1, metadata='AgAAAYmSCPDl', errorCode=0)])], errorCode=0)]) 2023-07-26 21:27:18 DEBUG Sender:477 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending transactional request InitProducerIdRequestData(transactionalId='java-kafka-streams-0_0', transactionTimeoutMs=10000, producerId=-1, producerEpoch=-1) to node a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com:9094 (id: 0 rack: null) with correlation ID 5 2023-07-26 21:27:18 DEBUG NetworkClient:532 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending INIT_PRODUCER_ID request with header RequestHeader(apiKey=INIT_PRODUCER_ID, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=5, headerVersion=2) and timeout 30000 to node 0: InitProducerIdRequestData(transactionalId='java-kafka-streams-0_0', transactionTimeoutMs=10000, producerId=-1, producerEpoch=-1) 2023-07-26 21:27:18 DEBUG NetworkClient:918 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Received INIT_PRODUCER_ID response from node 0 for request with header RequestHeader(apiKey=INIT_PRODUCER_ID, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=5, headerVersion=2): InitProducerIdResponseData(throttleTimeMs=0, errorCode=0, producerId=1, producerEpoch=18) 2023-07-26 21:27:18 INFO TransactionManager:440 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] ProducerId set to 1 with epoch 18 2023-07-26 21:27:18 DEBUG TransactionManager:988 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Transition from state INITIALIZING to READY 2023-07-26 21:27:18 INFO StreamTask:251 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] task [0_0] Initialized 2023-07-26 21:27:18 DEBUG StreamTask:948 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] task [0_0] A committed timestamp was detected: setting the partition time of partition input-topic-0 to 1690372206821 in stream task 0_0 2023-07-26 21:27:18 INFO StreamTask:279 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] task [0_0] Restored and ready to run 2023-07-26 21:27:18 DEBUG KafkaConsumer:2086 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Resuming partitions [input-topic-0] 2023-07-26 21:27:18 DEBUG StoreChangelogReader:325 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Transiting to update standby tasks: {} 2023-07-26 21:27:18 DEBUG KafkaConsumer:2086 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-restore-consumer, groupId=null] Resuming partitions [] 2023-07-26 21:27:18 DEBUG StoreChangelogReader:948 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Resumed partitions [] from the restore consumer 2023-07-26 21:27:18 INFO StreamThread:902 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Restoration took 255 ms for all tasks [0_0] 2023-07-26 21:27:18 INFO StreamThread:239 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] State transition from PARTITIONS_ASSIGNED to RUNNING 2023-07-26 21:27:19 INFO KafkaStreams:340 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] State transition from REBALANCING to RUNNING 2023-07-26 21:27:19 DEBUG StreamThread:908 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Initialization call done. State is RUNNING 2023-07-26 21:27:19 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state RUNNING 2023-07-26 21:27:19 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:19 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:19 DEBUG StreamThread:806 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Processing tasks with 1 iterations. 2023-07-26 21:27:19 INFO KafkaConsumer:2302 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Requesting the log end offset for input-topic-0 in order to compute lag 2023-07-26 21:27:19 DEBUG OffsetFetcher:565 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=1, topics=[ListOffsetsTopic(name='input-topic', partitions=[ListOffsetsPartition(partitionIndex=0, currentLeaderEpoch=0, timestamp=-1, maxNumOffsets=1)])]) to broker aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG StreamThread:825 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Processed 0 records with 1 iterations; invoking punctuators if necessary 2023-07-26 21:27:19 DEBUG StreamThread:837 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] 0 punctuators ran. 2023-07-26 21:27:19 DEBUG StreamThread:1117 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] since 1690374439018ms has elapsed (commit interval is 100ms) 2023-07-26 21:27:19 DEBUG TaskExecutor:176 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Committing task offsets {} 2023-07-26 21:27:19 DEBUG StreamThread:949 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Invoking poll on main Consumer 2023-07-26 21:27:19 DEBUG ConsumerCoordinator:1477 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Fetching committed offsets for partitions: [input-topic-0] 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending OFFSET_FETCH request with header RequestHeader(apiKey=OFFSET_FETCH, apiVersion=8, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=9, headerVersion=2) and timeout 30000 to node 2147483645: OffsetFetchRequestData(groupId='', topics=[], groups=[OffsetFetchRequestGroup(groupId='java-kafka-streams', topics=[OffsetFetchRequestTopics(name='input-topic', partitionIndexes=[0])])], requireStable=true) 2023-07-26 21:27:19 DEBUG ClientUtils:113 - Resolved host aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com as 52.192.119.151,52.198.83.252,3.115.103.113 2023-07-26 21:27:19 DEBUG NetworkClient:1031 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Initiating connection to node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) using address aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com/52.192.119.151 2023-07-26 21:27:19 DEBUG Selector:531 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 2023-07-26 21:27:19 DEBUG NetworkClient:993 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Completed connection to node 2. Fetching API versions. 2023-07-26 21:27:19 DEBUG NetworkClient:1007 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Initiating API versions fetch from node 2. 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending API_VERSIONS request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=10, headerVersion=2) and timeout 30000 to node 2: ApiVersionsRequestData(clientSoftwareName='apache-kafka-java', clientSoftwareVersion='3.5.1') 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received OFFSET_FETCH response from node 2147483645 for request with header RequestHeader(apiKey=OFFSET_FETCH, apiVersion=8, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=9, headerVersion=2): OffsetFetchResponseData(throttleTimeMs=0, topics=[], errorCode=0, groups=[OffsetFetchResponseGroup(groupId='java-kafka-streams', topics=[OffsetFetchResponseTopics(name='input-topic', partitions=[OffsetFetchResponsePartitions(partitionIndex=0, committedOffset=628, committedLeaderEpoch=-1, metadata='AgAAAYmSCPDl', errorCode=0)])], errorCode=0)]) 2023-07-26 21:27:19 INFO ConsumerCoordinator:975 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Setting offset for partition input-topic-0 to the committed offset FetchPosition{offset=628, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)], epoch=0}} 2023-07-26 21:27:19 DEBUG AbstractFetch:484 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Added READ_COMMITTED fetch request for partition input-topic-0 at position FetchPosition{offset=628, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)], epoch=0}} to node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG FetchSessionHandler:279 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Built full fetch (sessionId=INVALID, epoch=INITIAL) for node 2 with 1 partition(s). 2023-07-26 21:27:19 DEBUG AbstractFetch:246 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending READ_COMMITTED FullFetchRequest(toSend=(input-topic-0), canUseTopicIds=True) to broker aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG AbstractFetch:252 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Adding pending request for node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received API_VERSIONS response from node 2 for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=10, headerVersion=2): ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0, minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=13), ApiVersion(apiKey=2, minVersion=0, maxVersion=7), ApiVersion(apiKey=3, minVersion=0, maxVersion=12), ApiVersion(apiKey=4, minVersion=0, maxVersion=6), ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6, minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3), ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9, minVersion=0, maxVersion=8), ApiVersion(apiKey=10, minVersion=0, maxVersion=4), ApiVersion(apiKey=11, minVersion=0, maxVersion=9), ApiVersion(apiKey=12, minVersion=0, maxVersion=4), ApiVersion(apiKey=13, minVersion=0, maxVersion=5), ApiVersion(apiKey=14, minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5), ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17, minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3), ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20, minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2), ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23, minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3), ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26, minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1), ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29, minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2), ApiVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32, minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2), ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35, minVersion=0, maxVersion=3), ApiVersion(apiKey=36, minVersion=0, maxVersion=2), ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38, minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2), ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41, minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2), ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44, minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0), ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47, minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1), ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVersion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0), ApiVersion(apiKey=56, minVersion=0, maxVersion=1), ApiVersion(apiKey=57, minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0), ApiVersion(apiKey=61, minVersion=0, maxVersion=0), ApiVersion(apiKey=65, minVersion=0, maxVersion=0), ApiVersion(apiKey=66, minVersion=0, maxVersion=0), ApiVersion(apiKey=67, minVersion=0, maxVersion=0)], throttleTimeMs=0, supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[], zkMigrationReady=false) 2023-07-26 21:27:19 DEBUG NetworkClient:963 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Node 2 has finalized features epoch: 0, finalized features: [], supported features: [], ZK migration ready: false, API versions: (Produce(0): 0 to 9 [usable: 9], Fetch(1): 0 to 13 [usable: 13], ListOffsets(2): 0 to 7 [usable: 7], Metadata(3): 0 to 12 [usable: 12], LeaderAndIsr(4): 0 to 6 [usable: 6], StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 8 [usable: 8], FindCoordinator(10): 0 to 4 [usable: 4], JoinGroup(11): 0 to 9 [usable: 9], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 5 [usable: 5], SyncGroup(14): 0 to 5 [usable: 5], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6], DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4], OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3 [usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3 [usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to 3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2 [usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4 [usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0 to 2 [usable: 2], DescribeLogDirs(35): 0 to 3 [usable: 3], SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable: 3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2], DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to 1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1], DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51): 0 [usable: 0], AlterPartition(56): 0 to 1 [usable: 1], UpdateFeatures(57): 0 [usable: 0], Envelope(58): UNSUPPORTED, DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0], DescribeTransactions(65): 0 [usable: 0], ListTransactions(66): 0 [usable: 0], AllocateProducerIds(67): 0 [usable: 0], ConsumerGroupHeartbeat(68): UNSUPPORTED). 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=7, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=8, headerVersion=2) and timeout 30000 to node 2: ListOffsetsRequestData(replicaId=-1, isolationLevel=1, topics=[ListOffsetsTopic(name='input-topic', partitions=[ListOffsetsPartition(partitionIndex=0, currentLeaderEpoch=0, timestamp=-1, maxNumOffsets=1)])]) 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=11, headerVersion=2) and timeout 30000 to node 2: FetchRequestData(clusterId=null, replicaId=-1, replicaState=ReplicaState(replicaId=-1, replicaEpoch=-1), maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=1, sessionId=0, sessionEpoch=0, topics=[FetchTopic(topic='input-topic', topicId=Xdsk7Q5ITWuJQQj6SGLmjA, partitions=[FetchPartition(partition=0, currentLeaderEpoch=0, fetchOffset=628, lastFetchedEpoch=-1, logStartOffset=-1, partitionMaxBytes=1048576)])], forgottenTopicsData=[], rackId='') 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received LIST_OFFSETS response from node 2 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=7, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=8, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='input-topic', partitions=[ListOffsetsPartitionResponse(partitionIndex=0, errorCode=0, oldStyleOffsets=[], timestamp=-1, offset=1164, leaderEpoch=0)])]) 2023-07-26 21:27:19 DEBUG OffsetFetcher:617 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Handling ListOffsetResponse response for input-topic-0. Fetched offset 1164, timestamp -1 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received FETCH response from node 2 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=11, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=1104050658, responses=[FetchableTopicResponse(topic='', topicId=Xdsk7Q5ITWuJQQj6SGLmjA, partitions=[PartitionData(partitionIndex=0, errorCode=0, highWatermark=1164, lastStableOffset=1164, logStartOffset=0, divergingEpoch=EpochEndOffset(epoch=-1, endOffset=-1), currentLeader=LeaderIdAndEpoch(leaderId=-1, leaderEpoch=-1), snapshotId=SnapshotId(endOffset=-1, epoch=-1), abortedTransactions=[], preferredReadReplica=-1, records=MemoryRecords(size=41686, buffer=java.nio.HeapByteBuffer[pos=0 lim=41686 cap=41689]))])]) 2023-07-26 21:27:19 DEBUG FetchSessionHandler:566 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Node 2 sent a full fetch response that created a new incremental fetch session 1104050658 with 1 response partition(s) 2023-07-26 21:27:19 DEBUG AbstractFetch:181 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Fetch READ_COMMITTED at offset 628 for partition input-topic-0 returned fetch data PartitionData(partitionIndex=0, errorCode=0, highWatermark=1164, lastStableOffset=1164, logStartOffset=0, divergingEpoch=EpochEndOffset(epoch=-1, endOffset=-1), currentLeader=LeaderIdAndEpoch(leaderId=-1, leaderEpoch=-1), snapshotId=SnapshotId(endOffset=-1, epoch=-1), abortedTransactions=[], preferredReadReplica=-1, records=MemoryRecords(size=41686, buffer=java.nio.HeapByteBuffer[pos=0 lim=41686 cap=41689])) 2023-07-26 21:27:19 DEBUG AbstractFetch:199 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Removing pending request for node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG AbstractFetch:484 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Added READ_COMMITTED fetch request for partition input-topic-0 at position FetchPosition{offset=1164, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)], epoch=0}} to node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG FetchSessionHandler:356 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Built incremental fetch (sessionId=1104050658, epoch=1) for node 2. Added 0 partition(s), altered 1 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 1 partition(s) 2023-07-26 21:27:19 DEBUG AbstractFetch:246 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending READ_COMMITTED IncrementalFetchRequest(toSend=(input-topic-0), toForget=(), toReplace=(), implied=(), canUseTopicIds=True) to broker aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG AbstractFetch:252 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Adding pending request for node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=12, headerVersion=2) and timeout 30000 to node 2: FetchRequestData(clusterId=null, replicaId=-1, replicaState=ReplicaState(replicaId=-1, replicaEpoch=-1), maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=1, sessionId=1104050658, sessionEpoch=1, topics=[FetchTopic(topic='input-topic', topicId=Xdsk7Q5ITWuJQQj6SGLmjA, partitions=[FetchPartition(partition=0, currentLeaderEpoch=0, fetchOffset=1164, lastFetchedEpoch=-1, logStartOffset=-1, partitionMaxBytes=1048576)])], forgottenTopicsData=[], rackId='') 2023-07-26 21:27:19 DEBUG StreamThread:985 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Main Consumer poll completed in 177 ms and fetched 536 records from partitions [input-topic-0] 2023-07-26 21:27:19 DEBUG StreamThread:913 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotently invoking restoration logic in state RUNNING 2023-07-26 21:27:19 DEBUG StoreChangelogReader:440 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Finished restoring all changelogs [] 2023-07-26 21:27:19 DEBUG StreamThread:919 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Idempotent restore call done. Thread state has not changed. 2023-07-26 21:27:19 DEBUG StreamThread:806 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Processing tasks with 1 iterations. 2023-07-26 21:27:19 DEBUG TransactionManager:988 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Transition from state READY to IN_TRANSACTION 2023-07-26 21:27:19 DEBUG NetworkClient:1185 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(topicId=AAAAAAAAAAAAAAAAAAAAAA, name='output-topic')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=6, headerVersion=2) and timeout 30000 to node 2: MetadataRequestData(topics=[MetadataRequestTopic(topicId=AAAAAAAAAAAAAAAAAAAAAA, name='output-topic')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Received METADATA response from node 2 for request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=6, headerVersion=2): MetadataResponseData(throttleTimeMs=0, brokers=[MetadataResponseBroker(nodeId=0, host='a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=2, host='aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null), MetadataResponseBroker(nodeId=1, host='a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com', port=9094, rack=null)], clusterId='cvnYABPTTUWaswr-J8RUuA', controllerId=2, topics=[MetadataResponseTopic(errorCode=0, name='output-topic', topicId=caSS9T44RtimpxVs9fbKrA, isInternal=false, partitions=[MetadataResponsePartition(errorCode=0, partitionIndex=0, leaderId=0, leaderEpoch=0, replicaNodes=[0], isrNodes=[0], offlineReplicas=[])], topicAuthorizedOperations=-2147483648)], clusterAuthorizedOperations=-2147483648) 2023-07-26 21:27:19 DEBUG Metadata:399 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Setting the last seen epoch of partition output-topic-0 to 0 since the last known epoch was undefined. 2023-07-26 21:27:19 DEBUG Metadata:291 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Updated cluster metadata updateVersion 3 to MetadataCache{clusterId='cvnYABPTTUWaswr-J8RUuA', nodes={0=a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com:9094 (id: 0 rack: null), 1=a90079f8dff6946bba3239f510b146c0-1329634287.ap-northeast-1.elb.amazonaws.com:9094 (id: 1 rack: null), 2=aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)}, partitions=[PartitionMetadata(error=NONE, partition=output-topic-0, leader=Optional[0], leaderEpoch=Optional[0], replicas=0, isr=0, offlineReplicas=)], controller=aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null)} 2023-07-26 21:27:19 DEBUG KafkaProducer:1073 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Exception occurred during message send: org.apache.kafka.common.errors.RecordTooLargeException: The message is 11000088 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration. 2023-07-26 21:27:19 ERROR RecordCollectorImpl:322 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] stream-task [0_0] Error encountered sending record to topic output-topic for task 0_0 due to: org.apache.kafka.common.errors.RecordTooLargeException: The message is 11000088 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration. Exception handler choose to CONTINUE processing in spite of this error but written offsets would not be recorded. org.apache.kafka.common.errors.RecordTooLargeException: The message is 11000088 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration. 2023-07-26 21:27:19 INFO TransactionManager:393 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Transiting to abortable error state due to org.apache.kafka.common.errors.RecordTooLargeException: The message is 11000088 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration. 2023-07-26 21:27:19 DEBUG TransactionManager:986 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Transition from state IN_TRANSACTION to error state ABORTABLE_ERROR org.apache.kafka.common.errors.RecordTooLargeException: The message is 11000088 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration. 2023-07-26 21:27:19 DEBUG StreamThread:825 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Processed 1 records with 1 iterations; invoking punctuators if necessary 2023-07-26 21:27:19 DEBUG StreamThread:837 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] 0 punctuators ran. 2023-07-26 21:27:19 DEBUG StreamThread:1117 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Committing all active tasks [0_0] and standby tasks [] since 273ms has elapsed (commit interval is 100ms) 2023-07-26 21:27:19 DEBUG RecordCollectorImpl:345 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] stream-task [0_0] Flushing record collector 2023-07-26 21:27:19 DEBUG StreamTask:419 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] task [0_0] Prepared RUNNING task for committing 2023-07-26 21:27:19 DEBUG TaskExecutor:176 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Committing task offsets {0_0={input-topic-0=OffsetAndMetadata{offset=629, leaderEpoch=null, metadata='AgAAAYmSGuLv'}}} 2023-07-26 21:27:19 ERROR KafkaStreams:537 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] Encountered the following exception during processing and the registered exception handler opted to SHUTDOWN_CLIENT. The streams client is going to shut down now. org.apache.kafka.streams.errors.StreamsException: Error encountered trying to commit a transaction [stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] stream-task [0_0]] at org.apache.kafka.streams.processor.internals.StreamsProducer.commitTransaction(StreamsProducer.java:313) ~[kafka-streams-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.TaskExecutor.commitOffsetsOrTransaction(TaskExecutor.java:186) ~[kafka-streams-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.TaskExecutor.commitTasksAndMaybeUpdateCommittableOffsets(TaskExecutor.java:154) ~[kafka-streams-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.TaskManager.commitTasksAndMaybeUpdateCommittableOffsets(TaskManager.java:1678) ~[kafka-streams-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.TaskManager.commit(TaskManager.java:1646) ~[kafka-streams-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.StreamThread.maybeCommit(StreamThread.java:1121) ~[kafka-streams-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:840) ~[kafka-streams-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:617) ~[kafka-streams-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:579) [kafka-streams-3.5.1.jar:?] Caused by: org.apache.kafka.common.KafkaException: Cannot execute transactional method because we are in an error state at org.apache.kafka.clients.producer.internals.TransactionManager.maybeFailWithError(TransactionManager.java:1010) ~[kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.producer.internals.TransactionManager.sendOffsetsToTransaction(TransactionManager.java:306) ~[kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.producer.KafkaProducer.sendOffsetsToTransaction(KafkaProducer.java:757) ~[kafka-clients-3.5.1.jar:?] at org.apache.kafka.streams.processor.internals.StreamsProducer.commitTransaction(StreamsProducer.java:300) ~[kafka-streams-3.5.1.jar:?] ... 8 more Caused by: org.apache.kafka.common.errors.RecordTooLargeException: The message is 11000088 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration. 2023-07-26 21:27:19 INFO KafkaStreams:340 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] State transition from RUNNING to PENDING_ERROR 2023-07-26 21:27:19 INFO StreamThread:239 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN 2023-07-26 21:27:19 INFO StreamThread:1182 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Shutting down unclean 2023-07-26 21:27:19 INFO StreamThread:1168 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Informed to shut down 2023-07-26 21:27:19 DEBUG StreamThread:224 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Ignoring request to transit from PENDING_SHUTDOWN to PENDING_SHUTDOWN: only DEAD state is a valid next state 2023-07-26 21:27:19 INFO KafkaStreams:1367 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] Shutting down 1 stream threads 2023-07-26 21:27:19 DEBUG KafkaStreams:1374 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] Shutdown java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1 complete 2023-07-26 21:27:19 DEBUG RecordCollectorImpl:345 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] stream-task [0_0] Flushing record collector 2023-07-26 21:27:19 DEBUG StreamTask:419 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] task [0_0] Prepared RUNNING task for committing 2023-07-26 21:27:19 INFO StreamTask:1235 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] task [0_0] Suspended from RUNNING 2023-07-26 21:27:19 DEBUG ProcessorStateManager:544 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] stream-task [0_0] Closing its state manager and all the registered state stores: {} 2023-07-26 21:27:19 DEBUG StreamTask:138 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] task [0_0] Wiping state stores for ACTIVE task 0_0 2023-07-26 21:27:19 INFO RecordCollectorImpl:373 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] stream-task [0_0] Closing record collector dirty 2023-07-26 21:27:19 INFO KafkaProducer:833 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Aborting incomplete transaction 2023-07-26 21:27:19 DEBUG TransactionManager:988 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Transition from state ABORTABLE_ERROR to ABORTING_TRANSACTION 2023-07-26 21:27:19 DEBUG TransactionManager:1028 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Enqueuing transactional request EndTxnRequestData(transactionalId='java-kafka-streams-0_0', producerId=1, producerEpoch=18, committed=false) 2023-07-26 21:27:19 INFO TransactionManager:236 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Invoking InitProducerId with current producer ID and epoch ProducerIdAndEpoch(producerId=1, epoch=18) in order to bump the epoch 2023-07-26 21:27:19 DEBUG TransactionManager:1028 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Enqueuing transactional request InitProducerIdRequestData(transactionalId='java-kafka-streams-0_0', transactionTimeoutMs=10000, producerId=1, producerEpoch=18) 2023-07-26 21:27:19 DEBUG TransactionManager:792 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Not sending EndTxn for completed transaction since no partitions or offsets were successfully added 2023-07-26 21:27:19 DEBUG TransactionManager:988 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Transition from state ABORTING_TRANSACTION to INITIALIZING 2023-07-26 21:27:19 DEBUG Sender:477 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending transactional request InitProducerIdRequestData(transactionalId='java-kafka-streams-0_0', transactionTimeoutMs=10000, producerId=1, producerEpoch=18) to node a4ecd0c7876174076b3d5b3b30960b96-48688624.ap-northeast-1.elb.amazonaws.com:9094 (id: 0 rack: null) with correlation ID 7 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Sending INIT_PRODUCER_ID request with header RequestHeader(apiKey=INIT_PRODUCER_ID, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=7, headerVersion=2) and timeout 30000 to node 0: InitProducerIdRequestData(transactionalId='java-kafka-streams-0_0', transactionTimeoutMs=10000, producerId=1, producerEpoch=18) 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Received INIT_PRODUCER_ID response from node 0 for request with header RequestHeader(apiKey=INIT_PRODUCER_ID, apiVersion=4, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, correlationId=7, headerVersion=2): InitProducerIdResponseData(throttleTimeMs=0, errorCode=0, producerId=1, producerEpoch=19) 2023-07-26 21:27:19 INFO TransactionManager:440 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] ProducerId set to 1 with epoch 19 2023-07-26 21:27:19 DEBUG TransactionManager:988 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Transition from state INITIALIZING to READY 2023-07-26 21:27:19 INFO StreamTask:555 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] task [0_0] Closed dirty 2023-07-26 21:27:19 INFO KafkaProducer:1310 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. 2023-07-26 21:27:19 DEBUG Sender:249 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Beginning shutdown of Kafka producer I/O thread, sending remaining records. 2023-07-26 21:27:19 DEBUG Sender:291 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Shutdown of Kafka producer I/O thread has completed. 2023-07-26 21:27:19 INFO Metrics:693 - Metrics scheduler closed 2023-07-26 21:27:19 INFO Metrics:697 - Closing reporter org.apache.kafka.common.metrics.JmxReporter 2023-07-26 21:27:19 INFO Metrics:703 - Metrics reporters closed 2023-07-26 21:27:19 INFO AppInfoParser:83 - App info kafka.producer for java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer unregistered 2023-07-26 21:27:19 DEBUG KafkaProducer:1363 - [Producer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-0_0-producer, transactionalId=java-kafka-streams-0_0] Kafka producer has been closed 2023-07-26 21:27:19 INFO TaskManager:1323 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Shutdown complete 2023-07-26 21:27:19 INFO KafkaConsumer:1089 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-restore-consumer, groupId=null] Unsubscribed all topics or patterns and assigned partitions 2023-07-26 21:27:19 DEBUG ConsumerCoordinator:894 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Executing onLeavePrepare with generation Generation{generationId=18, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', protocol='stream'} 2023-07-26 21:27:19 INFO ConsumerCoordinator:338 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Revoke previously assigned partitions input-topic-0 2023-07-26 21:27:19 DEBUG StreamThread:82 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Current state PENDING_SHUTDOWN: revoked partitions [input-topic-0] because of consumer rebalance. currently assigned active tasks: [] currently assigned standby tasks: [] 2023-07-26 21:27:19 DEBUG StreamThread:224 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Ignoring request to transit from PENDING_SHUTDOWN to PARTITIONS_REVOKED: only DEAD state is a valid next state 2023-07-26 21:27:19 DEBUG TaskManager:964 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] The following revoked partitions [input-topic-0] are missing from the current task partitions. It could potentially be due to race condition of consumer detecting the heartbeat failure, or the tasks have been cleaned up by the handleAssignment callback. 2023-07-26 21:27:19 DEBUG TaskExecutor:176 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Committing task offsets {} 2023-07-26 21:27:19 INFO StreamThread:97 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] partition revocation took 1 ms. 2023-07-26 21:27:19 INFO ConsumerCoordinator:1133 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Member java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125 sending LeaveGroup request to coordinator aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2147483645 rack: null) due to the consumer unsubscribed from all topics 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending LEAVE_GROUP request with header RequestHeader(apiKey=LEAVE_GROUP, apiVersion=5, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=13, headerVersion=2) and timeout 30000 to node 2147483645: LeaveGroupRequestData(groupId='java-kafka-streams', memberId='', members=[MemberIdentity(memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, reason='the consumer unsubscribed from all topics')]) 2023-07-26 21:27:19 INFO ConsumerCoordinator:1025 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Resetting generation and member id due to: consumer pro-actively leaving the group 2023-07-26 21:27:19 INFO ConsumerCoordinator:1072 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Request joining group due to: consumer pro-actively leaving the group 2023-07-26 21:27:19 INFO KafkaConsumer:1089 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Unsubscribed all topics or patterns and assigned partitions 2023-07-26 21:27:19 DEBUG ConsumerCoordinator:1543 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Heartbeat thread has closed 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received LEAVE_GROUP response from node 2147483645 for request with header RequestHeader(apiKey=LEAVE_GROUP, apiVersion=5, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=13, headerVersion=2): LeaveGroupResponseData(throttleTimeMs=0, errorCode=0, members=[MemberResponse(memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, errorCode=0)]) 2023-07-26 21:27:19 DEBUG ConsumerCoordinator:1168 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] LeaveGroup response with Generation{generationId=18, memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', protocol='stream'} returned successfully: ClientResponse(receivedTimeMs=1690374439390, latencyMs=11, disconnected=false, timedOut=false, requestHeader=RequestHeader(apiKey=LEAVE_GROUP, apiVersion=5, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=13, headerVersion=2), responseBody=LeaveGroupResponseData(throttleTimeMs=0, errorCode=0, members=[MemberResponse(memberId='java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer-a5ecf576-87c0-4ea1-b558-6be5c4f0b125', groupInstanceId=null, errorCode=0)])) 2023-07-26 21:27:19 DEBUG FetchSessionHandler:602 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Set the metadata for next fetch request to close the existing session ID=1104050658 2023-07-26 21:27:19 DEBUG FetchSessionHandler:279 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Built full fetch (sessionId=1104050658, epoch=FINAL) for node 2 with 0 partition(s). 2023-07-26 21:27:19 DEBUG AbstractFetch:246 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending READ_COMMITTED FullFetchRequest(toSend=(), canUseTopicIds=True) to broker aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG AbstractFetch:252 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Adding pending request for node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG NetworkClient:532 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=14, headerVersion=2) and timeout 30000 to node 2: FetchRequestData(clusterId=null, replicaId=-1, replicaState=ReplicaState(replicaId=-1, replicaEpoch=-1), maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=1, sessionId=1104050658, sessionEpoch=-1, topics=[], forgottenTopicsData=[], rackId='') 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received FETCH response from node 2 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=12, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=1104050658, responses=[]) 2023-07-26 21:27:19 DEBUG FetchSessionHandler:566 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Node 2 sent a full fetch response that created a new incremental fetch session 1104050658 with 0 response partition(s) 2023-07-26 21:27:19 DEBUG AbstractFetch:199 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Removing pending request for node aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 DEBUG NetworkClient:918 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Received FETCH response from node 2 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, correlationId=14, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=0, responses=[]) 2023-07-26 21:27:19 DEBUG AbstractFetch:740 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Successfully sent a close message for fetch session: 1104050658 to node: aa193f86ba5f44cc4a02e874052aa89d-868019195.ap-northeast-1.elb.amazonaws.com:9094 (id: 2 rack: null) 2023-07-26 21:27:19 INFO Metrics:693 - Metrics scheduler closed 2023-07-26 21:27:19 INFO Metrics:697 - Closing reporter org.apache.kafka.common.metrics.JmxReporter 2023-07-26 21:27:19 INFO Metrics:703 - Metrics reporters closed 2023-07-26 21:27:19 INFO AppInfoParser:83 - App info kafka.consumer for java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer unregistered 2023-07-26 21:27:19 DEBUG KafkaConsumer:2482 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-consumer, groupId=java-kafka-streams] Kafka consumer has been closed 2023-07-26 21:27:19 INFO Metrics:693 - Metrics scheduler closed 2023-07-26 21:27:19 INFO Metrics:697 - Closing reporter org.apache.kafka.common.metrics.JmxReporter 2023-07-26 21:27:19 INFO Metrics:703 - Metrics reporters closed 2023-07-26 21:27:19 INFO AppInfoParser:83 - App info kafka.consumer for java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-restore-consumer unregistered 2023-07-26 21:27:19 DEBUG KafkaConsumer:2482 - [Consumer clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1-restore-consumer, groupId=null] Kafka consumer has been closed 2023-07-26 21:27:19 INFO StreamThread:239 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD 2023-07-26 21:27:19 INFO StreamThread:1217 - stream-thread [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-StreamThread-1] Shutdown complete 2023-07-26 21:27:19 INFO KafkaStreams:1389 - stream-client [java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d] Shutdown 1 stream threads complete 2023-07-26 21:27:19 DEBUG KafkaAdminClient:644 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Initiating close operation. 2023-07-26 21:27:19 DEBUG KafkaAdminClient:660 - [AdminClient clientId=java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin] Waiting for the I/O thread to exit. Hard shutdown in 31536000000 ms. 2023-07-26 21:27:19 INFO AppInfoParser:83 - App info kafka.admin.client for java-kafka-streams-e3187cf9-5337-4155-a7cd-fd4e426b889d-admin unregistered