Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8040

Streams needs to handle timeout in initTransactions

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • 2.0.0, 2.0.1, 2.1.0, 2.2.0, 2.1.1
    • 2.2.0, 2.0.2, 2.1.2
    • streams
    • None

    Description

      Following on KAFKA-6446, Streams needs to handle the new behavior.

      `initTxn` can throw TimeoutException now: default `MAX_BLOCK_MS_CONFIG` in producer is 60 seconds, so I (Guozhang Wang) think just wrapping it as StreamsException should be reasonable, similar to what we do for `producer#send`'s TimeoutException (https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java#L220-L225 ).

       

      Attachments

        Issue Links

        is a clone of

        Improvement - An improvement or enhancement to an existing feature or task. KAFKA-7932 Streams needs to handle new Producer exceptions

        • Critical - Crashes, loss of data, severe memory leak.
        • Resolved
        is related to

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-6446 KafkaProducer with transactionId endless waits when bootstrap server is down

        • Critical - Crashes, loss of data, severe memory leak.
        • Resolved
        links to

        Web Link GitHub Pull Request #6372

        Web Link GitHub Pull Request #6396

        Web Link GitHub Pull Request #6416

        Activity
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            vvcephei John Roesler
            vvcephei John Roesler
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment