14:28:45.733 [kafka-streams-test-service-akka.actor.default-dispatcher-4] INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started 14:28:45.971 [main] INFO o.apache.kafka.streams.StreamsConfig - StreamsConfig values: application.id = map-function-scala-example application.server = bootstrap.servers = [localhost:9092] buffered.records.per.partition = 1000 cache.max.bytes.buffering = 10485760 client.id = commit.interval.ms = 30000 connections.max.idle.ms = 540000 key.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde 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 partition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper poll.ms = 100 receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 replication.factor = 1 request.timeout.ms = 40000 retry.backoff.ms = 100 rocksdb.config.setter = null security.protocol = PLAINTEXT send.buffer.bytes = 131072 state.cleanup.delay.ms = 60000 state.dir = /tmp/kafka-streams timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp value.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde windowstore.changelog.additional.retention.ms = 86400000 zookeeper.connect = 14:28:46.113 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-global-restore-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:46.114 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:46.135 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.171 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.173 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.174 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.174 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.176 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.176 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.177 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.219 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:46.220 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:46.220 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:46.223 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:46.241 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:46.242 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:46.242 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:46.243 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:46.243 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:46.245 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:46.245 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:46.245 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:46.267 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.commit-latency 14:28:46.268 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.poll-latency 14:28:46.270 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.process-latency 14:28:46.271 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.punctuate-latency 14:28:46.271 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.task-created 14:28:46.271 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.task-closed 14:28:46.271 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.skipped-records 14:28:46.272 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating producer client 14:28:46.284 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig values: acks = 1 batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.id = map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null 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.fetch.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 10 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS timeout.ms = 30000 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer 14:28:46.292 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 14:28:46.297 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 14:28:46.297 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.298 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.298 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.298 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.298 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.298 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.298 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.298 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.305 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name batch-size 14:28:46.305 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name compression-rate 14:28:46.305 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name queue-time 14:28:46.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name request-time 14:28:46.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 14:28:46.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-per-request 14:28:46.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-retries 14:28:46.307 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name errors 14:28:46.307 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-size-max 14:28:46.311 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:46.311 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.k.c.producer.internals.Sender - Starting Kafka producer I/O thread. 14:28:46.311 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:46.311 [main] DEBUG o.a.k.clients.producer.KafkaProducer - Kafka producer started 14:28:46.311 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating consumer client 14:28:46.314 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = map-function-scala-example heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 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.StreamPartitionAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:46.314 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:46.315 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.315 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.315 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.315 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.315 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.316 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.316 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.316 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.323 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.323 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.323 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.323 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.323 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.324 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.324 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.324 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.325 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:46.325 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:46.325 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:46.325 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:46.326 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:46.326 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:46.326 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:46.326 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:46.326 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:46.326 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:46.327 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:46.327 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:46.327 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating restore consumer client 14:28:46.327 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-restore-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:46.327 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:46.327 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.327 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.327 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.328 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.328 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.328 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.328 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.328 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.329 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:46.329 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:46.329 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:46.329 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:46.330 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:46.330 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:46.330 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:46.331 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:46.331 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:46.331 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:46.331 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:46.331 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:46.331 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] State transition from NOT_RUNNING to RUNNING. 14:28:46.335 [main] DEBUG o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] Starting Kafka Stream process. 14:28:46.336 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.336 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.336 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.336 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.336 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.336 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.337 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.337 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.337 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.337 [main] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:46.404 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:46.405 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:46.405 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:46.408 [main] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 326640, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:46.408 [main] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:46.409 [main] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:46.495 [main] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:46.609 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:46.609 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:46.609 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:46.610 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:46.610 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:46.610 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:46.610 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:46.611 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-sent 14:28:46.611 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-received 14:28:46.611 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.latency 14:28:46.611 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] State transition from CREATED to RUNNING. 14:28:46.625 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name put 14:28:46.626 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-put 14:28:46.626 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name put-if-absent 14:28:46.626 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-put-if-absent 14:28:46.627 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name get 14:28:46.627 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-get 14:28:46.627 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name delete 14:28:46.627 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-delete 14:28:46.628 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name put-all 14:28:46.628 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-put-all 14:28:46.628 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name all 14:28:46.628 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-all 14:28:46.628 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name range 14:28:46.629 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-range 14:28:46.629 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name flush 14:28:46.629 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-flush 14:28:46.629 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name restore 14:28:46.629 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name test-store-restore 14:28:46.766 [GlobalStreamThread] INFO o.a.k.s.p.i.GlobalStateManagerImpl - restoring state for global store test-store 14:28:46.768 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:46.769 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:46.770 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:46.770 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:46.770 [GlobalStreamThread] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:46.770 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:46.770 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:46.772 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:46.773 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Sending metadata request (type=MetadataRequest, topics=) to node -1 14:28:46.778 [GlobalStreamThread] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 2 to Cluster(id = _Epo8QiSSuGbI1zi8iEXLA, nodes = [10.20.69.86:9092 (id: 0 rack: null)], partitions = []) 14:28:46.784 [GlobalStreamThread] DEBUG o.a.k.clients.consumer.KafkaConsumer - Subscribed to partition(s): StreamConfig2-0 14:28:46.785 [GlobalStreamThread] DEBUG o.a.k.c.consumer.internals.Fetcher - Partition StreamConfig2-0 is unknown for fetching offset, wait for metadata refresh 14:28:46.785 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Initialize connection to node 0 for sending metadata request 14:28:46.785 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node 0 at 10.20.69.86:9092. 14:28:46.786 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-0.bytes-sent 14:28:46.786 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-0.bytes-received 14:28:46.786 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-0.latency 14:28:46.786 [GlobalStreamThread] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node 0 14:28:46.786 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node 0. Fetching API versions. 14:28:46.786 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node 0. 14:28:46.788 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node 0: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:46.789 [GlobalStreamThread] DEBUG o.apache.kafka.clients.NetworkClient - Sending metadata request (type=MetadataRequest, topics=StreamConfig2) to node 0 14:28:46.790 [GlobalStreamThread] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 3 to Cluster(id = _Epo8QiSSuGbI1zi8iEXLA, nodes = [10.20.69.86:9092 (id: 0 rack: null)], partitions = [Partition(topic = StreamConfig2, partition = 0, leader = 0, replicas = [0], isr = [0])]) 14:28:46.797 [GlobalStreamThread] DEBUG o.a.k.c.consumer.internals.Fetcher - Handling ListOffsetResponse response for StreamConfig2-0. Fetched offset 2, timestamp -1 14:28:46.797 [GlobalStreamThread] DEBUG o.a.k.clients.consumer.KafkaConsumer - Subscribed to partition(s): StreamConfig2-0 14:28:46.797 [GlobalStreamThread] DEBUG o.a.k.clients.consumer.KafkaConsumer - Seeking to offset 2 for partition StreamConfig2-0 14:28:46.797 [GlobalStreamThread] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:46.800 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name -1_-1-test-store-hitRatio 14:28:46.802 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name process 14:28:46.802 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KSTREAM-SOURCE-0000000000-process 14:28:46.802 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name punctuate 14:28:46.802 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KSTREAM-SOURCE-0000000000-punctuate 14:28:46.803 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name create 14:28:46.803 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KSTREAM-SOURCE-0000000000-create 14:28:46.803 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name destroy 14:28:46.803 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KSTREAM-SOURCE-0000000000-destroy 14:28:46.804 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name forward 14:28:46.804 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KSTREAM-SOURCE-0000000000-forward 14:28:46.806 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KTABLE-SOURCE-0000000001-process 14:28:46.806 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KTABLE-SOURCE-0000000001-punctuate 14:28:46.807 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KTABLE-SOURCE-0000000001-create 14:28:46.807 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KTABLE-SOURCE-0000000001-destroy 14:28:46.807 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name task.-1_-1.KTABLE-SOURCE-0000000001-forward 14:28:46.810 [GlobalStreamThread] DEBUG o.a.k.clients.consumer.KafkaConsumer - Subscribed to partition(s): StreamConfig2-0 14:28:46.810 [GlobalStreamThread] DEBUG o.a.k.clients.consumer.KafkaConsumer - Seeking to offset 2 for partition StreamConfig2-0 14:28:46.811 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Starting 14:28:46.811 [StreamThread-1] DEBUG o.a.k.clients.consumer.KafkaConsumer - Subscribed to pattern: StreamConfig2 14:28:46.811 [GlobalStreamThread] DEBUG o.a.k.c.consumer.internals.Fetcher - Sending fetch for partitions [StreamConfig2-0] to broker 10.20.69.86:9092 (id: 0 rack: null) 14:28:46.812 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending GroupCoordinator request for group map-function-scala-example to broker localhost:9092 (id: -1 rack: null) 14:28:46.812 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:46.812 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:46.813 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:46.813 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:46.813 [StreamThread-1] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:46.814 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:46.814 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] Started Kafka Stream process 14:28:46.814 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:46.817 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:46.818 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Sending metadata request (type=MetadataRequest, topics=) to node -1 14:28:46.824 [StreamThread-1] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 2 to Cluster(id = _Epo8QiSSuGbI1zi8iEXLA, nodes = [10.20.69.86:9092 (id: 0 rack: null)], partitions = [Partition(topic = StreamConfig2, partition = 0, leader = 0, replicas = [0], isr = [0])]) 14:28:46.830 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1500326926829, latencyMs=17, disconnected=false, requestHeader={api_key=10,api_version=0,correlation_id=0,client_id=map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer}, responseBody={error_code=0,coordinator={node_id=0,host=10.20.69.86,port=9092}}) for group map-function-scala-example 14:28:46.830 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) for group map-function-scala-example. 14:28:46.830 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node 2147483647 at 10.20.69.86:9092. 14:28:46.833 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Heartbeat thread for group map-function-scala-example started 14:28:46.833 [StreamThread-1] INFO o.a.k.c.c.i.ConsumerCoordinator - Revoking previously assigned partitions [] for group map-function-scala-example 14:28:46.833 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] at state RUNNING: partitions [] revoked at the beginning of consumer rebalance. 14:28:46.833 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] State transition from RUNNING to PARTITIONS_REVOKED. 14:28:46.833 [StreamThread-1] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] State transition from RUNNING to REBALANCING. 14:28:46.833 [StreamThread-1] DEBUG o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] suspendTasksAndState: suspending all active tasks [] and standby tasks [] 14:28:46.837 [StreamThread-1] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions Looking at config 14:28:46.838 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Updating suspended tasks to contain active tasks [] 14:28:46.838 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all active tasks [] 14:28:46.838 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all standby tasks [] 14:28:46.838 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group map-function-scala-example iterator created HAS NEXT source-topic sink-topic 14:28:46.848 [StreamThread-1] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] found [StreamConfig2] topics possibly matching regex 14:28:46.848 [StreamThread-1] DEBUG o.a.k.s.processor.TopologyBuilder - stream-thread [StreamThread-1] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[StreamConfig2]} topic(s) with possible matching regex subscription(s) 14:28:46.852 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending JoinGroup ((type: JoinGroupRequest, groupId=map-function-scala-example, sessionTimeout=10000, rebalanceTimeout=2147483647, memberId=, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@51b1300d)) to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:28:46.852 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.bytes-sent CREATING source-topic sink-topic 14:28:46.853 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.bytes-received 14:28:46.853 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.latency 14:28:46.853 [StreamThread-1] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node 2147483647 14:28:46.853 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node 2147483647. Fetching API versions. 14:28:46.853 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node 2147483647. 14:28:46.855 [StreamThread-1] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node 2147483647: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:46.870 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful JoinGroup response for group map-function-scala-example: {error_code=0,generation_id=31,group_protocol=stream,leader_id=map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer-34336ba2-46de-498a-b55d-262b15e08020,member_id=map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer-34336ba2-46de-498a-b55d-262b15e08020,members=[{member_id=map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer-34336ba2-46de-498a-b55d-262b15e08020,member_metadata=java.nio.HeapByteBuffer[pos=0 lim=65 cap=65]}]} 14:28:46.872 [StreamThread-1] DEBUG o.a.k.c.c.i.ConsumerCoordinator - Performing assignment for group map-function-scala-example using strategy stream with subscriptions {map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer-34336ba2-46de-498a-b55d-262b15e08020=Subscription(topics=[StreamConfig2])} 14:28:46.872 [main] INFO o.apache.kafka.streams.StreamsConfig - StreamsConfig values: application.id = map-function-scala-example application.server = bootstrap.servers = [localhost:9092] buffered.records.per.partition = 1000 cache.max.bytes.buffering = 10485760 client.id = commit.interval.ms = 30000 connections.max.idle.ms = 540000 key.serde = class org.apache.kafka.common.serialization.Serdes$ByteArraySerde 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 partition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper poll.ms = 100 receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 replication.factor = 1 request.timeout.ms = 40000 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 timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp value.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde windowstore.changelog.additional.retention.ms = 86400000 zookeeper.connect = 14:28:46.872 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2.commit-latency 14:28:46.873 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2.poll-latency 14:28:46.873 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2.process-latency 14:28:46.873 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Constructed client metadata {f215d043-5170-41a5-8bf1-99d7c5873191=ClientMetadata{hostInfo=null, consumers=[map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer-34336ba2-46de-498a-b55d-262b15e08020], state=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0]}} from the member subscriptions. 14:28:46.873 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2.punctuate-latency 14:28:46.873 [StreamThread-1] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Starting to validate internal topics in partition assignor. 14:28:46.873 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor 14:28:46.873 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2.task-created 14:28:46.873 [StreamThread-1] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Created repartition topics [] from the parsed topology. 14:28:46.873 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2.task-closed 14:28:46.873 [StreamThread-1] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Starting to validate internal topics in partition assignor. 14:28:46.874 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2.skipped-records 14:28:46.874 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor 14:28:46.874 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] Creating producer client 14:28:46.874 [StreamThread-1] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Created state changelog topics {} from the parsed topology. 14:28:46.874 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig values: acks = 1 batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.id = map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-producer compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null 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.fetch.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 10 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS timeout.ms = 30000 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer 14:28:46.874 [StreamThread-1] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Assigning tasks [] to clients {f215d043-5170-41a5-8bf1-99d7c5873191=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0]} with number of replicas 0 14:28:46.875 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 14:28:46.875 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 14:28:46.876 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.876 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.876 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.876 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.876 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.877 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.877 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.877 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.877 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name batch-size 14:28:46.877 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name compression-rate 14:28:46.877 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name queue-time 14:28:46.877 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name request-time 14:28:46.877 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 14:28:46.878 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-per-request 14:28:46.878 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-retries 14:28:46.878 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name errors 14:28:46.878 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-size-max 14:28:46.878 [kafka-producer-network-thread | map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-producer] DEBUG o.a.k.c.producer.internals.Sender - Starting Kafka producer I/O thread. 14:28:46.879 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:46.879 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:46.879 [main] DEBUG o.a.k.clients.producer.KafkaProducer - Kafka producer started 14:28:46.879 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] Creating consumer client 14:28:46.879 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Assigned tasks to clients as {f215d043-5170-41a5-8bf1-99d7c5873191=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0]}. 14:28:46.879 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = map-function-scala-example heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 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.StreamPartitionAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:46.880 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:46.880 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.880 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.881 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.881 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.881 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.881 [StreamThread-1] WARN o.a.k.c.c.i.ConsumerCoordinator - The following subscribed topics are not assigned to any members in the group map-function-scala-example : [StreamConfig2] 14:28:46.881 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.881 [StreamThread-1] DEBUG o.a.k.c.c.i.ConsumerCoordinator - Finished assignment for group map-function-scala-example: {map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer-34336ba2-46de-498a-b55d-262b15e08020=Assignment(partitions=[])} 14:28:46.882 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.882 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending leader SyncGroup for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null): (type=SyncGroupRequest, groupId=map-function-scala-example, generationId=31, memberId=map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer-34336ba2-46de-498a-b55d-262b15e08020, groupAssignment=map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-consumer-34336ba2-46de-498a-b55d-262b15e08020) 14:28:46.882 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.882 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.883 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.883 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.883 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.883 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.883 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.883 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.883 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.884 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:46.884 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:46.884 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:46.884 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:46.884 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:46.885 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:46.885 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:46.885 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:46.885 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:46.885 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:46.885 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:46.886 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:46.886 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] Creating restore consumer client 14:28:46.886 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-restore-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:46.886 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:46.887 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.887 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.887 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.887 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.887 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.887 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.887 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.888 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.888 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:46.888 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:46.888 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:46.889 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:46.889 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:46.889 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:46.889 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:46.889 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:46.889 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:46.890 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:46.890 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:46.890 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:46.890 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] State transition from NOT_RUNNING to RUNNING. 14:28:46.890 [main] DEBUG o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54] Starting Kafka Stream process. 14:28:46.890 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.891 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:46.891 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:46.891 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:46.891 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:46.891 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:46.891 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:46.891 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:46.892 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:46.892 [main] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:46.908 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:46.908 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:46.908 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:46.909 [main] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 326640, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:46.909 [main] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:46.909 [main] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:46.914 [main] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:46.924 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Successfully joined group map-function-scala-example with generation 31 14:28:46.926 [StreamThread-1] INFO o.a.k.c.c.i.ConsumerCoordinator - Setting newly assigned partitions [] for group map-function-scala-example 14:28:46.926 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] at state PARTITIONS_REVOKED: new partitions [] assigned at the end of consumer rebalance. 14:28:46.926 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. 14:28:46.926 [StreamThread-1] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] State transition from REBALANCING to REBALANCING. 14:28:46.927 [StreamThread-1] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:46.927 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] State transition from ASSIGNING_PARTITIONS to RUNNING. 14:28:46.927 [StreamThread-1] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] State transition from REBALANCING to RUNNING. 14:28:47.019 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:47.019 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:47.019 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:47.019 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:47.019 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:47.019 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:47.019 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:47.019 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-sent 14:28:47.020 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-received 14:28:47.020 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.latency 14:28:47.020 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54] State transition from CREATED to RUNNING. 14:28:47.020 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54] Started Kafka Stream process Starting stream... 14:28:47.020 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] Starting HAS NEXT source-topic2 sink-topic2 CREATING source-topic2 sink-topic2 14:28:47.020 [StreamThread-2] DEBUG o.a.k.clients.consumer.KafkaConsumer - Subscribed to pattern: source-topic 14:28:47.020 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending GroupCoordinator request for group map-function-scala-example to broker localhost:9092 (id: -1 rack: null) 14:28:47.021 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:47.021 [StreamThread-2] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:47.022 [main] INFO o.apache.kafka.streams.StreamsConfig - StreamsConfig values: application.id = map-function-scala-example application.server = bootstrap.servers = [localhost:9092] buffered.records.per.partition = 1000 cache.max.bytes.buffering = 10485760 client.id = commit.interval.ms = 30000 connections.max.idle.ms = 540000 key.serde = class org.apache.kafka.common.serialization.Serdes$ByteArraySerde 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 partition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper poll.ms = 100 receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 replication.factor = 1 request.timeout.ms = 40000 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 timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp value.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde windowstore.changelog.additional.retention.ms = 86400000 zookeeper.connect = 14:28:47.022 [StreamThread-2] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:47.022 [StreamThread-2] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:47.022 [StreamThread-2] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:47.022 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3.commit-latency 14:28:47.022 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:47.022 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:47.023 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3.poll-latency 14:28:47.023 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3.process-latency 14:28:47.027 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3.punctuate-latency 14:28:47.028 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3.task-created 14:28:47.028 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3.task-closed 14:28:47.028 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3.skipped-records 14:28:47.029 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] Creating producer client 14:28:47.034 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig values: acks = 1 batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.id = map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-producer compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null 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.fetch.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 10 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS timeout.ms = 30000 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer 14:28:47.034 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 14:28:47.034 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 14:28:47.036 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.037 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.037 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.037 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.037 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.037 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.038 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.038 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.041 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name batch-size 14:28:47.041 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name compression-rate 14:28:47.041 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name queue-time 14:28:47.041 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name request-time 14:28:47.041 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 14:28:47.044 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:47.041 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-per-request 14:28:47.044 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Sending metadata request (type=MetadataRequest, topics=) to node -1 14:28:47.044 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-retries 14:28:47.044 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name errors 14:28:47.044 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-size-max 14:28:47.045 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:47.045 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:47.045 [kafka-producer-network-thread | map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-producer] DEBUG o.a.k.c.producer.internals.Sender - Starting Kafka producer I/O thread. 14:28:47.045 [main] DEBUG o.a.k.clients.producer.KafkaProducer - Kafka producer started 14:28:47.046 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] Creating consumer client 14:28:47.046 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = map-function-scala-example heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 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.StreamPartitionAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:47.046 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:47.047 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.047 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.048 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.048 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.048 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.049 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.049 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.050 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.050 [StreamThread-2] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 2 to Cluster(id = _Epo8QiSSuGbI1zi8iEXLA, nodes = [10.20.69.86:9092 (id: 0 rack: null)], partitions = []) 14:28:47.050 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.051 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.051 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1500326927050, latencyMs=29, disconnected=false, requestHeader={api_key=10,api_version=0,correlation_id=0,client_id=map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer}, responseBody={error_code=0,coordinator={node_id=0,host=10.20.69.86,port=9092}}) for group map-function-scala-example 14:28:47.051 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.051 [StreamThread-2] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) for group map-function-scala-example. 14:28:47.051 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node 2147483647 at 10.20.69.86:9092. 14:28:47.051 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.051 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.052 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.052 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.052 [StreamThread-2] INFO o.a.k.c.c.i.ConsumerCoordinator - Revoking previously assigned partitions [] for group map-function-scala-example 14:28:47.052 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.052 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] at state RUNNING: partitions [] revoked at the beginning of consumer rebalance. 14:28:47.052 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Heartbeat thread for group map-function-scala-example started 14:28:47.053 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:47.053 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] State transition from RUNNING to PARTITIONS_REVOKED. 14:28:47.054 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:47.054 [StreamThread-2] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54] State transition from RUNNING to REBALANCING. 14:28:47.054 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:47.054 [StreamThread-2] DEBUG o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] suspendTasksAndState: suspending all active tasks [] and standby tasks [] 14:28:47.055 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:47.055 [StreamThread-2] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:47.055 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:47.055 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] Updating suspended tasks to contain active tasks [] 14:28:47.055 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:47.056 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] Removing all active tasks [] 14:28:47.056 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:47.056 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] Removing all standby tasks [] 14:28:47.056 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:47.056 [StreamThread-2] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group map-function-scala-example 14:28:47.056 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:47.057 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:47.057 [StreamThread-2] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-2] found [] topics possibly matching regex 14:28:47.057 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:47.057 [StreamThread-2] DEBUG o.a.k.s.processor.TopologyBuilder - stream-thread [StreamThread-2] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[]} topic(s) with possible matching regex subscription(s) 14:28:47.057 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:47.058 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] Creating restore consumer client 14:28:47.058 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending JoinGroup ((type: JoinGroupRequest, groupId=map-function-scala-example, sessionTimeout=10000, rebalanceTimeout=2147483647, memberId=, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@30009b20)) to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:28:47.058 [StreamThread-2] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.bytes-sent 14:28:47.058 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-restore-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:47.058 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:47.058 [StreamThread-2] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.bytes-received 14:28:47.058 [StreamThread-2] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.latency 14:28:47.058 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.058 [StreamThread-2] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node 2147483647 14:28:47.059 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node 2147483647. Fetching API versions. 14:28:47.059 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node 2147483647. 14:28:47.059 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.059 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.059 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.059 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.060 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.060 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.060 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.060 [StreamThread-2] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node 2147483647: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:47.060 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:47.060 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:47.060 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:47.061 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:47.061 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:47.061 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:47.061 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:47.062 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:47.062 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:47.062 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:47.062 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:47.062 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:47.062 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] State transition from NOT_RUNNING to RUNNING. 14:28:47.062 [main] DEBUG o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb] Starting Kafka Stream process. 14:28:47.063 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.063 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.063 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.064 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.064 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.064 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.064 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.065 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.065 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.065 [main] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:47.065 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:47.066 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:47.066 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:47.066 [main] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 326640, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:47.066 [main] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:47.066 [main] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:47.068 [main] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:47.172 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:47.173 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:47.173 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:47.173 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:47.173 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:47.173 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:47.173 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:47.173 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-sent 14:28:47.174 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-received 14:28:47.174 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.latency 14:28:47.174 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb] State transition from CREATED to RUNNING. 14:28:47.174 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb] Started Kafka Stream process Starting stream... 14:28:47.174 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] Starting 14:28:47.174 [StreamThread-3] DEBUG o.a.k.clients.consumer.KafkaConsumer - Subscribed to pattern: source-topic2 HAS NEXT test-name json-config 14:28:47.174 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending GroupCoordinator request for group map-function-scala-example to broker localhost:9092 (id: -1 rack: null) CREATING test-name json-config 14:28:47.174 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:47.175 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:47.175 [main] INFO o.apache.kafka.streams.StreamsConfig - StreamsConfig values: application.id = map-function-scala-example application.server = bootstrap.servers = [localhost:9092] buffered.records.per.partition = 1000 cache.max.bytes.buffering = 10485760 client.id = commit.interval.ms = 30000 connections.max.idle.ms = 540000 key.serde = class org.apache.kafka.common.serialization.Serdes$ByteArraySerde 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 partition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper poll.ms = 100 receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 replication.factor = 1 request.timeout.ms = 40000 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 timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp value.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde windowstore.changelog.additional.retention.ms = 86400000 zookeeper.connect = 14:28:47.175 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:47.175 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:47.175 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4.commit-latency 14:28:47.176 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4.poll-latency 14:28:47.176 [StreamThread-3] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:47.176 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:47.176 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4.process-latency 14:28:47.176 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:47.176 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4.punctuate-latency 14:28:47.176 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4.task-created 14:28:47.176 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4.task-closed 14:28:47.177 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name thread.map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4.skipped-records 14:28:47.177 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] Creating producer client 14:28:47.177 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig values: acks = 1 batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [localhost:9092] buffer.memory = 33554432 client.id = map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-producer compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null 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.fetch.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 10 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS timeout.ms = 30000 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer 14:28:47.177 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:47.178 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Sending metadata request (type=MetadataRequest, topics=) to node -1 14:28:47.178 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 14:28:47.178 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 14:28:47.178 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.178 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.178 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.179 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.179 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.179 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.179 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.179 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.179 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name batch-size 14:28:47.179 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name compression-rate 14:28:47.180 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name queue-time 14:28:47.180 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name request-time 14:28:47.180 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 14:28:47.180 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-per-request 14:28:47.180 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-retries 14:28:47.180 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name errors 14:28:47.180 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-size-max 14:28:47.182 [StreamThread-3] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 2 to Cluster(id = _Epo8QiSSuGbI1zi8iEXLA, nodes = [10.20.69.86:9092 (id: 0 rack: null)], partitions = []) 14:28:47.183 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1500326927183, latencyMs=9, disconnected=false, requestHeader={api_key=10,api_version=0,correlation_id=0,client_id=map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer}, responseBody={error_code=0,coordinator={node_id=0,host=10.20.69.86,port=9092}}) for group map-function-scala-example 14:28:47.183 [StreamThread-3] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) for group map-function-scala-example. 14:28:47.183 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node 2147483647 at 10.20.69.86:9092. 14:28:47.183 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:47.184 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:47.184 [main] DEBUG o.a.k.clients.producer.KafkaProducer - Kafka producer started 14:28:47.184 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] Creating consumer client 14:28:47.184 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = map-function-scala-example heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 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.StreamPartitionAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:47.184 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:47.185 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.185 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.185 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.185 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.185 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.186 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.186 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.186 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.186 [kafka-producer-network-thread | map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-producer] DEBUG o.a.k.c.producer.internals.Sender - Starting Kafka producer I/O thread. 14:28:47.186 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.187 [StreamThread-3] INFO o.a.k.c.c.i.ConsumerCoordinator - Revoking previously assigned partitions [] for group map-function-scala-example 14:28:47.187 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Heartbeat thread for group map-function-scala-example started 14:28:47.187 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] at state RUNNING: partitions [] revoked at the beginning of consumer rebalance. 14:28:47.187 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.187 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] State transition from RUNNING to PARTITIONS_REVOKED. 14:28:47.187 [StreamThread-3] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb] State transition from RUNNING to REBALANCING. 14:28:47.187 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.187 [StreamThread-3] DEBUG o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] suspendTasksAndState: suspending all active tasks [] and standby tasks [] 14:28:47.187 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.187 [StreamThread-3] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:47.187 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.187 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] Updating suspended tasks to contain active tasks [] 14:28:47.187 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] Removing all active tasks [] 14:28:47.188 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] Removing all standby tasks [] 14:28:47.188 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.188 [StreamThread-3] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group map-function-scala-example 14:28:47.188 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.188 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.188 [StreamThread-3] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] found [] topics possibly matching regex 14:28:47.188 [StreamThread-3] DEBUG o.a.k.s.processor.TopologyBuilder - stream-thread [StreamThread-3] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[]} topic(s) with possible matching regex subscription(s) 14:28:47.188 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:47.188 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending JoinGroup ((type: JoinGroupRequest, groupId=map-function-scala-example, sessionTimeout=10000, rebalanceTimeout=2147483647, memberId=, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@27f95d9d)) to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:28:47.188 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:47.188 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.bytes-sent 14:28:47.188 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:47.189 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:47.189 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.bytes-received 14:28:47.189 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.latency 14:28:47.189 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:47.189 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:47.189 [StreamThread-3] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node 2147483647 14:28:47.189 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:47.189 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node 2147483647. Fetching API versions. 14:28:47.189 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node 2147483647. 14:28:47.189 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:47.189 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:47.190 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:47.190 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:47.190 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:47.190 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] Creating restore consumer client 14:28:47.190 [main] INFO o.a.k.c.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [localhost:9092] check.crcs = true client.id = map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-restore-consumer connections.max.idle.ms = 540000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = heartbeat.interval.ms = 3000 interceptor.classes = null internal.leave.group.on.close = false key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 2147483647 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 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.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 14:28:47.190 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Starting the Kafka consumer 14:28:47.191 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.191 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.191 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.191 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.191 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.191 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.192 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.192 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node 2147483647: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:47.192 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.192 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 14:28:47.193 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name join-latency 14:28:47.193 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name sync-latency 14:28:47.193 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name commit-latency 14:28:47.193 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 14:28:47.194 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-fetched 14:28:47.194 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 14:28:47.194 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-lag 14:28:47.194 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 14:28:47.194 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.1-cp2 14:28:47.194 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 5092731dfc53f849 14:28:47.194 [main] DEBUG o.a.k.clients.consumer.KafkaConsumer - Kafka consumer created 14:28:47.194 [main] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] State transition from NOT_RUNNING to RUNNING. 14:28:47.194 [main] DEBUG o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76] Starting Kafka Stream process. 14:28:47.195 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.195 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 14:28:47.195 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 14:28:47.195 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 14:28:47.195 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 14:28:47.196 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 14:28:47.196 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 14:28:47.196 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 14:28:47.196 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 14:28:47.196 [main] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:47.197 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:47.197 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:47.197 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:47.198 [main] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 326640, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:47.198 [main] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:47.198 [main] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:47.199 [main] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-sent 14:28:47.306 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-received 14:28:47.307 [main] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.latency 14:28:47.307 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76] State transition from CREATED to RUNNING. 14:28:47.307 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76] Started Kafka Stream process Starting stream... 14:28:47.307 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] Starting 14:28:47.307 [StreamThread-4] DEBUG o.a.k.clients.consumer.KafkaConsumer - Subscribed to pattern: test-name 14:28:47.307 [main] DEBUG o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] Stopping Kafka Stream process. 14:28:47.307 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] State transition from RUNNING to PENDING_SHUTDOWN. 14:28:47.307 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending GroupCoordinator request for group map-function-scala-example to broker localhost:9092 (id: -1 rack: null) 14:28:47.307 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at localhost:9092. 14:28:47.308 [StreamThread-4] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 14:28:47.308 [StreamThread-4] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 14:28:47.308 [StreamThread-4] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 14:28:47.309 [StreamThread-4] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1 14:28:47.309 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node -1. Fetching API versions. 14:28:47.309 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node -1. 14:28:47.309 [kafka-streams-close-thread] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Informed thread to shut down 14:28:47.309 [kafka-streams-close-thread] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN. 14:28:47.310 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:47.311 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Sending metadata request (type=MetadataRequest, topics=) to node -1 14:28:47.314 [StreamThread-4] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 2 to Cluster(id = _Epo8QiSSuGbI1zi8iEXLA, nodes = [10.20.69.86:9092 (id: 0 rack: null)], partitions = [Partition(topic = test-name, partition = 0, leader = 0, replicas = [0], isr = [0])]) 14:28:47.315 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1500326927315, latencyMs=8, disconnected=false, requestHeader={api_key=10,api_version=0,correlation_id=0,client_id=map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer}, responseBody={error_code=0,coordinator={node_id=0,host=10.20.69.86,port=9092}}) for group map-function-scala-example 14:28:47.315 [StreamThread-4] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) for group map-function-scala-example. 14:28:47.316 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node 2147483647 at 10.20.69.86:9092. 14:28:47.316 [StreamThread-4] INFO o.a.k.c.c.i.ConsumerCoordinator - Revoking previously assigned partitions [] for group map-function-scala-example 14:28:47.316 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] at state RUNNING: partitions [] revoked at the beginning of consumer rebalance. 14:28:47.317 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] State transition from RUNNING to PARTITIONS_REVOKED. 14:28:47.317 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Heartbeat thread for group map-function-scala-example started 14:28:47.317 [StreamThread-4] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76] State transition from RUNNING to REBALANCING. 14:28:47.317 [StreamThread-4] DEBUG o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] suspendTasksAndState: suspending all active tasks [] and standby tasks [] 14:28:47.317 [StreamThread-4] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:47.317 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] Updating suspended tasks to contain active tasks [] 14:28:47.317 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] Removing all active tasks [] 14:28:47.317 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] Removing all standby tasks [] 14:28:47.317 [StreamThread-4] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group map-function-scala-example 14:28:47.318 [StreamThread-4] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-4] found [test-name] topics possibly matching regex 14:28:47.318 [StreamThread-4] DEBUG o.a.k.s.processor.TopologyBuilder - stream-thread [StreamThread-4] updating builder with SubscriptionUpdates{updatedTopicSubscriptions=[test-name]} topic(s) with possible matching regex subscription(s) 14:28:47.318 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending JoinGroup ((type: JoinGroupRequest, groupId=map-function-scala-example, sessionTimeout=10000, rebalanceTimeout=2147483647, memberId=, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@69a5ef25)) to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:28:47.318 [StreamThread-4] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.bytes-sent 14:28:47.319 [StreamThread-4] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.bytes-received 14:28:47.319 [StreamThread-4] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-2147483647.latency 14:28:47.319 [StreamThread-4] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node 2147483647 14:28:47.319 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node 2147483647. Fetching API versions. 14:28:47.319 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node 2147483647. 14:28:47.322 [StreamThread-4] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node 2147483647: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:47.355 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Shutting down at user request 14:28:47.355 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Shutting down 14:28:47.355 [StreamThread-1] DEBUG o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] shutdownTasksAndState: shutting downactive tasks [], standby tasks [], suspended tasks [], and suspended standby tasks [] 14:28:47.357 [StreamThread-1] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:47.357 [StreamThread-1] INFO o.a.k.clients.producer.KafkaProducer - Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. 14:28:47.358 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.k.c.producer.internals.Sender - Beginning shutdown of Kafka producer I/O thread, sending remaining records. 14:28:47.358 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:47.358 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:47.358 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:47.358 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:47.359 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:47.359 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:47.359 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:47.359 [kafka-producer-network-thread | map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1-producer] DEBUG o.a.k.c.producer.internals.Sender - Shutdown of Kafka producer I/O thread has completed. 14:28:47.359 [StreamThread-1] DEBUG o.a.k.clients.producer.KafkaProducer - The Kafka producer has closed. 14:28:47.359 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Heartbeat thread for group map-function-scala-example has closed 14:28:47.360 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:47.360 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:47.360 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:47.360 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-sent 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-received 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.latency 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node-2147483647.bytes-sent 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node-2147483647.bytes-received 14:28:47.361 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node-2147483647.latency 14:28:47.361 [StreamThread-1] DEBUG o.a.k.clients.consumer.KafkaConsumer - The Kafka consumer has closed. 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:47.362 [StreamThread-1] DEBUG o.a.k.clients.consumer.KafkaConsumer - The Kafka consumer has closed. 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:47.362 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:47.363 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:47.363 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:47.363 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:47.363 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:47.363 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all active tasks [] 14:28:47.363 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all standby tasks [] 14:28:47.363 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Stream thread shutdown complete 14:28:47.363 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] State transition from PENDING_SHUTDOWN to NOT_RUNNING. 14:28:47.363 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.commit-latency 14:28:47.363 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.poll-latency 14:28:47.363 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.process-latency 14:28:47.363 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.punctuate-latency 14:28:47.364 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.task-created 14:28:47.364 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.task-closed 14:28:47.364 [StreamThread-1] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name thread.map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-StreamThread-1.skipped-records 14:28:47.365 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name topic.StreamConfig2.bytes-fetched 14:28:47.365 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name topic.StreamConfig2.records-fetched 14:28:47.366 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name StreamConfig2-0.records-lag 14:28:47.366 [GlobalStreamThread] DEBUG o.a.k.c.consumer.internals.Fetcher - Sending fetch for partitions [StreamConfig2-0] to broker 10.20.69.86:9092 (id: 0 rack: null) 14:28:47.378 [GlobalStreamThread] DEBUG o.a.k.s.p.i.GlobalStreamThread - Shutting down GlobalStreamThread at user request 14:28:47.379 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-closed: 14:28:47.380 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name connections-created: 14:28:47.380 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent-received: 14:28:47.380 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-sent: 14:28:47.380 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name bytes-received: 14:28:47.380 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name select-time: 14:28:47.380 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name io-time: 14:28:47.380 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-sent 14:28:47.380 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.bytes-received 14:28:47.381 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node--1.latency 14:28:47.381 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node-0.bytes-sent 14:28:47.381 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node-0.bytes-received 14:28:47.381 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name node-0.latency 14:28:47.381 [GlobalStreamThread] DEBUG o.a.k.clients.consumer.KafkaConsumer - The Kafka consumer has closed. 14:28:47.381 [GlobalStreamThread] DEBUG o.a.k.s.p.i.GlobalStateManagerImpl - Closing global storage engine test-store 14:28:47.381 [GlobalStreamThread] DEBUG o.a.k.s.state.internals.ThreadCache - Thread map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191-GlobalStreamThread cache stats on flush: #puts=0, #gets=0, #evicts=0, #flushes=1 14:28:47.383 [GlobalStreamThread] DEBUG o.a.kafka.common.metrics.Metrics - Removed sensor with name -1_-1-test-store-hitRatio 14:28:47.387 [kafka-streams-close-thread] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] Stopped Kafka Streams process. 14:28:47.388 [main] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-f215d043-5170-41a5-8bf1-99d7c5873191] State transition from PENDING_SHUTDOWN to NOT_RUNNING. 14:28:49.545 [kafka-streams-test-service-akka.actor.default-dispatcher-3] INFO init - Admin interface listening on /0:0:0:0:0:0:0:0:8001 14:28:49.591 [kafka-streams-test-service-akka.actor.default-dispatcher-3] INFO init - Server binding successful! Starting up. 14:28:49.591 [kafka-streams-test-service-akka.actor.default-dispatcher-3] INFO init - Listening on /0:0:0:0:0:0:0:0:8000 14:28:56.931 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful JoinGroup response for group map-function-scala-example: {error_code=0,generation_id=32,group_protocol=stream,leader_id=map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c,member_id=map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c,members=[{member_id=map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c,member_metadata=java.nio.HeapByteBuffer[pos=0 lim=50 cap=421]},{member_id=map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer-06157563-8f80-49ed-b29f-73f877782dc6,member_metadata=java.nio.HeapByteBuffer[pos=0 lim=50 cap=241]},{member_id=map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer-9b2b7efc-e084-4b77-a942-689efd1ab1f4,member_metadata=java.nio.HeapByteBuffer[pos=0 lim=61 cap=61]}]} 14:28:56.932 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Initialize connection to node 0 for sending metadata request 14:28:56.932 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Initiating connection to node 0 at 10.20.69.86:9092. 14:28:56.932 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful JoinGroup response for group map-function-scala-example: {error_code=0,generation_id=32,group_protocol=stream,leader_id=map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c,member_id=map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer-9b2b7efc-e084-4b77-a942-689efd1ab1f4,members=[]} 14:28:56.932 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful JoinGroup response for group map-function-scala-example: {error_code=0,generation_id=32,group_protocol=stream,leader_id=map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c,member_id=map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer-06157563-8f80-49ed-b29f-73f877782dc6,members=[]} 14:28:56.932 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending follower SyncGroup for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null): (type=SyncGroupRequest, groupId=map-function-scala-example, generationId=32, memberId=map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer-9b2b7efc-e084-4b77-a942-689efd1ab1f4, groupAssignment=) 14:28:56.932 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending follower SyncGroup for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null): (type=SyncGroupRequest, groupId=map-function-scala-example, generationId=32, memberId=map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer-06157563-8f80-49ed-b29f-73f877782dc6, groupAssignment=) 14:28:56.934 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-0.bytes-sent 14:28:56.935 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-0.bytes-received 14:28:56.936 [StreamThread-3] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-0.latency 14:28:56.936 [StreamThread-3] DEBUG o.a.kafka.common.network.Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node 0 14:28:56.936 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Completed connection to node 0. Fetching API versions. 14:28:56.936 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Initiating API versions fetch from node 0. 14:28:56.938 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Recorded API versions for node 0: (Produce(0): 0 to 2 [usable: 2], Fetch(1): 0 to 3 [usable: 3], Offsets(2): 0 to 1 [usable: 1], Metadata(3): 0 to 2 [usable: 2], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 2 [usable: 2], OffsetFetch(9): 0 to 2 [usable: 2], GroupCoordinator(10): 0 [usable: 0], JoinGroup(11): 0 to 1 [usable: 1], Heartbeat(12): 0 [usable: 0], LeaveGroup(13): 0 [usable: 0], SyncGroup(14): 0 [usable: 0], DescribeGroups(15): 0 [usable: 0], ListGroups(16): 0 [usable: 0], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 [usable: 0], CreateTopics(19): 0 to 1 [usable: 1], DeleteTopics(20): 0 [usable: 0]) 14:28:56.939 [StreamThread-3] DEBUG o.apache.kafka.clients.NetworkClient - Sending metadata request (type=MetadataRequest, topics=) to node 0 14:28:56.944 [StreamThread-3] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 3 to Cluster(id = _Epo8QiSSuGbI1zi8iEXLA, nodes = [10.20.69.86:9092 (id: 0 rack: null)], partitions = [Partition(topic = test-name, partition = 0, leader = 0, replicas = [0], isr = [0])]) 14:28:56.944 [StreamThread-3] DEBUG o.a.k.c.c.i.ConsumerCoordinator - Performing assignment for group map-function-scala-example using strategy stream with subscriptions {map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer-9b2b7efc-e084-4b77-a942-689efd1ab1f4=Subscription(topics=[test-name]), map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c=Subscription(topics=[]), map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer-06157563-8f80-49ed-b29f-73f877782dc6=Subscription(topics=[])} 14:28:56.944 [StreamThread-3] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Constructed client metadata {4694886d-66a8-4f8b-9c31-0447e77b2e76=ClientMetadata{hostInfo=null, consumers=[map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer-9b2b7efc-e084-4b77-a942-689efd1ab1f4], state=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0]}, 72622e43-3a62-476d-8232-915f15356b54=ClientMetadata{hostInfo=null, consumers=[map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer-06157563-8f80-49ed-b29f-73f877782dc6], state=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0]}, 1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb=ClientMetadata{hostInfo=null, consumers=[map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c], state=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0]}} from the member subscriptions. 14:28:56.945 [StreamThread-3] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Starting to validate internal topics in partition assignor. 14:28:56.945 [StreamThread-3] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Completed validating internal topics in partition assignor 14:28:56.945 [StreamThread-3] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Created repartition topics [] from the parsed topology. 14:28:56.945 [StreamThread-3] INFO o.a.k.s.p.DefaultPartitionGrouper - Skipping assigning topic source-topic2 to tasks since its metadata is not available yet 14:28:56.945 [StreamThread-3] WARN o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] No partitions found for topic source-topic2 14:28:56.945 [StreamThread-3] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Starting to validate internal topics in partition assignor. 14:28:56.945 [StreamThread-3] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Completed validating internal topics in partition assignor 14:28:56.945 [StreamThread-3] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Created state changelog topics {} from the parsed topology. 14:28:56.945 [StreamThread-3] DEBUG o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Assigning tasks [] to clients {4694886d-66a8-4f8b-9c31-0447e77b2e76=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0], 72622e43-3a62-476d-8232-915f15356b54=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0], 1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0]} with number of replicas 0 14:28:56.945 [StreamThread-3] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-3] Assigned tasks to clients as {4694886d-66a8-4f8b-9c31-0447e77b2e76=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0], 72622e43-3a62-476d-8232-915f15356b54=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0], 1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0]) capacity: 1.0 cost: 0.0]}. 14:28:56.946 [StreamThread-3] WARN o.a.k.c.c.i.ConsumerCoordinator - The following subscribed topics are not assigned to any members in the group map-function-scala-example : [test-name] 14:28:56.946 [StreamThread-3] DEBUG o.a.k.c.c.i.ConsumerCoordinator - Finished assignment for group map-function-scala-example: {map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer-9b2b7efc-e084-4b77-a942-689efd1ab1f4=Assignment(partitions=[]), map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c=Assignment(partitions=[]), map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer-06157563-8f80-49ed-b29f-73f877782dc6=Assignment(partitions=[])} 14:28:56.946 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending leader SyncGroup for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null): (type=SyncGroupRequest, groupId=map-function-scala-example, generationId=32, memberId=map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c, groupAssignment=map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76-StreamThread-4-consumer-9b2b7efc-e084-4b77-a942-689efd1ab1f4,map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb-StreamThread-3-consumer-80aa1f3d-370f-4d3e-8353-e8d403f9ad3c,map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54-StreamThread-2-consumer-06157563-8f80-49ed-b29f-73f877782dc6) 14:28:56.949 [StreamThread-3] INFO o.a.k.c.c.i.AbstractCoordinator - Successfully joined group map-function-scala-example with generation 32 14:28:56.949 [StreamThread-3] INFO o.a.k.c.c.i.ConsumerCoordinator - Setting newly assigned partitions [] for group map-function-scala-example 14:28:56.949 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] at state PARTITIONS_REVOKED: new partitions [] assigned at the end of consumer rebalance. 14:28:56.949 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. 14:28:56.949 [StreamThread-3] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb] State transition from REBALANCING to REBALANCING. 14:28:56.949 [StreamThread-3] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:56.949 [StreamThread-3] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-3] State transition from ASSIGNING_PARTITIONS to RUNNING. 14:28:56.950 [StreamThread-3] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-1af7fd3f-aaef-4b8a-ac1b-904af3cfe4bb] State transition from REBALANCING to RUNNING. 14:28:56.950 [StreamThread-2] INFO o.a.k.c.c.i.AbstractCoordinator - Successfully joined group map-function-scala-example with generation 32 14:28:56.950 [StreamThread-2] INFO o.a.k.c.c.i.ConsumerCoordinator - Setting newly assigned partitions [] for group map-function-scala-example 14:28:56.950 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] at state PARTITIONS_REVOKED: new partitions [] assigned at the end of consumer rebalance. 14:28:56.950 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. 14:28:56.950 [StreamThread-2] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54] State transition from REBALANCING to REBALANCING. 14:28:56.951 [StreamThread-2] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:56.951 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] State transition from ASSIGNING_PARTITIONS to RUNNING. 14:28:56.951 [StreamThread-2] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-72622e43-3a62-476d-8232-915f15356b54] State transition from REBALANCING to RUNNING. 14:28:56.952 [StreamThread-4] INFO o.a.k.c.c.i.AbstractCoordinator - Successfully joined group map-function-scala-example with generation 32 14:28:56.952 [StreamThread-4] INFO o.a.k.c.c.i.ConsumerCoordinator - Setting newly assigned partitions [] for group map-function-scala-example 14:28:56.952 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] at state PARTITIONS_REVOKED: new partitions [] assigned at the end of consumer rebalance. 14:28:56.952 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] State transition from PARTITIONS_REVOKED to ASSIGNING_PARTITIONS. 14:28:56.952 [StreamThread-4] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76] State transition from REBALANCING to REBALANCING. 14:28:56.953 [StreamThread-4] DEBUG o.a.k.clients.consumer.KafkaConsumer - Unsubscribed all topics or patterns and assigned partitions 14:28:56.953 [StreamThread-4] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-4] State transition from ASSIGNING_PARTITIONS to RUNNING. 14:28:56.953 [StreamThread-4] INFO o.apache.kafka.streams.KafkaStreams - stream-client [map-function-scala-example-4694886d-66a8-4f8b-9c31-0447e77b2e76] State transition from REBALANCING to RUNNING. 14:28:59.950 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:28:59.959 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:00.047 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:00.048 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:00.050 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:00.050 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:03.035 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:03.038 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:03.128 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:03.130 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:03.135 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:03.137 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:06.134 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:06.135 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:06.139 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:06.140 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:06.207 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:06.210 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:09.137 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:09.138 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:09.142 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:09.142 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:09.294 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:09.295 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:12.191 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:12.193 [StreamThread-3] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:12.213 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:12.214 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example 14:29:12.398 [kafka-coordinator-heartbeat-thread | map-function-scala-example] DEBUG o.a.k.c.c.i.AbstractCoordinator - Sending Heartbeat request for group map-function-scala-example to coordinator 10.20.69.86:9092 (id: 2147483647 rack: null) 14:29:12.399 [StreamThread-4] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful Heartbeat response for group map-function-scala-example