D:\Java\jdk1.8.0_91\bin\java -Didea.launcher.port=7532 "-Didea.launcher.bin.path=D:\Program Files (x86)\JetBrains\IntelliJ IDEA 2016.2.2\bin" -Dfile.encoding=UTF-8 -classpath "D:\Java\jdk1.8.0_91\jre\lib\charsets.jar;D:\Java\jdk1.8.0_91\jre\lib\deploy.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\access-bridge-32.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\cldrdata.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\dnsns.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\jaccess.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\jfxrt.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\localedata.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\nashorn.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunec.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunjce_provider.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunmscapi.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunpkcs11.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\zipfs.jar;D:\Java\jdk1.8.0_91\jre\lib\javaws.jar;D:\Java\jdk1.8.0_91\jre\lib\jce.jar;D:\Java\jdk1.8.0_91\jre\lib\jfr.jar;D:\Java\jdk1.8.0_91\jre\lib\jfxswt.jar;D:\Java\jdk1.8.0_91\jre\lib\jsse.jar;D:\Java\jdk1.8.0_91\jre\lib\management-agent.jar;D:\Java\jdk1.8.0_91\jre\lib\plugin.jar;D:\Java\jdk1.8.0_91\jre\lib\resources.jar;D:\Java\jdk1.8.0_91\jre\lib\rt.jar;D:\Amplify\raakella\amplify\provisioning\dev\SubscriptionMock\build\classes\main;D:\Amplify\raakella\amplify\provisioning\dev\SubscriptionMock\build\resources\main;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-starter-stream-kafka\1.1.0.RELEASE\8b2c17bbd9615f51f94e0d2907ca4cbe5759031b\spring-cloud-starter-stream-kafka-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.avro\avro\1.8.1\f4e11d00055760dca33daab193192bd75cc87b59\avro-1.8.1.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.confluent\kafka-avro-serializer\3.0.0\64b35a995447495b9c2478f1d08f29539e97c0f1\kafka-avro-serializer-3.0.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\connect-json\0.10.1.0\9672086fc07f69412e706c3f89582cfc9124df69\connect-json-0.10.1.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\kafka-streams\0.10.1.0\184fe00a7afba26772c056ef4dc1fba4425cd8ef\kafka-streams-0.10.1.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\kafka-clients\0.10.1.0\1a351630175ce886ffe200a03dd3a56ec5ee93df\kafka-clients-0.10.1.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-stream-schema\1.1.0.RELEASE\265712f2fff054e29d3c003393cd4991518232dd\spring-cloud-stream-schema-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-stream-binder-kafka\1.1.0.RELEASE\c475b9bd671404f3930e175ec5a03d65843e4af5\spring-cloud-stream-binder-kafka-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.codehaus.jackson\jackson-core-asl\1.9.13\3c304d70f42f832e0a86d45bd437f692129299a4\jackson-core-asl-1.9.13.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.codehaus.jackson\jackson-mapper-asl\1.9.13\1ee2f2bed0e5dd29d1cb155a166e6f8d50bbddb7\jackson-mapper-asl-1.9.13.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.thoughtworks.paranamer\paranamer\2.7\3ed64c69e882a324a75e890024c32a28aff0ade8\paranamer-2.7.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.commons\commons-compress\1.8.1\a698750c16740fd5b3871425f4cb3bbaa87f529d\commons-compress-1.8.1.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.tukaani\xz\1.5\9c64274b7dbb65288237216e3fae7877fd3f2bee\xz-1.5.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.slf4j\slf4j-api\1.7.22\a1c83373863cec7ae8d89dc1c5722d8cb6ec0309\slf4j-api-1.7.22.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.confluent\kafka-schema-registry-client\3.0.0\e0d668b28e46597286818ede314f0a1483de7bd9\kafka-schema-registry-client-3.0.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.confluent\common-config\3.0.0\ba8110b6f413e630efe23c8a79e91ce546ecb490\common-config-3.0.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\connect-api\0.10.1.0\9ebbd005a61d0d88f98f1bfc369e0103e5f00672\connect-api-0.10.1.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.fasterxml.jackson.core\jackson-databind\2.8.5\b3035f37e674c04dafe36a660c3815cc59f764e2\jackson-databind-2.8.5.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.rocksdb\rocksdbjni\4.9.0\9be2d4f0639e3abddc5ab647240fdba8ef8f7bdb\rocksdbjni-4.9.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.101tec\zkclient\0.9\822482d08b9a0af9c43e8d1b6cb94e81ee3e361c\zkclient-0.9.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\log4j\log4j\1.2.17\5af35056b4d257e4b64b9e8069c0746e8b08629f\log4j-1.2.17.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\net.jpountz.lz4\lz4\1.3.0\c708bb2590c0652a642236ef45d9f99ff842a2ce\lz4-1.3.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-stream\1.1.0.RELEASE\1a6d3c740375a5124eae4c471884700f087e3263\spring-cloud-stream-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-stream-codec\1.1.0.RELEASE\892c915a6733ffde07de31dac5781751a08aee84\spring-cloud-stream-codec-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.integration\spring-integration-kafka\2.0.1.RELEASE\add065cb3b165fe3236810dbedb53b70a50a758a\spring-integration-kafka-2.0.1.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\kafka_2.11\0.9.0.1\6cc159e873fd6e5b43532faa4bf20a5929c03fc6\kafka_2.11-0.9.0.1.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.kafka\spring-kafka\1.0.4.RELEASE\c3ea4d3decba994541224cd9e2f720934a1f262b\spring-kafka-1.0.4.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.confluent\common-utils\3.0.0\7d1cda6028ce7befd7fec5fbe3d2622232d850f0\common-utils-3.0.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.fasterxml.jackson.core\jackson-annotations\2.8.5\9d82ff47bc2c2d3b5b6a6618fe636782bbcd5b07\jackson-annotations-2.8.5.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.fasterxml.jackson.core\jackson-core\2.8.5\60d059f5d2930ccd1ef03535b713fd9f933d1ba7\jackson-core-2.8.5.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.zookeeper\zookeeper\3.4.8\933ea2ed15e6a0e24b788973e3d128ff163c3136\zookeeper-3.4.8.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-actuator\1.4.3.RELEASE\79b4f3ebf23f86c2680cbd37a109272f4e782022\spring-boot-starter-actuator-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-web\1.4.3.RELEASE\a0dcc919eda8e8ecb6f13f52a30e6afbb8266103\spring-boot-starter-web-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-validation\1.4.3.RELEASE\6d8ee356222ed1e7195c8b9fa7588c51a6ad6216\spring-boot-starter-validation-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-messaging\4.3.5.RELEASE\480f1116f2060107493b91e72e21359b02aca776\spring-messaging-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.integration\spring-integration-core\4.3.6.RELEASE\39f1a7f39d6fdc6b7bcb17bd8706f4a298abff36\spring-integration-core-4.3.6.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.integration\spring-integration-jmx\4.3.6.RELEASE\4285b5a7e14bca4349a315fa692e956083b75822\spring-integration-jmx-4.3.6.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-tuple\1.0.0.RELEASE\5feaacebc66a885e9f2017063586df2300ce5c68\spring-tuple-1.0.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.integration\spring-integration-tuple\1.0.0.RELEASE\4ac09adb2ab6857604784b3e61ef02bcdc974928\spring-integration-tuple-1.0.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.retry\spring-retry\1.1.5.RELEASE\8669af2bbd289e8dc5ebe6fdf44da1da0ba19b2a\spring-retry-1.1.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.esotericsoftware\kryo-shaded\3.0.3\977d6b42d82de551fcf77dad84ef06c2839e3a74\kryo-shaded-3.0.3.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.yammer.metrics\metrics-core\2.2.0\f82c035cfa786d3cbec362c38c22a5f5b1bc8724\metrics-core-2.2.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.scala-lang.modules\scala-xml_2.11\1.0.4\b67c76af885ba3323ce51bbed4c9232f4bd5d8fd\scala-xml_2.11-1.0.4.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.scala-lang\scala-library\2.11.7\f75e7acabd57b213d6f61483240286c07213ec0e\scala-library-2.11.7.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.scala-lang.modules\scala-parser-combinators_2.11\1.0.4\7369d653bcfa95d321994660477a4d7e81d7f490\scala-parser-combinators_2.11-1.0.4.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\net.sf.jopt-simple\jopt-simple\3.2\d625f12ba08083c8c16dcedd5396ec730e9e77ab\jopt-simple-3.2.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter\1.4.3.RELEASE\c99bad104719e947b3f9aa2b7569583805e4c5d5\spring-boot-starter-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-actuator\1.4.3.RELEASE\270a42908a44ae4a939a282479db3bb35086a51a\spring-boot-actuator-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-tomcat\1.4.3.RELEASE\61c48035a7a3b06b42fdd07b7109e562077b3792\spring-boot-starter-tomcat-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.hibernate\hibernate-validator\5.2.4.Final\fb18766b576aa6632bcfe9a20a023cbd52bf9769\hibernate-validator-5.2.4.Final.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-web\4.3.5.RELEASE\6641daccf2fddafc8358144f3a4f999130fdf144\spring-web-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-webmvc\4.3.5.RELEASE\c624659217edab07d8279fb0f90462136f089220\spring-webmvc-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.tomcat.embed\tomcat-embed-el\8.5.6\a102298d8dc72f4065533d5962953d753b172602\tomcat-embed-el-8.5.6.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-beans\4.3.5.RELEASE\e12bbc3277da28e2e2608a187f83091dc6c300bf\spring-beans-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-context\4.3.5.RELEASE\ca3391c0e17d0138335ba51b51371661d20d56a8\spring-context-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-core\4.3.5.RELEASE\80299e3f80e8c6d5c076db2ba6adf44a4b52f578\spring-core-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-aop\4.3.5.RELEASE\4f113218af716bd8d174c411f19b26418b5a70f6\spring-aop-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-tx\4.3.5.RELEASE\296d8ae21fadc0f115dae7d1e8d5c4f8c7de2c3e\spring-tx-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.esotericsoftware\minlog\1.3.0\ff07b5f1b01d2f92bb00a337f9a94873712f0827\minlog-1.3.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.objenesis\objenesis\2.1\87c0ea803b69252868d09308b4618f766f135a96\objenesis-2.1.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot\1.4.3.RELEASE\17f94def4460075afdfba6bf8f897cd1fc95bf77\spring-boot-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-autoconfigure\1.4.3.RELEASE\41df1bfbdd4ae4e8499ebe1a4bc613bda316d6e1\spring-boot-autoconfigure-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-logging\1.4.3.RELEASE\1c58783c0694abf695babfd39829922d2d501ec2\spring-boot-starter-logging-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.tomcat.embed\tomcat-embed-core\8.5.6\960834b5abc6b2135250487abf6c060a0fa5a22e\tomcat-embed-core-8.5.6.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.tomcat.embed\tomcat-embed-websocket\8.5.6\6f6940a216b380ea8506530c374fcfeef820ba54\tomcat-embed-websocket-8.5.6.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\javax.validation\validation-api\1.1.0.Final\8613ae82954779d518631e05daa73a6a954817d5\validation-api-1.1.0.Final.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.jboss.logging\jboss-logging\3.3.0.Final\3616bb87707910296e2c195dc016287080bba5af\jboss-logging-3.3.0.Final.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.fasterxml\classmate\1.3.3\864c8e370a691e343210cc7c532fc198cee460d8\classmate-1.3.3.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-expression\4.3.5.RELEASE\3689dc6c5b942ecde4122eac889ed87977d6f287\spring-expression-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.yaml\snakeyaml\1.17\7a27ea250c5130b2922b86dea63cbb1cc10a660c\snakeyaml-1.17.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\ch.qos.logback\logback-classic\1.1.8\e54f49a227611976642f81cf2106b81c1ece8bf5\logback-classic-1.1.8.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.slf4j\jcl-over-slf4j\1.7.22\86ceac14535af5a42c8fb0d06d79b925dd3cb263\jcl-over-slf4j-1.7.22.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.slf4j\jul-to-slf4j\1.7.22\b0429e950b3d2bc2c39c1bacafac753edbe3781c\jul-to-slf4j-1.7.22.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.slf4j\log4j-over-slf4j\1.7.22\a527c37e9ca6c3d19ba298edd4aa344ca751a203\log4j-over-slf4j-1.7.22.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\ch.qos.logback\logback-core\1.1.8\b4d1c3dea91727faf8b3d19cf4b9b972d6c0b89\logback-core-1.1.8.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.xerial.snappy\snappy-java\1.1.2.6\48d92871ca286a47f230feb375f0bbffa83b85f6\snappy-java-1.1.2.6.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\jline\jline\0.9.94\99a18e9a44834afdebc467294e1138364c207402\jline-0.9.94.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.netty\netty\3.7.0.Final\7a8c35599c68c0bf383df74469aa3e03d9aca87\netty-3.7.0.Final.jar;D:\Program Files (x86)\JetBrains\IntelliJ IDEA 2016.2.2\lib\idea_rt.jar" com.intellij.rt.execution.application.AppMain com.oracle.communications.subscription.event.AvroProducerADDKafkaStreams 22:30:51.170 [main] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig - KafkaAvroSerializerConfig values: schema.registry.url = [http://slc02pad.us.oracle.com:8081] max.schemas.per.subject = 1000 22:30:51.499 [main] INFO io.confluent.kafka.serializers.KafkaAvroDeserializerConfig - KafkaAvroDeserializerConfig values: schema.registry.url = [http://slc02pad.us.oracle.com:8081] max.schemas.per.subject = 1000 specific.avro.reader = true 22:30:51.529 [main] INFO org.apache.kafka.streams.StreamsConfig - StreamsConfig values: application.id = specific-avro-integration-test application.server = bootstrap.servers = [den01ykg.us.oracle.com:9092] buffered.records.per.partition = 1000 cache.max.bytes.buffering = 10485760 client.id = commit.interval.ms = 30000 key.serde = class org.apache.kafka.common.serialization.Serdes$ByteArraySerde metric.reporters = [] metrics.num.samples = 2 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 replication.factor = 1 rocksdb.config.setter = null state.cleanup.delay.ms = 60000 state.dir = /tmp/kafka-streams timestamp.extractor = class org.apache.kafka.streams.processor.ConsumerRecordTimestampExtractor value.serde = class com.oracle.communications.subscription.event.SpecificAvroSerde windowstore.changelog.additional.retention.ms = 86400000 zookeeper.connect = den01ykg.us.oracle.com:2181 22:30:52.409 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name thread.specific-avro-integration-test-1-StreamThread-1.commit-time 22:30:52.414 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name thread.specific-avro-integration-test-1-StreamThread-1.poll-time 22:30:52.414 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name thread.specific-avro-integration-test-1-StreamThread-1.process-time 22:30:52.415 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name thread.specific-avro-integration-test-1-StreamThread-1.punctuate-time 22:30:52.415 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name thread.specific-avro-integration-test-1-StreamThread-1.task-creation 22:30:52.415 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name thread.specific-avro-integration-test-1-StreamThread-1.task-destruction 22:30:52.417 [main] INFO org.apache.kafka.streams.processor.internals.StreamThread - stream-thread [StreamThread-1] Creating producer client 22:30:52.437 [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: acks = 1 batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [den01ykg.us.oracle.com:9092] buffer.memory = 33554432 client.id = specific-avro-integration-test-1-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 = 0 retry.backoff.ms = 100 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 22:30:52.439 [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: acks = 1 batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [den01ykg.us.oracle.com:9092] buffer.memory = 33554432 client.id = specific-avro-integration-test-1-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 = 0 retry.backoff.ms = 100 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 22:30:52.446 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 22:30:52.449 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 22:30:52.633 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [den01ykg.us.oracle.com:9092 (id: -1 rack: null)], partitions = []) 22:30:52.737 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 22:30:52.738 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-created: 22:30:52.738 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 22:30:52.738 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 22:30:52.738 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 22:30:52.738 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name select-time: 22:30:52.739 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name io-time: 22:30:52.746 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name batch-size 22:30:52.747 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name compression-rate 22:30:52.747 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name queue-time 22:30:52.747 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name request-time 22:30:52.747 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 22:30:52.748 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-per-request 22:30:52.748 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name record-retries 22:30:52.748 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name errors 22:30:52.748 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name record-size-max 22:30:52.750 [kafka-producer-network-thread | specific-avro-integration-test-1-StreamThread-1-producer] DEBUG org.apache.kafka.clients.producer.internals.Sender - Starting Kafka producer I/O thread. 22:30:52.752 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.0 22:30:52.752 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a74efb23d1d4 22:30:52.753 [main] DEBUG org.apache.kafka.clients.producer.KafkaProducer - Kafka producer started 22:30:52.753 [main] INFO org.apache.kafka.streams.processor.internals.StreamThread - stream-thread [StreamThread-1] Creating consumer client 22:30:52.760 [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [den01ykg.us.oracle.com:9092] check.crcs = true client.id = specific-avro-integration-test-1-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 = specific-avro-integration-test heartbeat.interval.ms = 3000 interceptor.classes = null key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.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.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 22:30:52.760 [main] DEBUG org.apache.kafka.clients.consumer.KafkaConsumer - Starting the Kafka consumer 22:30:52.761 [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [den01ykg.us.oracle.com:9092] check.crcs = true client.id = specific-avro-integration-test-1-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 = specific-avro-integration-test heartbeat.interval.ms = 3000 interceptor.classes = null key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.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.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 22:30:52.763 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [den01ykg.us.oracle.com:9092 (id: -1 rack: null)], partitions = []) 22:30:52.764 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 22:30:52.765 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-created: 22:30:52.765 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 22:30:52.765 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 22:30:52.765 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 22:30:52.765 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name select-time: 22:30:52.765 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name io-time: log4j:WARN No appenders could be found for logger (org.I0Itec.zkclient.ZkConnection). log4j:WARN Please initialize the log4j system properly. log4j:WARN No appenders could be found for logger (org.I0Itec.zkclient.ZkEventThread). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. 22:30:52.816 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT 22:30:52.816 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=RAVINDRA.in.oracle.com 22:30:52.816 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_91 22:30:52.816 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation 22:30:52.816 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=D:\Java\jdk1.8.0_91\jre 22:30:52.816 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=D:\Java\jdk1.8.0_91\jre\lib\charsets.jar;D:\Java\jdk1.8.0_91\jre\lib\deploy.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\access-bridge-32.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\cldrdata.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\dnsns.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\jaccess.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\jfxrt.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\localedata.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\nashorn.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunec.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunjce_provider.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunmscapi.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunpkcs11.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\zipfs.jar;D:\Java\jdk1.8.0_91\jre\lib\javaws.jar;D:\Java\jdk1.8.0_91\jre\lib\jce.jar;D:\Java\jdk1.8.0_91\jre\lib\jfr.jar;D:\Java\jdk1.8.0_91\jre\lib\jfxswt.jar;D:\Java\jdk1.8.0_91\jre\lib\jsse.jar;D:\Java\jdk1.8.0_91\jre\lib\management-agent.jar;D:\Java\jdk1.8.0_91\jre\lib\plugin.jar;D:\Java\jdk1.8.0_91\jre\lib\resources.jar;D:\Java\jdk1.8.0_91\jre\lib\rt.jar;D:\Amplify\raakella\amplify\provisioning\dev\SubscriptionMock\build\classes\main;D:\Amplify\raakella\amplify\provisioning\dev\SubscriptionMock\build\resources\main;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-starter-stream-kafka\1.1.0.RELEASE\8b2c17bbd9615f51f94e0d2907ca4cbe5759031b\spring-cloud-starter-stream-kafka-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.avro\avro\1.8.1\f4e11d00055760dca33daab193192bd75cc87b59\avro-1.8.1.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.confluent\kafka-avro-serializer\3.0.0\64b35a995447495b9c2478f1d08f29539e97c0f1\kafka-avro-serializer-3.0.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\connect-json\0.10.1.0\9672086fc07f69412e706c3f89582cfc9124df69\connect-json-0.10.1.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\kafka-streams\0.10.1.0\184fe00a7afba26772c056ef4dc1fba4425cd8ef\kafka-streams-0.10.1.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\kafka-clients\0.10.1.0\1a351630175ce886ffe200a03dd3a56ec5ee93df\kafka-clients-0.10.1.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-stream-schema\1.1.0.RELEASE\265712f2fff054e29d3c003393cd4991518232dd\spring-cloud-stream-schema-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-stream-binder-kafka\1.1.0.RELEASE\c475b9bd671404f3930e175ec5a03d65843e4af5\spring-cloud-stream-binder-kafka-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.codehaus.jackson\jackson-core-asl\1.9.13\3c304d70f42f832e0a86d45bd437f692129299a4\jackson-core-asl-1.9.13.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.codehaus.jackson\jackson-mapper-asl\1.9.13\1ee2f2bed0e5dd29d1cb155a166e6f8d50bbddb7\jackson-mapper-asl-1.9.13.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.thoughtworks.paranamer\paranamer\2.7\3ed64c69e882a324a75e890024c32a28aff0ade8\paranamer-2.7.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.commons\commons-compress\1.8.1\a698750c16740fd5b3871425f4cb3bbaa87f529d\commons-compress-1.8.1.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.tukaani\xz\1.5\9c64274b7dbb65288237216e3fae7877fd3f2bee\xz-1.5.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.slf4j\slf4j-api\1.7.22\a1c83373863cec7ae8d89dc1c5722d8cb6ec0309\slf4j-api-1.7.22.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.confluent\kafka-schema-registry-client\3.0.0\e0d668b28e46597286818ede314f0a1483de7bd9\kafka-schema-registry-client-3.0.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.confluent\common-config\3.0.0\ba8110b6f413e630efe23c8a79e91ce546ecb490\common-config-3.0.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\connect-api\0.10.1.0\9ebbd005a61d0d88f98f1bfc369e0103e5f00672\connect-api-0.10.1.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.fasterxml.jackson.core\jackson-databind\2.8.5\b3035f37e674c04dafe36a660c3815cc59f764e2\jackson-databind-2.8.5.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.rocksdb\rocksdbjni\4.9.0\9be2d4f0639e3abddc5ab647240fdba8ef8f7bdb\rocksdbjni-4.9.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.101tec\zkclient\0.9\822482d08b9a0af9c43e8d1b6cb94e81ee3e361c\zkclient-0.9.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\log4j\log4j\1.2.17\5af35056b4d257e4b64b9e8069c0746e8b08629f\log4j-1.2.17.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\net.jpountz.lz4\lz4\1.3.0\c708bb2590c0652a642236ef45d9f99ff842a2ce\lz4-1.3.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-stream\1.1.0.RELEASE\1a6d3c740375a5124eae4c471884700f087e3263\spring-cloud-stream-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.cloud\spring-cloud-stream-codec\1.1.0.RELEASE\892c915a6733ffde07de31dac5781751a08aee84\spring-cloud-stream-codec-1.1.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.integration\spring-integration-kafka\2.0.1.RELEASE\add065cb3b165fe3236810dbedb53b70a50a758a\spring-integration-kafka-2.0.1.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.kafka\kafka_2.11\0.9.0.1\6cc159e873fd6e5b43532faa4bf20a5929c03fc6\kafka_2.11-0.9.0.1.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.kafka\spring-kafka\1.0.4.RELEASE\c3ea4d3decba994541224cd9e2f720934a1f262b\spring-kafka-1.0.4.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.confluent\common-utils\3.0.0\7d1cda6028ce7befd7fec5fbe3d2622232d850f0\common-utils-3.0.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.fasterxml.jackson.core\jackson-annotations\2.8.5\9d82ff47bc2c2d3b5b6a6618fe636782bbcd5b07\jackson-annotations-2.8.5.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.fasterxml.jackson.core\jackson-core\2.8.5\60d059f5d2930ccd1ef03535b713fd9f933d1ba7\jackson-core-2.8.5.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.zookeeper\zookeeper\3.4.8\933ea2ed15e6a0e24b788973e3d128ff163c3136\zookeeper-3.4.8.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-actuator\1.4.3.RELEASE\79b4f3ebf23f86c2680cbd37a109272f4e782022\spring-boot-starter-actuator-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-web\1.4.3.RELEASE\a0dcc919eda8e8ecb6f13f52a30e6afbb8266103\spring-boot-starter-web-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-validation\1.4.3.RELEASE\6d8ee356222ed1e7195c8b9fa7588c51a6ad6216\spring-boot-starter-validation-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-messaging\4.3.5.RELEASE\480f1116f2060107493b91e72e21359b02aca776\spring-messaging-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.integration\spring-integration-core\4.3.6.RELEASE\39f1a7f39d6fdc6b7bcb17bd8706f4a298abff36\spring-integration-core-4.3.6.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.integration\spring-integration-jmx\4.3.6.RELEASE\4285b5a7e14bca4349a315fa692e956083b75822\spring-integration-jmx-4.3.6.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-tuple\1.0.0.RELEASE\5feaacebc66a885e9f2017063586df2300ce5c68\spring-tuple-1.0.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.integration\spring-integration-tuple\1.0.0.RELEASE\4ac09adb2ab6857604784b3e61ef02bcdc974928\spring-integration-tuple-1.0.0.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.retry\spring-retry\1.1.5.RELEASE\8669af2bbd289e8dc5ebe6fdf44da1da0ba19b2a\spring-retry-1.1.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.esotericsoftware\kryo-shaded\3.0.3\977d6b42d82de551fcf77dad84ef06c2839e3a74\kryo-shaded-3.0.3.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.yammer.metrics\metrics-core\2.2.0\f82c035cfa786d3cbec362c38c22a5f5b1bc8724\metrics-core-2.2.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.scala-lang.modules\scala-xml_2.11\1.0.4\b67c76af885ba3323ce51bbed4c9232f4bd5d8fd\scala-xml_2.11-1.0.4.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.scala-lang\scala-library\2.11.7\f75e7acabd57b213d6f61483240286c07213ec0e\scala-library-2.11.7.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.scala-lang.modules\scala-parser-combinators_2.11\1.0.4\7369d653bcfa95d321994660477a4d7e81d7f490\scala-parser-combinators_2.11-1.0.4.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\net.sf.jopt-simple\jopt-simple\3.2\d625f12ba08083c8c16dcedd5396ec730e9e77ab\jopt-simple-3.2.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter\1.4.3.RELEASE\c99bad104719e947b3f9aa2b7569583805e4c5d5\spring-boot-starter-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-actuator\1.4.3.RELEASE\270a42908a44ae4a939a282479db3bb35086a51a\spring-boot-actuator-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-tomcat\1.4.3.RELEASE\61c48035a7a3b06b42fdd07b7109e562077b3792\spring-boot-starter-tomcat-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.hibernate\hibernate-validator\5.2.4.Final\fb18766b576aa6632bcfe9a20a023cbd52bf9769\hibernate-validator-5.2.4.Final.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-web\4.3.5.RELEASE\6641daccf2fddafc8358144f3a4f999130fdf144\spring-web-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-webmvc\4.3.5.RELEASE\c624659217edab07d8279fb0f90462136f089220\spring-webmvc-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.tomcat.embed\tomcat-embed-el\8.5.6\a102298d8dc72f4065533d5962953d753b172602\tomcat-embed-el-8.5.6.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-beans\4.3.5.RELEASE\e12bbc3277da28e2e2608a187f83091dc6c300bf\spring-beans-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-context\4.3.5.RELEASE\ca3391c0e17d0138335ba51b51371661d20d56a8\spring-context-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-core\4.3.5.RELEASE\80299e3f80e8c6d5c076db2ba6adf44a4b52f578\spring-core-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-aop\4.3.5.RELEASE\4f113218af716bd8d174c411f19b26418b5a70f6\spring-aop-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-tx\4.3.5.RELEASE\296d8ae21fadc0f115dae7d1e8d5c4f8c7de2c3e\spring-tx-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.esotericsoftware\minlog\1.3.0\ff07b5f1b01d2f92bb00a337f9a94873712f0827\minlog-1.3.0.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.objenesis\objenesis\2.1\87c0ea803b69252868d09308b4618f766f135a96\objenesis-2.1.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot\1.4.3.RELEASE\17f94def4460075afdfba6bf8f897cd1fc95bf77\spring-boot-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-autoconfigure\1.4.3.RELEASE\41df1bfbdd4ae4e8499ebe1a4bc613bda316d6e1\spring-boot-autoconfigure-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework.boot\spring-boot-starter-logging\1.4.3.RELEASE\1c58783c0694abf695babfd39829922d2d501ec2\spring-boot-starter-logging-1.4.3.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.tomcat.embed\tomcat-embed-core\8.5.6\960834b5abc6b2135250487abf6c060a0fa5a22e\tomcat-embed-core-8.5.6.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.apache.tomcat.embed\tomcat-embed-websocket\8.5.6\6f6940a216b380ea8506530c374fcfeef820ba54\tomcat-embed-websocket-8.5.6.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\javax.validation\validation-api\1.1.0.Final\8613ae82954779d518631e05daa73a6a954817d5\validation-api-1.1.0.Final.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.jboss.logging\jboss-logging\3.3.0.Final\3616bb87707910296e2c195dc016287080bba5af\jboss-logging-3.3.0.Final.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\com.fasterxml\classmate\1.3.3\864c8e370a691e343210cc7c532fc198cee460d8\classmate-1.3.3.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.springframework\spring-expression\4.3.5.RELEASE\3689dc6c5b942ecde4122eac889ed87977d6f287\spring-expression-4.3.5.RELEASE.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.yaml\snakeyaml\1.17\7a27ea250c5130b2922b86dea63cbb1cc10a660c\snakeyaml-1.17.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\ch.qos.logback\logback-classic\1.1.8\e54f49a227611976642f81cf2106b81c1ece8bf5\logback-classic-1.1.8.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.slf4j\jcl-over-slf4j\1.7.22\86ceac14535af5a42c8fb0d06d79b925dd3cb263\jcl-over-slf4j-1.7.22.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.slf4j\jul-to-slf4j\1.7.22\b0429e950b3d2bc2c39c1bacafac753edbe3781c\jul-to-slf4j-1.7.22.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.slf4j\log4j-over-slf4j\1.7.22\a527c37e9ca6c3d19ba298edd4aa344ca751a203\log4j-over-slf4j-1.7.22.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\ch.qos.logback\logback-core\1.1.8\b4d1c3dea91727faf8b3d19cf4b9b972d6c0b89\logback-core-1.1.8.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\org.xerial.snappy\snappy-java\1.1.2.6\48d92871ca286a47f230feb375f0bbffa83b85f6\snappy-java-1.1.2.6.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\jline\jline\0.9.94\99a18e9a44834afdebc467294e1138364c207402\jline-0.9.94.jar;C:\Users\RAAKELLA\.gradle\caches\modules-2\files-2.1\io.netty\netty\3.7.0.Final\7a8c35599c68c0bf383df74469aa3e03d9aca87\netty-3.7.0.Final.jar;D:\Program Files (x86)\JetBrains\IntelliJ IDEA 2016.2.2\lib\idea_rt.jar 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=D:\Java\jdk1.8.0_91\bin;C:\windows\Sun\Java\bin;C:\windows\system32;C:\windows;C:\Program Files\Docker\Docker\Resources\bin;D:\oracle\db\product\12.1.0\dbhome_1\bin;C:\ProgramData\Oracle\Java\javapath;C:\windows\system32;C:\windows;C:\windows\System32\Wbem;C:\windows\System32\WindowsPowerShell\v1.0\;D:\software\apache-maven-3.3.9\bin;D:\Program Files (x86)\Git\cmd;D:\Program Files (x86)\Git\mingw64\bin;D:\Program Files (x86)\Git\mingw64\libexec\git-core;D:\software\zookeeper-3.4.9\bin;D:\software\curl;D:\software\gradle-3.1\bin1;D:\software\groovy-2.4.7\bin;C:\Program Files (x86)\Sennheiser\SoftphoneSDK\;D:\software\zookeeper-3.4.9\bin;D:\software\gradle-3.0-bin\gradle-3.0\bin;. 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=C:\Users\RAAKELLA\AppData\Local\Temp\ 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler= 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Windows 10 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=x86 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=10.0 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=RAAKELLA 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=C:\Users\RAAKELLA 22:30:52.817 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=D:\Amplify\raakella\amplify\provisioning\dev\SubscriptionMock 22:30:52.818 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=den01ykg.us.oracle.com:2181 sessionTimeout=30000 watcher=org.I0Itec.zkclient.ZkClient@1ceb1df 22:30:52.821 [main] DEBUG org.apache.zookeeper.ClientCnxn - zookeeper.disableAutoWatchReset is false 22:30:52.836 [main-SendThread(den01ykg.us.oracle.com:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server den01ykg.us.oracle.com/10.89.202.72:2181. Will not attempt to authenticate using SASL (unknown error) 22:30:53.115 [main-SendThread(den01ykg.us.oracle.com:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established to den01ykg.us.oracle.com/10.89.202.72:2181, initiating session 22:30:53.120 [main-SendThread(den01ykg.us.oracle.com:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Session establishment request sent on den01ykg.us.oracle.com/10.89.202.72:2181 22:30:53.418 [main-SendThread(den01ykg.us.oracle.com:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server den01ykg.us.oracle.com/10.89.202.72:2181, sessionid = 0x15a99af9e500019, negotiated timeout = 30000 22:30:53.465 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 22:30:53.465 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name join-latency 22:30:53.466 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name sync-latency 22:30:53.469 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name commit-latency 22:30:53.483 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 22:30:53.483 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-fetched 22:30:53.484 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 22:30:53.484 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-lag 22:30:53.484 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 22:30:53.485 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.0 22:30:53.485 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a74efb23d1d4 22:30:53.485 [main] DEBUG org.apache.kafka.clients.consumer.KafkaConsumer - Kafka consumer created 22:30:53.485 [main] INFO org.apache.kafka.streams.processor.internals.StreamThread - stream-thread [StreamThread-1] Creating restore consumer client 22:30:53.486 [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [den01ykg.us.oracle.com:9092] check.crcs = true client.id = specific-avro-integration-test-1-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 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.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.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 22:30:53.486 [main] DEBUG org.apache.kafka.clients.consumer.KafkaConsumer - Starting the Kafka consumer 22:30:53.486 [main] INFO org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [den01ykg.us.oracle.com:9092] check.crcs = true client.id = specific-avro-integration-test-1-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 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 1000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.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.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 22:30:53.487 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [den01ykg.us.oracle.com:9092 (id: -1 rack: null)], partitions = []) 22:30:53.488 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 22:30:53.488 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-created: 22:30:53.488 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 22:30:53.488 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 22:30:53.489 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 22:30:53.489 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name select-time: 22:30:53.489 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name io-time: 22:30:53.490 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name heartbeat-latency 22:30:53.490 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name join-latency 22:30:53.490 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name sync-latency 22:30:53.491 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name commit-latency 22:30:53.491 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-fetched 22:30:53.491 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-fetched 22:30:53.491 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name fetch-latency 22:30:53.492 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-lag 22:30:53.492 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name fetch-throttle-time 22:30:53.492 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.0 22:30:53.492 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a74efb23d1d4 22:30:53.492 [main] DEBUG org.apache.kafka.clients.consumer.KafkaConsumer - Kafka consumer created 22:30:53.495 [main] DEBUG org.apache.kafka.streams.KafkaStreams - Starting Kafka Stream process 22:30:53.495 [main] INFO org.apache.kafka.streams.KafkaStreams - Started Kafka Stream process 22:30:53.495 [StreamThread-1] INFO org.apache.kafka.streams.processor.internals.StreamThread - stream-thread [StreamThread-1] Starting 22:30:53.495 [StreamThread-1] DEBUG org.apache.kafka.clients.consumer.KafkaConsumer - Subscribed to topic(s): amp.provisioning.events.provisionRequest 22:30:53.495 [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: acks = all batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [den01ykg.us.oracle.com:9092] buffer.memory = 33554432 client.id = compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 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 = 0 retry.backoff.ms = 100 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 io.confluent.kafka.serializers.KafkaAvroSerializer 22:30:53.496 [StreamThread-1] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Sending coordinator request for group specific-avro-integration-test to broker den01ykg.us.oracle.com:9092 (id: -1 rack: null) 22:30:53.496 [main] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig - KafkaAvroSerializerConfig values: schema.registry.url = [http://slc02pad.us.oracle.com:8081] max.schemas.per.subject = 1000 22:30:53.496 [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: acks = all batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [den01ykg.us.oracle.com:9092] buffer.memory = 33554432 client.id = producer-1 compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 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 = 0 retry.backoff.ms = 100 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 io.confluent.kafka.serializers.KafkaAvroSerializer 22:30:53.500 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 22:30:53.500 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 22:30:53.501 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [den01ykg.us.oracle.com:9092 (id: -1 rack: null)], partitions = []) 22:30:53.502 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 22:30:53.502 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-created: 22:30:53.502 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 22:30:53.503 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 22:30:53.503 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 22:30:53.503 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name select-time: 22:30:53.504 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name io-time: 22:30:53.504 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name batch-size 22:30:53.504 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name compression-rate 22:30:53.504 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name queue-time 22:30:53.504 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name request-time 22:30:53.505 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 22:30:53.505 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-per-request 22:30:53.505 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name record-retries 22:30:53.505 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name errors 22:30:53.505 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name record-size-max 22:30:53.506 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.0 22:30:53.506 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a74efb23d1d4 22:30:53.506 [main] DEBUG org.apache.kafka.clients.producer.KafkaProducer - Kafka producer started 22:30:53.506 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - Starting Kafka producer I/O thread. 22:30:53.528 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at den01ykg.us.oracle.com:9092. {"orderId": "ORD1030404", "correlationId": "1488646853506", "items": [{"provisionOrderLineId": "1", "productActionCode": "ADD", "subscriptionId": "101"}]} 22:30:53.565 [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: acks = all batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [den01ykg.us.oracle.com:9092] buffer.memory = 33554432 client.id = compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 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 = 0 retry.backoff.ms = 100 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 io.confluent.kafka.serializers.KafkaAvroSerializer 22:30:53.566 [main] INFO io.confluent.kafka.serializers.KafkaAvroSerializerConfig - KafkaAvroSerializerConfig values: schema.registry.url = [http://slc02pad.us.oracle.com:8081] max.schemas.per.subject = 1000 22:30:53.566 [main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: acks = all batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [den01ykg.us.oracle.com:9092] buffer.memory = 33554432 client.id = producer-2 compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 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 = 0 retry.backoff.ms = 100 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 io.confluent.kafka.serializers.KafkaAvroSerializer 22:30:53.566 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 22:30:53.566 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 22:30:53.566 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [den01ykg.us.oracle.com:9092 (id: -1 rack: null)], partitions = []) 22:30:53.568 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 22:30:53.568 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name connections-created: 22:30:53.568 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 22:30:53.568 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 22:30:53.568 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 22:30:53.568 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name select-time: 22:30:53.569 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name io-time: 22:30:53.569 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name batch-size 22:30:53.569 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name compression-rate 22:30:53.569 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name queue-time 22:30:53.569 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name request-time 22:30:53.569 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 22:30:53.569 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name records-per-request 22:30:53.570 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name record-retries 22:30:53.570 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name errors 22:30:53.570 [main] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name record-size-max 22:30:53.570 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.0 22:30:53.570 [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a74efb23d1d4 22:30:53.570 [main] DEBUG org.apache.kafka.clients.producer.KafkaProducer - Kafka producer started 22:30:53.570 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.producer.internals.Sender - Starting Kafka producer I/O thread. 22:30:53.666 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Initialize connection to node -1 for sending metadata request 22:30:53.666 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at den01ykg.us.oracle.com:9092. 22:30:53.805 [StreamThread-1] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 22:30:53.805 [StreamThread-1] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 22:30:53.805 [StreamThread-1] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 22:30:53.806 [StreamThread-1] DEBUG org.apache.kafka.common.network.Selector - Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 22:30:53.806 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Completed connection to node -1 22:30:53.829 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request {topics=[amp.provisioning.events.provisionRequest]} to node -1 22:30:53.940 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 22:30:53.940 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 22:30:53.940 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 22:30:53.941 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.common.network.Selector - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 22:30:53.941 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Completed connection to node -1 22:30:53.968 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request {topics=[amp.provisioning.events.provisionRequest]} to node -1 22:30:54.116 [StreamThread-1] DEBUG org.apache.kafka.common.network.Selector - Connection with den01ykg.us.oracle.com/10.89.202.72 disconnected java.io.IOException: An existing connection was forcibly closed by the remote host at sun.nio.ch.SocketDispatcher.read0(Native Method) at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43) at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) at sun.nio.ch.IOUtil.read(IOUtil.java:197) at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) at org.apache.kafka.common.network.PlaintextTransportLayer.read(PlaintextTransportLayer.java:110) at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:81) at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343) at org.apache.kafka.common.network.Selector.poll(Selector.java:291) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:180) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:193) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:248) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1013) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979) at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:407) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:242) 22:30:54.117 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Node -1 disconnected. 22:30:54.119 [StreamThread-1] WARN org.apache.kafka.clients.NetworkClient - Bootstrap broker den01ykg.us.oracle.com:9092 disconnected 22:30:54.120 [StreamThread-1] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient - Cancelled GROUP_COORDINATOR request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@ad41b4, request=RequestSend(header={api_key=10,api_version=0,correlation_id=0,client_id=specific-avro-integration-test-1-StreamThread-1-consumer}, body={group_id=specific-avro-integration-test}), createdTimeMs=1488646853518, sendTimeMs=1488646853832) with correlation id 0 due to node -1 being disconnected 22:30:54.121 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Give up sending metadata request since no node is available 22:30:54.222 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Initialize connection to node -1 for sending metadata request 22:30:54.222 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at den01ykg.us.oracle.com:9092. 22:30:54.244 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.common.network.Selector - Connection with den01ykg.us.oracle.com/10.89.202.72 disconnected java.io.EOFException: null at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343) at org.apache.kafka.common.network.Selector.poll(Selector.java:291) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:236) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135) at java.lang.Thread.run(Thread.java:745) 22:30:54.244 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Node -1 disconnected. 22:30:54.244 [kafka-producer-network-thread | producer-2] WARN org.apache.kafka.clients.NetworkClient - Bootstrap broker den01ykg.us.oracle.com:9092 disconnected 22:30:54.244 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Give up sending metadata request since no node is available 22:30:54.345 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Initialize connection to node -1 for sending metadata request 22:30:54.345 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at den01ykg.us.oracle.com:9092. 22:30:54.497 [StreamThread-1] DEBUG org.apache.kafka.common.network.Selector - Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 22:30:54.497 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Completed connection to node -1 22:30:54.524 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request {topics=[amp.provisioning.events.provisionRequest]} to node -1 22:30:54.621 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.common.network.Selector - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 22:30:54.621 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Completed connection to node -1 22:30:54.647 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request {topics=[amp.provisioning.events.provisionRequest]} to node -1 22:30:54.808 [StreamThread-1] DEBUG org.apache.kafka.common.network.Selector - Connection with den01ykg.us.oracle.com/10.89.202.72 disconnected java.io.EOFException: null at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343) at org.apache.kafka.common.network.Selector.poll(Selector.java:291) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:209) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:148) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:136) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:197) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:248) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1013) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979) at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:407) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:242) 22:30:54.808 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Node -1 disconnected. 22:30:54.808 [StreamThread-1] WARN org.apache.kafka.clients.NetworkClient - Bootstrap broker den01ykg.us.oracle.com:9092 disconnected 22:30:54.809 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Give up sending metadata request since no node is available 22:30:54.909 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Initialize connection to node -1 for sending metadata request 22:30:54.909 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at den01ykg.us.oracle.com:9092. 22:30:54.928 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.common.network.Selector - Connection with den01ykg.us.oracle.com/10.89.202.72 disconnected java.io.EOFException: null at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343) at org.apache.kafka.common.network.Selector.poll(Selector.java:291) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:236) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135) at java.lang.Thread.run(Thread.java:745) 22:30:54.929 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Node -1 disconnected. 22:30:54.929 [kafka-producer-network-thread | producer-2] WARN org.apache.kafka.clients.NetworkClient - Bootstrap broker den01ykg.us.oracle.com:9092 disconnected 22:30:54.929 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Give up sending metadata request since no node is available 22:30:55.030 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Initialize connection to node -1 for sending metadata request 22:30:55.030 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at den01ykg.us.oracle.com:9092. 22:30:55.181 [StreamThread-1] DEBUG org.apache.kafka.common.network.Selector - Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 22:30:55.181 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Completed connection to node -1 22:30:55.212 [StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request {topics=[amp.provisioning.events.provisionRequest]} to node -1 22:30:55.306 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.common.network.Selector - Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 22:30:55.306 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Completed connection to node -1 22:30:55.334 [kafka-producer-network-thread | producer-2] DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request {topics=[amp.provisioning.events.provisionRequest]} to node -1 Process finished with exit code 1