You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@storm.apache.org by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2018/08/06 13:54:00 UTC

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

     [ https://issues.apache.org/jira/browse/STORM-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stig Rohde Døssing reassigned STORM-3175:
-----------------------------------------

    Assignee: David DeMar

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