Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1019

reopen a Kafka system producer if send() method is called again

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.11.0
    • None
    • None
    • None

    Description

      Normally, when a kafka system producer runs into an issue during a send() call and throws an exception, it causes the container to shutdown.
      But if the client issues another producer.send(), after the producer has thrown an exception, it means that the user caught the exception and decided to continue. So we will reopen the producer.

      Attachments

        1. SAMZA-1019.0.patch
          3 kB
          Xinyu Liu
        2. SAMZA-1019.1.patch
          4 kB
          Boris Shkolnik

        Activity

          People

            boryas Boris Shkolnik
            boryas Boris Shkolnik
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: