[GitHub] storm pull request #2790: STORM-3175 - Allow usage of custom Callback.

[srdo]

Github user srdo commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2790#discussion_r207511238
  
    --- 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 --
    
    I think we need to define our own interface for this. Callback isn't 
serializable, so Storm won't be able to transfer it from the Nimbus submitter 
to the worker JVM.


---