[jira] [Created] (KAFKA-3970) Message Listener(that can hit callback registered)

["rajan verma (JIRA)" <ji...@apache.org>]

rajan verma created KAFKA-3970:
----------------------------------

             Summary: Message Listener(that can hit callback registered)
                 Key: KAFKA-3970
                 URL: https://issues.apache.org/jira/browse/KAFKA-3970
             Project: Kafka
          Issue Type: New Feature
            Reporter: rajan verma
            Priority: Minor


At my current project I am writing a Message Listener for kafka.

-Message listener can register a callable (domain url , headers, schema of domain end point)

-Initially wrote Message listener as java Callable later used akka Futures (as akka promises to scale well)

-Attaching classes that i am using in my current project.These are POC not production ready


Please review and let me know if this is a good idea as it looks promising 






--
This message was sent by Atlassian JIRA
(v6.3.4#6332)