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)