[
https://issues.apache.org/jira/browse/STORM-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570255#comment-16570255
]
David DeMar commented on STORM-3175:
------------------------------------
Thanks for your help with this, [~Srdo].
Didn't realize that about the lambdas. Do I just paste over the same code in a
new PR, minus the lambdas? Should I reference this ticket or create a new one?
> 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)
