Support for topics+streams at class WildcardStreamsHandler

Hi guys, i have seen that if create a message stream by using: createMessageStreams I can define a map with Topic->#Streams Is there a reason why createMessageStreamsByFilter us not giving the same support? I have only a TopicFilter and numStreams interface such as: public List> createMessageSt

Exception management in kafka async producer

Hi guys, i was wondering what will be the best way to provide delivery guarantee service by using an async producer in kafka 0.7.2. I want my service to be ready to support kafka downtimes for at least 12 hours so i would like to aggregate logs locally into some failover spool and then rerun them w