[jira] [Commented] (STORM-3175) Use custom Callback in KafkaBolt

["David DeMar (JIRA)" <ji...@apache.org>]

    [ 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)