Github user ptgoetz commented on a diff in the pull request:
https://github.com/apache/storm/pull/1711#discussion_r80280538
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/ByteKeyValueScheme.java ---
@@ -0,0 +1,33 @@
+package org.apache.storm.kafka;
--- End
GitHub user asmaier opened a pull request:
https://github.com/apache/storm/pull/1711
Added ByteKeyValueScheme class.
It is a common use case to send and receive byte key and values via Kafka.
Unfortunately the storm-kafka package misses support for this. So I added a
