Skip to content
This repository has been archived by the owner on Jan 24, 2024. It is now read-only.

Fix KoP will cause Kafka Errors.REQUEST_TIMED_OUT when consume multi TopicPartition in one consumer request #654

Merged
merged 9 commits into from
Aug 16, 2021
Merged

Fix KoP will cause Kafka Errors.REQUEST_TIMED_OUT when consume multi TopicPartition in one consumer request #654

merged 9 commits into from
Aug 16, 2021

Commits on Aug 14, 2021

  1. Fix when consume multi TopicPartition in one request, in MessageFetch… 

    …Context.handleFetch(), tryComplete() may enter race condition

When one topicPartition removed from responseData, maybe removed again, which will cause Errors.REQUEST_TIMED_OUT
    wenbing1 committed Aug 14, 2021
    Configuration menu
    Copy the full SHA
    ea67c6c View commit details
    Browse the repository at this point in the history

Commits on Aug 15, 2021

  1. add License to Test file

    @wenbingshen
    wenbingshen committed Aug 15, 2021
    Configuration menu
    Copy the full SHA
    4be1295 View commit details
    Browse the repository at this point in the history

  2. fix MessageFetchContextTest.testHandleFetchUnSafe flaky test

    @wenbingshen
    wenbingshen committed Aug 15, 2021
    Configuration menu
    Copy the full SHA
    44fd7dd View commit details
    Browse the repository at this point in the history

  3. replace JUnit with TestNG and address reviewer's comment

    @wenbingshen
    wenbingshen committed Aug 15, 2021
    Configuration menu
    Copy the full SHA
    e01c8f3 View commit details
    Browse the repository at this point in the history

  4. fix License check error

    @wenbingshen
    wenbingshen committed Aug 15, 2021
    Configuration menu
    Copy the full SHA
    4b04f77 View commit details
    Browse the repository at this point in the history

Commits on Aug 16, 2021

  1. fix responseData null point exception & replace synchronized with Ato… 

    …micBoolean to avoid thread blocking & fix test failed
    @wenbingshen
    wenbingshen committed Aug 16, 2021
    Configuration menu
    Copy the full SHA
    3c2abc7 View commit details
    Browse the repository at this point in the history

  2. replace responseData with resultFuture to judge the null pointer exce… 

    …ption
    @wenbingshen
    wenbingshen committed Aug 16, 2021
    Configuration menu
    Copy the full SHA
    29b179d View commit details
    Browse the repository at this point in the history

  3. set if statements combined

    @wenbingshen
    wenbingshen committed Aug 16, 2021
    Configuration menu
    Copy the full SHA
    a828031 View commit details
    Browse the repository at this point in the history

  4. Simplify the MessageFetchContextTest

    @wenbingshen
    wenbingshen committed Aug 16, 2021
    Configuration menu
    Copy the full SHA
    ace004a View commit details
    Browse the repository at this point in the history