[
https://issues.apache.org/jira/browse/STORM-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15290073#comment-15290073
]
Narendra Bidari commented on STORM-1765:
----------------------------------------
[~sriharsha] : Thanks I was able to get it working, the problem was I was using
storm 0.10 (Storm-kafka ) which was having old Producer, I used Storm 1.0 and
it is working fine.
> KafkaBolt with new producer api should be part of storm-kaka-client
> -------------------------------------------------------------------
>
> Key: STORM-1765
> URL: https://issues.apache.org/jira/browse/STORM-1765
> Project: Apache Storm
> Issue Type: Bug
> Reporter: Sriharsha Chintalapani
> Assignee: Hugo Louro
>
> During the discussion of storm-kaka-client we agreed on following
> "We talked about this some more and it seems to me it would make more sense
> to leave this new spout in storm-kafka-client (or whatever you want to call
> it) and move the KafkaBolt which uses the new producer api over here also.
> That way this component only needs to depend on the new kafka-clients java
> api and not on the entire scala kafka core. We can make the old storm-kafka
> depend on this component so it still picks up the bolt so if anyone is using
> that its still works. We can deprecate the old KafkaSpout but keep it around
> for people using older versions of Kafka - tgravescs"
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)