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

[FEATURE] Support kafka LogValidator validate inner records and compression codec when handle producer request with entryFormat=kafka #791

Merged
merged 37 commits into from
Oct 20, 2021
Merged

[FEATURE] Support kafka LogValidator validate inner records and compression codec when handle producer request with entryFormat=kafka #791

merged 37 commits into from
Oct 20, 2021

Commits on Oct 7, 2021

  1. Support kafka LogValidator validator inner records and compression co… 

    …dec when handle producer request
    @wenbingshen
    wenbingshen committed Oct 7, 2021
    Configuration menu
    Copy the full SHA
    5d08a6c View commit details
    Browse the repository at this point in the history

  2. only need to validate when entryFormat=kafka

    @wenbingshen
    wenbingshen committed Oct 7, 2021
    Configuration menu
    Copy the full SHA
    1ed687f View commit details
    Browse the repository at this point in the history

  3. add FieldContext doc

    @wenbingshen
    wenbingshen committed Oct 7, 2021
    Configuration menu
    Copy the full SHA
    af595ef View commit details
    Browse the repository at this point in the history

  4. add KopLogValidator

    @wenbingshen
    wenbingshen committed Oct 7, 2021
    Configuration menu
    Copy the full SHA
    f07f484 View commit details
    Browse the repository at this point in the history

  5. add LongRef and CompressionCodec

    @wenbingshen
    wenbingshen committed Oct 7, 2021
    Configuration menu
    Copy the full SHA
    6bb270d View commit details
    Browse the repository at this point in the history

  6. fix Codacy static code error

    @wenbingshen
    wenbingshen committed Oct 7, 2021
    Configuration menu
    Copy the full SHA
    5580cef View commit details
    Browse the repository at this point in the history

  7. fix checkstyle

    @wenbingshen
    wenbingshen committed Oct 7, 2021
    Configuration menu
    Copy the full SHA
    23545b0 View commit details
    Browse the repository at this point in the history

Commits on Oct 9, 2021

  1. merge master and resolve conflict

    @wenbingshen
    wenbingshen committed Oct 9, 2021
    Configuration menu
    Copy the full SHA
    4395153 View commit details
    Browse the repository at this point in the history

  2. Update kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/K… 

    …afkaServiceConfiguration.java

Co-authored-by: Yunze Xu <xyzinfernity@163.com>
    @wenbingshen @BewareMyPower
    wenbingshen and BewareMyPower authored Oct 9, 2021
    Configuration menu
    Copy the full SHA
    1453cbc View commit details
    Browse the repository at this point in the history

Commits on Oct 10, 2021

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

    @wenbingshen
    wenbingshen committed Oct 10, 2021
    Configuration menu
    Copy the full SHA
    015d174 View commit details
    Browse the repository at this point in the history

  2. move validateMessagesAndAssignOffsets call to KafkaEntryFormatter#encode

    @wenbingshen
    wenbingshen committed Oct 10, 2021
    Configuration menu
    Copy the full SHA
    e232f17 View commit details
    Browse the repository at this point in the history

  3. add test for LongRef and CompressionCodec

    @wenbingshen
    wenbingshen committed Oct 10, 2021
    Configuration menu
    Copy the full SHA
    75d6cc2 View commit details
    Browse the repository at this point in the history

Commits on Oct 11, 2021

  1. add MixedKafkaEntryFormatter support 0.10.x kafka clients

    @wenbingshen
    wenbingshen committed Oct 11, 2021
    Configuration menu
    Copy the full SHA
    9a1362c View commit details
    Browse the repository at this point in the history

  2. fix checkstyle error

    @wenbingshen
    wenbingshen committed Oct 11, 2021
    Configuration menu
    Copy the full SHA
    6365176 View commit details
    Browse the repository at this point in the history

Commits on Oct 12, 2021

  1. Update kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/f… 

    …ormat/MixedKafkaEntryFormatter.java

Co-authored-by: Kai Wang <kwang@streamnative.io>
    @wenbingshen @Demogorgon314
    wenbingshen and Demogorgon314 authored Oct 12, 2021
    Configuration menu
    Copy the full SHA
    1010d01 View commit details
    Browse the repository at this point in the history

  2. Update kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/f… 

    …ormat/MixedKafkaEntryFormatter.java

Co-authored-by: Kai Wang <kwang@streamnative.io>
    @wenbingshen @Demogorgon314
    wenbingshen and Demogorgon314 authored Oct 12, 2021
    Configuration menu
    Copy the full SHA
    a267fb3 View commit details
    Browse the repository at this point in the history

  3. Update kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/u… 

    …tils/KopLogValidator.java

Co-authored-by: Kai Wang <kwang@streamnative.io>
    @wenbingshen @Demogorgon314
    wenbingshen and Demogorgon314 authored Oct 12, 2021
    Configuration menu
    Copy the full SHA
    98456a5 View commit details
    Browse the repository at this point in the history

  4. Merge remote-tracking branch 'kop/master' into addLogValidator

    @wenbingshen
    wenbingshen committed Oct 12, 2021
    Configuration menu
    Copy the full SHA
    ebe03bf View commit details
    Browse the repository at this point in the history

  5. addressed reviewer's comments

    @wenbingshen
    wenbingshen committed Oct 12, 2021
    Configuration menu
    Copy the full SHA
    8e1350e View commit details
    Browse the repository at this point in the history

  6. remove unnecessary AtomicReference

    @wenbingshen
    wenbingshen committed Oct 12, 2021
    Configuration menu
    Copy the full SHA
    41f513c View commit details
    Browse the repository at this point in the history

  7. Update docs/configuration.md 

    Co-authored-by: Huanli Meng <48120384+Huanli-Meng@users.noreply.github.com>
    @wenbingshen @Huanli-Meng
    wenbingshen and Huanli-Meng authored Oct 12, 2021
    Configuration menu
    Copy the full SHA
    5713a66 View commit details
    Browse the repository at this point in the history

  8. Merge remote-tracking branch 'kop/master' into addLogValidator

    @wenbingshen
    wenbingshen committed Oct 12, 2021
    Configuration menu
    Copy the full SHA
    f0ff60b View commit details
    Browse the repository at this point in the history

  9. Merge branch 'addLogValidator' of https://github.com/wenbingshen/kop … 

    …into addLogValidator
    @wenbingshen
    wenbingshen committed Oct 12, 2021
    Configuration menu
    Copy the full SHA
    d06ca93 View commit details
    Browse the repository at this point in the history

Commits on Oct 13, 2021

  1. Update docs/configuration.md 

    Co-authored-by: Huanli Meng <48120384+Huanli-Meng@users.noreply.github.com>
    @wenbingshen @Huanli-Meng
    wenbingshen and Huanli-Meng authored Oct 13, 2021
    Configuration menu
    Copy the full SHA
    9001b80 View commit details
    Browse the repository at this point in the history

Commits on Oct 14, 2021

  1. Merge remote-tracking branch 'origin/addLogValidator' into addLogVali… 

    …dator
    @wenbingshen
    wenbingshen committed Oct 14, 2021
    Configuration menu
    Copy the full SHA
    38f6801 View commit details
    Browse the repository at this point in the history

  2. Merge remote-tracking branch 'kop/master' into addLogValidator

    @wenbingshen
    wenbingshen committed Oct 14, 2021
    Configuration menu
    Copy the full SHA
    5537fb1 View commit details
    Browse the repository at this point in the history

  3. rename KafkaEntryFormatter and add Recycler to encode/decode result

    @wenbingshen
    wenbingshen committed Oct 14, 2021
    Configuration menu
    Copy the full SHA
    0997a20 View commit details
    Browse the repository at this point in the history

  4. rename test class name

    @wenbingshen
    wenbingshen committed Oct 14, 2021
    Configuration menu
    Copy the full SHA
    12a9703 View commit details
    Browse the repository at this point in the history

  5. fix Codacy Static Code

    @wenbingshen
    wenbingshen committed Oct 14, 2021
    Configuration menu
    Copy the full SHA
    3f71139 View commit details
    Browse the repository at this point in the history

  6. Fix the number of repeated releases of byteBuf is greater than the re… 

    …ference count refCnt
    @wenbingshen
    wenbingshen committed Oct 14, 2021
    Configuration menu
    Copy the full SHA
    eb9e291 View commit details
    Browse the repository at this point in the history

Commits on Oct 15, 2021

  1. Addressed reviewer's comments

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

  2. Merge remote-tracking branch 'kop/master' into addLogValidator

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

  3. fix checkstyle and Codacy

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

  4. fix checkstyle

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

Commits on Oct 20, 2021

  1. Addressed comments

    @wenbingshen
    wenbingshen committed Oct 20, 2021
    Configuration menu
    Copy the full SHA
    4c955d5 View commit details
    Browse the repository at this point in the history

  2. Merge remote-tracking branch 'kop/master' into addLogValidator

    @wenbingshen
    wenbingshen committed Oct 20, 2021
    Configuration menu
    Copy the full SHA
    7f53e2b View commit details
    Browse the repository at this point in the history

  3. fix codacy static code

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