Github user dfdemar commented on a diff in the pull request:
https://github.com/apache/storm/pull/2790#discussion_r207537361
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/KafkaBolt.java
---
@@ -62,6 +62,7 @@
private OutputCollector collector;
private TupleToKafkaMapper<K,V> mapper;
private KafkaTopicSelector topicSelector;
+ private Callback providedCallback;
--- End diff --
Ah, good point. The workaround I was using prior to this was all done after
serialization so this wasn't something I had to worry about. Let me think about
what that interface should look like and I'll come up with something.
---
