Setting up a basic word count job, similar to the one from confluent-2.1.0-alpha1 (WordCountJob). Mine does the same thing essentially, just within our namespace.
Coming across this error though, which is strange because the code for the moment is identical with the exception of the topic names. Exception in thread "StreamThread-1" org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'topic_metadata': Error reading array of size 1731681, only 54 bytes available at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:75) at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:380) at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:449) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:269) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:179) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:973) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:937) at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:295) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218) Is there something I'm missing? Thanks for the help. Lawrence ________________________________ Begin full output: /Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/bin/java -Didea.launcher.port=7539 "-Didea.launcher.bin.path=/Applications/IntelliJ IDEA.app/Contents/bin" -Dfile.encoding=UTF-8 -classpath "/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/tools.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Users/lweikum/COMPANY/POCStreams/out/production/lawrenceExample:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-streams-0.10.0.0-SNAPSHOT.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-clients-0.10.0.0-SNAPSHOT.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-tools-0.10.0.0-SNAPSHOT.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/slf4j-api-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/zookeeper-3.4.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/zkclient-0.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/netty-3.2.2.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/jline-0.9.94.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/common-utils-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/common-metrics-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/common-config-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aopalliance-repackaged-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/argparse4j-0.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-autoscaling-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudformation-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudfront-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudsearch-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudtrail-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudwatch-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudwatchmetrics-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cognitoidentity-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cognitosync-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-core-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-datapipeline-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-directconnect-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-dynamodb-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-ec2-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-elasticache-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-elasticbeanstalk-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-elasticloadbalancing-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-elastictranscoder-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-emr-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-glacier-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-iam-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-importexport-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-kinesis-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-logs-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-opsworks-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-rds-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-redshift-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-route53-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-s3-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-ses-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-simpledb-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-simpleworkflow-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-sns-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-sqs-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-storagegateway-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-sts-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-support-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-swf-libraries-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-beanutils-1.8.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-codec-1.9.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-collections-3.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-compress-1.9.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-digester-1.8.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-lang3-3.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-logging-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-validator-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/connect-api-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/connect-file-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/connect-json-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/connect-runtime-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/hk2-api-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/hk2-locator-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/hk2-utils-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/httpclient-4.5.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/httpcore-4.4.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/httpmime-4.5.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-annotations-2.3.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-annotations-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-core-2.3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-core-2.6.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-databind-2.3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-databind-2.6.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-jaxrs-base-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-jaxrs-json-provider-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-module-jaxb-annotations-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javassist-3.18.1-GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.annotation-api-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.inject-1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.inject-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.servlet-api-3.1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.ws.rs-api-2.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-client-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-common-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-container-servlet-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-container-servlet-core-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-guava-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-media-jaxb-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-server-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-http-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-io-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-security-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-server-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-servlet-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-util-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jline-0.9.94.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/joda-time-2.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jopt-simple-3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/junit-3.8.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-clients-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-log4j-appender-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-streams-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-streams-examples-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-tools-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka_2.11-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka_2.11-0.9.1.0-cp1-test.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/lz4-1.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/metrics-core-2.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/netty-3.7.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/osgi-resource-locator-1.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/rocksdbjni-4.1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/scala-library-2.11.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/scala-parser-combinators_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/scala-xml_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/slf4j-api-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/snappy-java-1.1.1.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/support-metrics-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/support-metrics-common-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/support-metrics-fullcollector-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/validation-api-1.1.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/zkclient-0.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/zookeeper-3.4.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/kafka-avro-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/kafka-connect-avro-converter-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/kafka-json-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/slf4j-api-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/snappy-java-1.0.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/activation-1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/jline-0.9.94.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/jopt-simple-3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-avro-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-clients-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-json-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-rest-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka_2.11-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/log4j-1.2.15.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/lz4-1.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/mail-1.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/metrics-core-2.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/netty-3.7.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/scala-library-2.11.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/scala-parser-combinators_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/scala-xml_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/slf4j-api-1.6.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/snappy-java-1.1.1.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/zkclient-0.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/zookeeper-3.4.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-jdbc/kafka-connect-jdbc-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-jdbc/postgresql-9.4-1206-jdbc41.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-jdbc/sqlite-jdbc-3.8.11.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/ant-1.9.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/ant-launcher-1.9.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/antlr-2.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/antlr-runtime-3.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/aopalliance-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/apache-log4j-extras-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/apacheds-i18n-2.0.0-M15.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/apacheds-kerberos-codec-2.0.0-M15.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/api-asn1-api-1.0.0-M20.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/api-util-1.0.0-M20.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/avro-ipc-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/avro-ipc-1.7.7-tests.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/avro-mapred-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/bonecp-0.8.0.RELEASE.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/calcite-avatica-1.2.0-incubating.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/calcite-core-1.2.0-incubating.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/calcite-linq4j-1.2.0-incubating.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-beanutils-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-beanutils-core-1.8.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-cli-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-codec-1.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-collections-3.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-compiler-2.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-configuration-1.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-dbcp-1.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-digester-1.8.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-httpclient-3.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-io-2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-lang-2.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-logging-1.1.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-math3-3.1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-net-3.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-pool-1.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/curator-client-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/curator-framework-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/curator-recipes-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/datanucleus-api-jdo-3.2.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/datanucleus-core-3.2.10.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/datanucleus-rdbms-3.2.9.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/derby-10.10.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/eigenbase-properties-1.1.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/groovy-all-2.1.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/gson-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/guava-14.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/guice-3.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/guice-servlet-3.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-annotations-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-auth-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-common-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-hdfs-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-app-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-common-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-core-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-jobclient-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-shuffle-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-api-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-client-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-common-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-server-applicationhistoryservice-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-server-common-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-server-resourcemanager-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-server-web-proxy-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-ant-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-cli-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-common-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-exec-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-hcatalog-core-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-metastore-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-serde-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-service-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-shims-0.20S-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-shims-0.23-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-shims-common-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-shims-scheduler-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/htrace-core-3.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/httpclient-4.2.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/httpcore-4.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/ivy-2.4.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-jaxrs-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-xc-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/janino-2.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/javax.inject-1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jaxb-api-2.2.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jdo-api-3.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jettison-1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jline-2.12.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/joda-time-1.6.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jpam-1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/json-20090211.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jsr305-1.3.9.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jta-1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/kafka-avro-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/kafka-connect-avro-converter-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/kafka-connect-hdfs-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/leveldbjni-all-1.8.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/libfb303-0.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/libthrift-0.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/log4j-1.2.16.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/netty-3.6.2.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/opencsv-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-avro-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-column-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-common-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-encoding-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-format-2.3.0-incubating.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-generator-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-hadoop-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-hadoop-bundle-1.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-hadoop-bundle-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-jackson-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/pentaho-aggdesigner-algorithm-5.1.5-jhyde.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/protobuf-java-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/servlet-api-2.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/slf4j-log4j12-1.7.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/ST4-4.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/stax-api-1.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/stax-api-1.0-2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/stringtemplate-3.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/velocity-1.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/xercesImpl-2.9.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/xml-apis-1.3.04.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/xmlenc-0.52.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/zookeeper-3.4.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/avro-ipc-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/avro-ipc-1.7.7-tests.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/avro-mapred-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/camus-api-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/camus-etl-kafka-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/camus-kafka-coders-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/camus-schema-registry-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/commons-cli-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/confluent-camus-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/gson-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/java-dogstatsd-client-2.0.8.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jetty-6.1.26.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/joda-time-1.6.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jopt-simple-3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/kafka-clients-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/kafka_2.11-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/lz4-1.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/metrics-core-2.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/scala-library-2.11.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/scala-parser-combinators_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/scala-xml_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/servlet-api-2.5-20081211.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/slf4j-api-1.6.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/snappy-java-1.0.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/velocity-1.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/zkclient-0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/zkclient-0.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/zookeeper-3.3.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/aopalliance-repackaged-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/asm-debug-all-5.0.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/classmate-1.0.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hamcrest-core-1.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hibernate-validator-5.1.2.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hk2-api-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hk2-locator-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hk2-utils-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-annotations-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-jaxrs-base-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-jaxrs-json-provider-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-module-jaxb-annotations-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javassist-3.18.1-GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.annotation-api-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.el-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.el-api-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.inject-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.servlet-api-3.1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.ws.rs-api-2.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jboss-logging-3.1.3.GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-bean-validation-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-client-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-common-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-container-jetty-http-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-container-servlet-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-container-servlet-core-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-guava-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-media-jaxb-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-server-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-test-framework-core-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-test-framework-provider-jetty-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-continuation-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-http-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-io-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-security-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-server-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-servlet-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-servlets-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-util-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/junit-4.12.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/osgi-resource-locator-1.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/rest-utils-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/rest-utils-examples-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/rest-utils-test-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/validation-api-1.1.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/aopalliance-repackaged-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/classmate-1.0.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/hibernate-validator-5.1.2.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/hk2-api-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/hk2-locator-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/hk2-utils-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javassist-3.18.1-GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.annotation-api-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.el-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.el-api-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.inject-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.ws.rs-api-2.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jboss-logging-3.1.3.GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-bean-validation-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-client-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-common-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-guava-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-media-jaxb-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-server-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jline-0.9.94.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jopt-simple-3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/kafka-clients-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/kafka-schema-registry-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/kafka_2.11-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/lz4-1.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/metrics-core-2.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/netty-3.7.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/osgi-resource-locator-1.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/scala-library-2.11.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/scala-parser-combinators_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/scala-xml_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/slf4j-api-1.6.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/snappy-java-1.0.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/validation-api-1.1.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/zkclient-0.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/zookeeper-3.4.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/connect-0.10.0.0-SNAPSHOT.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-0.10.0.0-SNAPSHOT.jar:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar" com.intellij.rt.execution.application.AppMain com.savagebeast.KafkaStreams.StreamsTest.WordCountTestJob SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] [StreamsConfig] - StreamsConfig values: replication.factor = 1 num.standby.replicas = 0 metric.reporters = [] commit.interval.ms = 30000 bootstrap.servers = [localhost:9092] state.dir = /tmp/kafka-streams partition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper state.cleanup.delay.ms = 60000 poll.ms = 100 zookeeper.connect = localhost:2181 key.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde metrics.sample.window.ms = 30000 buffered.records.per.partition = 1000 value.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde timestamp.extractor = class org.apache.kafka.streams.processor.ConsumerRecordTimestampExtractor num.stream.threads = 1 metrics.num.samples = 2 application.id = lawrence-streams-wordcount client.id = [StreamThread] - Creating producer client for stream thread [StreamThread-1] [ProducerConfig] - ProducerConfig values: metric.reporters = [] metadata.max.age.ms = 300000 reconnect.backoff.ms = 50 sasl.kerberos.ticket.renew.window.factor = 0.8 bootstrap.servers = [localhost:9092] ssl.keystore.type = JKS sasl.mechanism = GSSAPI max.block.ms = 60000 interceptor.classes = null ssl.truststore.password = null client.id = lawrence-streams-wordcount-1-StreamThread-1-producer ssl.endpoint.identification.algorithm = null request.timeout.ms = 30000 acks = 1 receive.buffer.bytes = 32768 ssl.truststore.type = JKS retries = 0 ssl.truststore.location = null ssl.keystore.password = null send.buffer.bytes = 131072 compression.type = none metadata.fetch.timeout.ms = 60000 retry.backoff.ms = 100 sasl.kerberos.kinit.cmd = /usr/bin/kinit buffer.memory = 33554432 timeout.ms = 30000 key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 ssl.trustmanager.algorithm = PKIX block.on.buffer.full = false ssl.key.password = null sasl.kerberos.min.time.before.relogin = 60000 connections.max.idle.ms = 540000 max.in.flight.requests.per.connection = 5 metrics.num.samples = 2 ssl.protocol = TLS ssl.provider = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] batch.size = 16384 ssl.keystore.location = null ssl.cipher.suites = null security.protocol = PLAINTEXT max.request.size = 1048576 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer ssl.keymanager.algorithm = SunX509 metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner linger.ms = 100 [ProducerConfig] - ProducerConfig values: metric.reporters = [] metadata.max.age.ms = 300000 reconnect.backoff.ms = 50 sasl.kerberos.ticket.renew.window.factor = 0.8 bootstrap.servers = [localhost:9092] ssl.keystore.type = JKS sasl.mechanism = GSSAPI max.block.ms = 60000 interceptor.classes = null ssl.truststore.password = null client.id = lawrence-streams-wordcount-1-StreamThread-1-producer ssl.endpoint.identification.algorithm = null request.timeout.ms = 30000 acks = 1 receive.buffer.bytes = 32768 ssl.truststore.type = JKS retries = 0 ssl.truststore.location = null ssl.keystore.password = null send.buffer.bytes = 131072 compression.type = none metadata.fetch.timeout.ms = 60000 retry.backoff.ms = 100 sasl.kerberos.kinit.cmd = /usr/bin/kinit buffer.memory = 33554432 timeout.ms = 30000 key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 ssl.trustmanager.algorithm = PKIX block.on.buffer.full = false ssl.key.password = null sasl.kerberos.min.time.before.relogin = 60000 connections.max.idle.ms = 540000 max.in.flight.requests.per.connection = 5 metrics.num.samples = 2 ssl.protocol = TLS ssl.provider = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] batch.size = 16384 ssl.keystore.location = null ssl.cipher.suites = null security.protocol = PLAINTEXT max.request.size = 1048576 value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer ssl.keymanager.algorithm = SunX509 metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner linger.ms = 100 [AppInfoParser] - Kafka version : 0.10.0.0-SNAPSHOT [AppInfoParser] - Kafka commitId : cceaaf9eee0f52af [StreamThread] - Creating consumer client for stream thread [StreamThread-1] [ConsumerConfig] - ConsumerConfig values: metric.reporters = [] metadata.max.age.ms = 300000 partition.assignment.strategy = [org.apache.kafka.streams.processor.internals.StreamPartitionAssignor] reconnect.backoff.ms = 50 sasl.kerberos.ticket.renew.window.factor = 0.8 max.partition.fetch.bytes = 1048576 bootstrap.servers = [localhost:9092] ssl.keystore.type = JKS enable.auto.commit = false sasl.mechanism = GSSAPI interceptor.classes = null exclude.internal.topics = true ssl.truststore.password = null client.id = lawrence-streams-wordcount-1-StreamThread-1-consumer ssl.endpoint.identification.algorithm = null max.poll.records = 2147483647 check.crcs = true request.timeout.ms = 40000 heartbeat.interval.ms = 3000 auto.commit.interval.ms = 5000 receive.buffer.bytes = 65536 ssl.truststore.type = JKS ssl.truststore.location = null ssl.keystore.password = null fetch.min.bytes = 1 send.buffer.bytes = 131072 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer group.id = lawrence-streams-wordcount retry.backoff.ms = 100 sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 ssl.trustmanager.algorithm = PKIX ssl.key.password = null fetch.max.wait.ms = 500 sasl.kerberos.min.time.before.relogin = 60000 connections.max.idle.ms = 540000 session.timeout.ms = 30000 metrics.num.samples = 2 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer ssl.protocol = TLS ssl.provider = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.keystore.location = null ssl.cipher.suites = null security.protocol = PLAINTEXT ssl.keymanager.algorithm = SunX509 metrics.sample.window.ms = 30000 auto.offset.reset = earliest [ZkEventThread] - Starting ZkClient event thread. [ZooKeeper] - Client environment:zookeeper.version=3.4.3-1240972, built on 02/06/2012 10:48 GMT [ZooKeeper] - Client environment:host.name=172.20.50.203 [ZooKeeper] - Client environment:java.version=1.8.0_25 [ZooKeeper] - Client environment:java.vendor=Oracle Corporation [ZooKeeper] - Client environment:java.home=/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre [ZooKeeper] - Client environment:java.class.path=/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/lib/tools.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_25.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Users/lweikum/COMPANY/POCStreams/out/production/lawrenceExample:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-streams-0.10.0.0-SNAPSHOT.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-clients-0.10.0.0-SNAPSHOT.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-tools-0.10.0.0-SNAPSHOT.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/slf4j-api-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/zookeeper-3.4.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/zkclient-0.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/netty-3.2.2.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/jline-0.9.94.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/common-utils-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/common-metrics-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/confluent-common/common-config-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aopalliance-repackaged-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/argparse4j-0.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-autoscaling-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudformation-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudfront-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudsearch-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudtrail-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudwatch-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cloudwatchmetrics-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cognitoidentity-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-cognitosync-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-core-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-datapipeline-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-directconnect-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-dynamodb-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-ec2-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-elasticache-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-elasticbeanstalk-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-elasticloadbalancing-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-elastictranscoder-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-emr-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-glacier-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-iam-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-importexport-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-kinesis-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-logs-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-opsworks-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-rds-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-redshift-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-route53-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-s3-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-ses-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-simpledb-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-simpleworkflow-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-sns-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-sqs-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-storagegateway-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-sts-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-support-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/aws-java-sdk-swf-libraries-1.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-beanutils-1.8.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-codec-1.9.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-collections-3.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-compress-1.9.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-digester-1.8.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-lang3-3.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-logging-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/commons-validator-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/connect-api-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/connect-file-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/connect-json-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/connect-runtime-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/hk2-api-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/hk2-locator-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/hk2-utils-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/httpclient-4.5.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/httpcore-4.4.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/httpmime-4.5.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-annotations-2.3.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-annotations-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-core-2.3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-core-2.6.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-databind-2.3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-databind-2.6.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-jaxrs-base-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-jaxrs-json-provider-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jackson-module-jaxb-annotations-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javassist-3.18.1-GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.annotation-api-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.inject-1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.inject-2.4.0-b31.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.servlet-api-3.1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/javax.ws.rs-api-2.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-client-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-common-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-container-servlet-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-container-servlet-core-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-guava-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-media-jaxb-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jersey-server-2.22.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-http-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-io-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-security-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-server-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-servlet-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jetty-util-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jline-0.9.94.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/joda-time-2.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/jopt-simple-3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/junit-3.8.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-clients-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-log4j-appender-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-streams-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-streams-examples-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka-tools-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka_2.11-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/kafka_2.11-0.9.1.0-cp1-test.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/lz4-1.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/metrics-core-2.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/netty-3.7.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/osgi-resource-locator-1.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/rocksdbjni-4.1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/scala-library-2.11.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/scala-parser-combinators_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/scala-xml_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/slf4j-api-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/snappy-java-1.1.1.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/support-metrics-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/support-metrics-common-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/support-metrics-fullcollector-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/validation-api-1.1.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/zkclient-0.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka/zookeeper-3.4.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/kafka-avro-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/kafka-connect-avro-converter-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/kafka-json-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/slf4j-api-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/snappy-java-1.0.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-serde-tools/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/activation-1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/jline-0.9.94.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/jopt-simple-3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-avro-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-clients-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-json-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-rest-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/kafka_2.11-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/log4j-1.2.15.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/lz4-1.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/mail-1.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/metrics-core-2.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/netty-3.7.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/scala-library-2.11.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/scala-parser-combinators_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/scala-xml_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/slf4j-api-1.6.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/snappy-java-1.1.1.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/zkclient-0.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-rest/zookeeper-3.4.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-jdbc/kafka-connect-jdbc-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-jdbc/postgresql-9.4-1206-jdbc41.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-jdbc/sqlite-jdbc-3.8.11.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/ant-1.9.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/ant-launcher-1.9.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/antlr-2.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/antlr-runtime-3.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/aopalliance-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/apache-log4j-extras-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/apacheds-i18n-2.0.0-M15.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/apacheds-kerberos-codec-2.0.0-M15.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/api-asn1-api-1.0.0-M20.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/api-util-1.0.0-M20.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/avro-ipc-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/avro-ipc-1.7.7-tests.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/avro-mapred-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/bonecp-0.8.0.RELEASE.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/calcite-avatica-1.2.0-incubating.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/calcite-core-1.2.0-incubating.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/calcite-linq4j-1.2.0-incubating.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-beanutils-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-beanutils-core-1.8.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-cli-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-codec-1.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-collections-3.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-compiler-2.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-configuration-1.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-dbcp-1.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-digester-1.8.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-httpclient-3.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-io-2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-lang-2.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-logging-1.1.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-math3-3.1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-net-3.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/commons-pool-1.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/curator-client-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/curator-framework-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/curator-recipes-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/datanucleus-api-jdo-3.2.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/datanucleus-core-3.2.10.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/datanucleus-rdbms-3.2.9.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/derby-10.10.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/eigenbase-properties-1.1.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/groovy-all-2.1.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/gson-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/guava-14.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/guice-3.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/guice-servlet-3.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-annotations-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-auth-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-common-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-hdfs-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-app-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-common-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-core-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-jobclient-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-mapreduce-client-shuffle-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-api-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-client-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-common-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-server-applicationhistoryservice-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-server-common-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-server-resourcemanager-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hadoop-yarn-server-web-proxy-2.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-ant-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-cli-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-common-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-exec-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-hcatalog-core-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-metastore-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-serde-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-service-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-shims-0.20S-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-shims-0.23-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-shims-common-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/hive-shims-scheduler-1.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/htrace-core-3.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/httpclient-4.2.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/httpcore-4.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/ivy-2.4.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-jaxrs-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jackson-xc-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/janino-2.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/javax.inject-1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jaxb-api-2.2.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jdo-api-3.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jettison-1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jline-2.12.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/joda-time-1.6.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jpam-1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/json-20090211.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jsr305-1.3.9.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/jta-1.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/kafka-avro-serializer-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/kafka-connect-avro-converter-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/kafka-connect-hdfs-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/leveldbjni-all-1.8.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/libfb303-0.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/libthrift-0.9.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/log4j-1.2.16.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/netty-3.6.2.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/opencsv-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-avro-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-column-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-common-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-encoding-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-format-2.3.0-incubating.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-generator-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-hadoop-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-hadoop-bundle-1.6.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-hadoop-bundle-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/parquet-jackson-1.7.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/pentaho-aggdesigner-algorithm-5.1.5-jhyde.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/protobuf-java-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/servlet-api-2.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/slf4j-log4j12-1.7.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/ST4-4.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/stax-api-1.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/stax-api-1.0-2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/stringtemplate-3.2.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/velocity-1.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/xercesImpl-2.9.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/xml-apis-1.3.04.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/xmlenc-0.52.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-connect-hdfs/zookeeper-3.4.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/avro-ipc-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/avro-ipc-1.7.7-tests.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/avro-mapred-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/camus-api-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/camus-etl-kafka-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/camus-kafka-coders-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/camus-schema-registry-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/commons-cli-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/confluent-camus-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/gson-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/java-dogstatsd-client-2.0.8.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jetty-6.1.26.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/joda-time-1.6.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/jopt-simple-3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/kafka-clients-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/kafka_2.11-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/lz4-1.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/metrics-core-2.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/scala-library-2.11.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/scala-parser-combinators_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/scala-xml_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/servlet-api-2.5-20081211.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/slf4j-api-1.6.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/snappy-java-1.0.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/velocity-1.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/zkclient-0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/zkclient-0.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/camus/zookeeper-3.3.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/aopalliance-repackaged-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/asm-debug-all-5.0.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/classmate-1.0.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hamcrest-core-1.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hibernate-validator-5.1.2.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hk2-api-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hk2-locator-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/hk2-utils-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-annotations-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-jaxrs-base-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-jaxrs-json-provider-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jackson-module-jaxb-annotations-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javassist-3.18.1-GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.annotation-api-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.el-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.el-api-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.inject-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.servlet-api-3.1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/javax.ws.rs-api-2.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jboss-logging-3.1.3.GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-bean-validation-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-client-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-common-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-container-jetty-http-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-container-servlet-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-container-servlet-core-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-guava-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-media-jaxb-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-server-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-test-framework-core-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jersey-test-framework-provider-jetty-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-continuation-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-http-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-io-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-security-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-server-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-servlet-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-servlets-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/jetty-util-9.2.12.v20150709.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/junit-4.12.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/osgi-resource-locator-1.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/rest-utils-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/rest-utils-examples-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/rest-utils-test-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/rest-utils/validation-api-1.1.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/aopalliance-repackaged-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/avro-1.7.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/classmate-1.0.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/commons-compress-1.4.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/hibernate-validator-5.1.2.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/hk2-api-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/hk2-locator-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/hk2-utils-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-annotations-2.5.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-core-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-core-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-databind-2.5.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jackson-mapper-asl-1.9.13.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javassist-3.18.1-GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.annotation-api-1.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.el-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.el-api-2.2.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.inject-2.4.0-b25.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/javax.ws.rs-api-2.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jboss-logging-3.1.3.GA.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-bean-validation-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-client-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-common-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-guava-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-media-jaxb-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jersey-server-2.19.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jline-0.9.94.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/jopt-simple-3.2.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/kafka-clients-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/kafka-schema-registry-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/kafka-schema-registry-client-2.1.0-alpha1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/kafka_2.11-0.9.1.0-cp1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/log4j-1.2.17.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/lz4-1.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/metrics-core-2.2.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/netty-3.7.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/osgi-resource-locator-1.0.1.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/paranamer-2.3.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/scala-library-2.11.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/scala-parser-combinators_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/scala-xml_2.11-1.0.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/slf4j-api-1.6.4.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/slf4j-log4j12-1.7.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/snappy-java-1.0.5.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/validation-api-1.1.0.Final.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/xz-1.0.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/zkclient-0.7.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/schema-registry/zookeeper-3.4.6.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/connect-0.10.0.0-SNAPSHOT.jar:/Users/lweikum/COMPANY/POCStreams/lawrenceExample/lib/kafka-0.10.0.0-SNAPSHOT.jar:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar [ZooKeeper] - Client environment:java.library.path=/Users/lweikum/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:. [ZooKeeper] - Client environment:java.io.tmpdir=/var/folders/44/brpv47jx14q_10pcxpp02d2000042h/T/ [ZooKeeper] - Client environment:java.compiler=<NA> [ZooKeeper] - Client environment:os.name=Mac OS X [ZooKeeper] - Client environment:os.arch=x86_64 [ZooKeeper] - Client environment:os.version=10.10.5 [ZooKeeper] - Client environment:user.name=lweikum [ZooKeeper] - Client environment:user.home=/Users/lweikum [ZooKeeper] - Client environment:user.dir=/Users/lweikum/COMPANY/POCStreams [ZooKeeper] - Initiating client connection, connectString=localhost:2181 sessionTimeout=30000 watcher=org.I0Itec.zkclient.ZkClient@1fa268de [ClientCnxn] - Opening socket connection to server /127.0.0.1:2181 [ZooKeeperSaslClient] - Client will not SASL-authenticate because the default JAAS configuration section 'Client' could not be found. If you are not using SASL, you may ignore this. On the other hand, if you expected SASL to work, please fix your JAAS configuration. [ClientCnxn] - Socket connection established to localhost/127.0.0.1:2181, initiating session [ClientCnxn] - Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x154c4b8ef12002e, negotiated timeout = 30000 [ZkClient] - zookeeper state changed (SyncConnected) [ConsumerConfig] - ConsumerConfig values: metric.reporters = [] metadata.max.age.ms = 300000 partition.assignment.strategy = [org.apache.kafka.streams.processor.internals.StreamPartitionAssignor] reconnect.backoff.ms = 50 sasl.kerberos.ticket.renew.window.factor = 0.8 max.partition.fetch.bytes = 1048576 bootstrap.servers = [localhost:9092] ssl.keystore.type = JKS enable.auto.commit = false sasl.mechanism = GSSAPI interceptor.classes = null exclude.internal.topics = true ssl.truststore.password = null client.id = lawrence-streams-wordcount-1-StreamThread-1-consumer ssl.endpoint.identification.algorithm = null max.poll.records = 2147483647 check.crcs = true request.timeout.ms = 40000 heartbeat.interval.ms = 3000 auto.commit.interval.ms = 5000 receive.buffer.bytes = 65536 ssl.truststore.type = JKS ssl.truststore.location = null ssl.keystore.password = null fetch.min.bytes = 1 send.buffer.bytes = 131072 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer group.id = lawrence-streams-wordcount retry.backoff.ms = 100 sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 ssl.trustmanager.algorithm = PKIX ssl.key.password = null fetch.max.wait.ms = 500 sasl.kerberos.min.time.before.relogin = 60000 connections.max.idle.ms = 540000 session.timeout.ms = 30000 metrics.num.samples = 2 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer ssl.protocol = TLS ssl.provider = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.keystore.location = null ssl.cipher.suites = null security.protocol = PLAINTEXT ssl.keymanager.algorithm = SunX509 metrics.sample.window.ms = 30000 auto.offset.reset = earliest [ConsumerConfig] - The configuration replication.factor = 1 was supplied but isn't a known config. [ConsumerConfig] - The configuration num.standby.replicas = 0 was supplied but isn't a known config. [ConsumerConfig] - The configuration zookeeper.connect = localhost:2181 was supplied but isn't a known config. [ConsumerConfig] - The configuration __stream.thread.instance__ = Thread[StreamThread-1,5,main] was supplied but isn't a known config. [AppInfoParser] - Kafka version : 0.10.0.0-SNAPSHOT [AppInfoParser] - Kafka commitId : cceaaf9eee0f52af [StreamThread] - Creating restore consumer client for stream thread [StreamThread-1] [ConsumerConfig] - ConsumerConfig values: metric.reporters = [] metadata.max.age.ms = 300000 partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor] reconnect.backoff.ms = 50 sasl.kerberos.ticket.renew.window.factor = 0.8 max.partition.fetch.bytes = 1048576 bootstrap.servers = [localhost:9092] ssl.keystore.type = JKS enable.auto.commit = false sasl.mechanism = GSSAPI interceptor.classes = null exclude.internal.topics = true ssl.truststore.password = null client.id = lawrence-streams-wordcount-1-StreamThread-1-restore-consumer ssl.endpoint.identification.algorithm = null max.poll.records = 2147483647 check.crcs = true request.timeout.ms = 40000 heartbeat.interval.ms = 3000 auto.commit.interval.ms = 5000 receive.buffer.bytes = 65536 ssl.truststore.type = JKS ssl.truststore.location = null ssl.keystore.password = null fetch.min.bytes = 1 send.buffer.bytes = 131072 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer group.id = retry.backoff.ms = 100 sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 ssl.trustmanager.algorithm = PKIX ssl.key.password = null fetch.max.wait.ms = 500 sasl.kerberos.min.time.before.relogin = 60000 connections.max.idle.ms = 540000 session.timeout.ms = 30000 metrics.num.samples = 2 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer ssl.protocol = TLS ssl.provider = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.keystore.location = null ssl.cipher.suites = null security.protocol = PLAINTEXT ssl.keymanager.algorithm = SunX509 metrics.sample.window.ms = 30000 auto.offset.reset = earliest [ConsumerConfig] - ConsumerConfig values: metric.reporters = [] metadata.max.age.ms = 300000 partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor] reconnect.backoff.ms = 50 sasl.kerberos.ticket.renew.window.factor = 0.8 max.partition.fetch.bytes = 1048576 bootstrap.servers = [localhost:9092] ssl.keystore.type = JKS enable.auto.commit = false sasl.mechanism = GSSAPI interceptor.classes = null exclude.internal.topics = true ssl.truststore.password = null client.id = lawrence-streams-wordcount-1-StreamThread-1-restore-consumer ssl.endpoint.identification.algorithm = null max.poll.records = 2147483647 check.crcs = true request.timeout.ms = 40000 heartbeat.interval.ms = 3000 auto.commit.interval.ms = 5000 receive.buffer.bytes = 65536 ssl.truststore.type = JKS ssl.truststore.location = null ssl.keystore.password = null fetch.min.bytes = 1 send.buffer.bytes = 131072 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer group.id = retry.backoff.ms = 100 sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 ssl.trustmanager.algorithm = PKIX ssl.key.password = null fetch.max.wait.ms = 500 sasl.kerberos.min.time.before.relogin = 60000 connections.max.idle.ms = 540000 session.timeout.ms = 30000 metrics.num.samples = 2 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer ssl.protocol = TLS ssl.provider = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.keystore.location = null ssl.cipher.suites = null security.protocol = PLAINTEXT ssl.keymanager.algorithm = SunX509 metrics.sample.window.ms = 30000 auto.offset.reset = earliest [AppInfoParser] - Kafka version : 0.10.0.0-SNAPSHOT [AppInfoParser] - Kafka commitId : cceaaf9eee0f52af [KafkaStreams] - Started Kafka Stream process [StreamThread] - Starting stream thread [StreamThread-1] [StreamThread] - Shutting down stream thread [StreamThread-1] [KafkaProducer] - Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. [StreamThread] - Stream thread shutdown complete [StreamThread-1] Exception in thread "StreamThread-1" org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'topic_metadata': Error reading array of size 1731681, only 54 bytes available at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:75) at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:380) at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:449) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:269) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:179) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:973) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:937) at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:295) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218) Process finished with exit code 0
