Details

      Description

      At Kafka WIH executeWorkItem, there are 2 nested try-catch blocks, that are not strictly needed, and currently if there is an exception in the producer (inner catch) there is no invocation to handleException method.

      {{producer.send }}call is asynchronous and returns a Future<MetadataRecord>: therefore, to complete the workitem, it's needed to wait for the result.

      Besides, results map in the failure case is never sent (no completeWorkitem call) and for the sunny scenario, it doesn't add any meaningful information.

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                gonzalomf Gonzalo Muñoz Fernández
                Reporter:
                gonzalomf Gonzalo Muñoz Fernández
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: