Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-3175

Use custom Callback in KafkaBolt

    XMLWordPrintableJSON

    Details

      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 KafkaProducer.send().

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dfdemar David DeMar
                Reporter:
                dfdemar David DeMar
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 4.5h
                  4.5h