[
https://issues.apache.org/jira/browse/STORM-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David DeMar updated STORM-3175:
-------------------------------
Description: 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}. (was: 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}.)
> 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
> Priority: Minor
> Labels: newbie
>
> 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}.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
