[
https://issues.apache.org/jira/browse/STORM-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570262#comment-16570262
]
Stig Rohde Døssing commented on STORM-3175:
-------------------------------------------
Go ahead and reuse this ticket, that way it'll be obvious to readers of the
changelog that we aren't fixing two separate issues.
The reason we can't use lambdas in 1.x is that it needs to be Java 7
compatible. The easiest way for you to get the changes over into 1.x is
probably to check out 1.x-branch locally, and use git cherry-pick to get your
changes in, then adjust so the code works on Java 7.
> Use custom Callback in KafkaBolt
> --------------------------------
>
> Key: STORM-3175
> URL: https://issues.apache.org/jira/browse/STORM-3175
> Project: Apache Storm
> Issue Type: New Feature
> Components: storm-kafka-client
> Reporter: David DeMar
> Assignee: David DeMar
> Priority: Minor
> Labels: newbie, pull-request-available
> Fix For: 2.0.0
>
> Time Spent: 3.5h
> Remaining Estimate: 0h
>
> Currently {{KafkaBolt}} completely encapsulates its {{KafkaProducer}} so
> there's no way to inject a custom Callback when sending a message to Kafka.
> This change will add a method that allows the injection of a Callback
> function that will be passed into
> {color:#333333}{{KafkaProducer.send()}}{color}.
> The reasoning behind this change is to expose any exceptions that occur
> during Kafka publishing so they can be logged and have metrics built around
> them. This would provide more customized ways we could build alerting around
> Kafka publishing failures.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
