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

[FEATURE] Add fetch down converted when entryFormat=kafka #660

Merged
merged 20 commits into from
Aug 19, 2021
Merged

[FEATURE] Add fetch down converted when entryFormat=kafka #660

merged 20 commits into from
Aug 19, 2021

Commits on Aug 17, 2021

  1. Simple test commit

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

  2. add kafka 010 module

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

Commits on Aug 18, 2021

  1. Merge remote-tracking branch 'kop/master' into addFetchDownConverted

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

  2. update test to verify that the high-version Kafka consumer reads the … 

    …records written by the low-version producer with magic=1
    @wenbingshen
    wenbingshen committed Aug 18, 2021
    Configuration menu
    Copy the full SHA
    8dac3ae View commit details
    Browse the repository at this point in the history

  3. fix checkstyle error

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

  4. check record corrupt

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

  5. add check down converted

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

  6. fix BasicEndToEndPulsarTest failed

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

  7. fix BasicEndToEndPulsarTest failed

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

  8. fix test failed

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

  9. fix test failed

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

  10. fix test failed

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

  11. add log

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

  12. When magic is less than 2, non-empty headers cannot be appendWithOffs… 

    …et to MemoryRecordsBuilder
    @wenbingshen
    wenbingshen committed Aug 18, 2021
    Configuration menu
    Copy the full SHA
    7e0c0b6 View commit details
    Browse the repository at this point in the history

  13. Fix the error of verification record when high version kafka consumer… 

    …s read low version magic, and support the down conversion when low version consumer client reads high version magic data
    @wenbingshen
    wenbingshen committed Aug 18, 2021
    Configuration menu
    Copy the full SHA
    e668bb4 View commit details
    Browse the repository at this point in the history

  14. Merge remote-tracking branch 'kop/master' into addFetchDownConverted

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

  15. fix error append offset

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

Commits on Aug 19, 2021

  1. move the block of convertedRecords != null into batchMagic > magic block

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

  2. catch KafkaException to release entry

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

  3. fix checkstyle error

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