Re: csv files to kafka

Hi Joe, I am cloned this repo with git clone https://github.com/stealthly/f2k.git cd f2k when I run . #./gradlew clean fatJar the error is "Execution failed for task ':compileProto'." when I run with --debug option it gives the info Gradle user home: /root/.gradle Current dir: /root/f2k java

NPE in debug logging statement in kafka new producer

Hi While I am testing kafka java producer, I saw the following NPE SLF4J: Failed toString() invocation on an object of type [org.apache.kafka.common.Cluster] java.lang.NullPointerException at org.apache.kafka.common.PartitionInfo.toString(PartitionInfo.java:72) at java.lang.String.valueOf(String.