[
https://issues.apache.org/jira/browse/STORM-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stig Rohde Døssing resolved STORM-3175.
---------------------------------------
Resolution: Fixed
Fix Version/s: 2.0.0
Thanks [~dfdemar], merged to master. Since the code uses lambdas, we'll need a
second PR against 1.x-branch if you want this feature in the 1.x release line.
> Use custom Callback in KafkaBolt
> --------------------------------
>
> Key: STORM-3175
> URL: https://issues.apache.org/jira/browse/STORM-3175
> Project: Apache Storm
> Issue Type: Improvement
> Components: storm-kafka-client
> Reporter: David DeMar
> Assignee: David DeMar
> Priority: Minor
> Labels: newbie, pull-request-available
> Fix For: 2.0.0
>
> Time Spent: 3h 20m
> 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)
