Yunze Xu

[BUG] Topic cannot be deleted after producing transactional messages

5

**Describe the bug** **To Reproduce** - Kafka Client: 3.1.0 - Pulsar: 2.10.0 - KoP: 2.10.1.1 KoP configs: ```properties messagingProtocols=kafka protocolHandlerDirectory=./protocols allowAutoTopicCreationType=partitioned kafkaListeners=PLAINTEXT://127.0.0.1:9092 brokerEntryMetadataInterceptors=org.apache.pulsar.common.intercept.AppendIndexMetadataInterceptor brokerDeleteInactiveTopicsEnabled=false brokerDeleteInactivePartitionedTopicMetadataEnabled=true brokerDeduplicationEnabled=true kafkaTransactionCoordinatorEnabled=true brokerDeleteInactiveTopicsMode=delete_when_subscriptions_caught_up ``` First,...

Flaky-test: PendingTopicFuturesTest#testExceptionalComplete

3

PendingTopicFuturesTest is flaky. The testExceptionalComplete test method fails sporadically. Add `invocationCount = 100` and test it in my local env. There is one time it failed. ``` 18:40:00.342 [TestNG-method=testExceptionalComplete-1:io.streamnative.pulsar.handlers.kop.PendingTopicFuturesTest@113] INFO...

After the internal discussion in StreamNative, we decide to apply the [schema registry feature](https://github.com/streamnative/kop/pull/1303) that upgrades the dependency to JDK 11 to branch-2.9.2 and branch-2.10.0 because the `sn-pulsar` docker images...

SNIP 42: Kafka Avro Serializer and Deserializer

27

Table of Contents ================= * [Motivation](#motivation) * [Approach](#approach) * [API Design](#api-design) * [Schema Registry Client](#schema-registry-client) * [Schema Version Header](#schema-version-header) * [Serializer](#serializer) * [Deserializer](#deserializer) * [Interaction with Pulsar clients](#interaction-with-pulsar-clients) * [Kafka...

[BUG] Memory leak by updating metrics in threads not managed by Netty

3

**Describe the bug** https://github.com/streamnative/kop/blob/60ec259d354d4bb61f82133338b72d2ea46fa6d5/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/stats/ThreadLocalAccessor.java#L24-L36 or older code: https://github.com/streamnative/kop/blob/82211b9ba2553a68b06c1b2f3479459e5b75f846/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/stats/DataSketchesOpStatsLogger.java#L183-L197 The `onRemoval` method is responsible to remove the thread local `LocalData` from the map when the thread stops. However, this method can...

[BUG] Strange write frequency to the offset topic

2

**Describe the bug** Following screenshots all represent the publish rate to the offset topic (`__consumer_offsets`), which represents the frequency to commit the offsets. We can see there was a wave...

**Is your feature request related to a problem? Please describe.** Currently all documents of KoP don't have a table of contents. **Describe the solution you'd like** Since Github doesn't support...

**Is your feature request related to a problem? Please describe.** There is an unload bug that cannot be reproduced on a 2 nodes cluster. See #1180 > When there are...

KafkaMessageOrderKafkaTest is flaky. The `testKafkaProduceMessageOrder` test method fails sporadically. [example failure](https://github.com/streamnative/kop/runs/5505464003?check_suite_focus=true) ``` Error: Tests run: 4, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 18.826 s

**Is your feature request related to a problem? Please describe.** KoP's group coordinator was implemented from the very beginning. Kafka has introduced many optimizations for the group coordinator since that...