Kai Wang
Kai Wang
**Describe the solution you'd like** Use `Crc32cLongChecksum` from `bookkeeper`, instead of `Crc32C.compute`. the `Crc32cLongChecksum` uses SSE 4.2 to optimize the CRC32C algorithm, it might have 6 times better performance.
### Task list - [ ] Upgrade Kafka dependency to 2.8.x - [ ] Support producer fence
`DistributedClusterTest` is flaky. The `cleanup` test method fails sporadically. [example failure](https://github.com/streamnative/kop/runs/3764772073?check_suite_focus=true#step:5:234) ``` Error: Tests run: 8, Failures: 1, Errors: 0, Skipped: 4, Time elapsed: 58.51 s
`BasicEndToEndKafkaTest` is flaky. The `testDeleteClosedTopics` test method fails sporadically. [example failure](https://github.com/streamnative/kop/actions/runs/3133699365/jobs/5087371106#step:13:113) ``` [INFO] Running io.streamnative.pulsar.handlers.kop.BasicEndToEndKafkaTest Error: Tests run: 13, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 28.796 s
### Motivation Currently, the table view only supports persistent topics with read compacted. However, some data don't require persistent storage, like load data in PIP-192 [#16691](https://github.com/apache/pulsar/issues/16691). We need to support...
(cherry picked from commit https://github.com/streamnative/kop/commit/10f28dfcd190412c28785b29e01beeeb47be085e) ### Motivation broker to broker hostname verification ### Documentation Check the box below. Need to update docs? - [ ] `doc-required` (If you need help...
`MultiLedgerTest` is flaky. The `testListOffsetForEmptyRolloverLedger` test method fails sporadically. [example failure](https://github.com/streamnative/kop/actions/runs/3289289774/jobs/5420643729#step:13:110) ``` Error: Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 20.967 s
### Motivation When users disable the `KafkaEnableMultiTenantMetadata`, we should use the config's metadata tenant as the `PulsarTopicProducerStateManagerSnapshotBuffer` topic tenant. ### Modifications Use the config's metadata tenant when disable multi-tenant metadata...