kop icon indicating copy to clipboard operation
kop copied to clipboard

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar

Results 171 kop issues
Sort by recently updated
recently updated
newest added

# Transaction Tasks ### Kafka 2.8.0 and previous version transaction support: - [x] Transaction log https://github.com/streamnative/kop/pull/424, #716 - [ ] #915 - [x] Transaction timeout (#823) - [x] #896 -...

type/feature

### Task list - [ ] Upgrade Kafka dependency to 2.8.x - [ ] Support producer fence

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

flaky-tests

**Is your feature request related to a problem? Please describe.** KoP's Kafka dependency keeps 2.0.0 for a long time. To support some new features since Kafka 2.0.0, we must upgrade...

type/feature

**Is your feature request related to a problem? Please describe.** - The most recent successful test (fa94761c90d92bcef92071cc5abeb301ed2d152f) took 43 min (tests 40 min): https://github.com/streamnative/kop/runs/3952242908?check_suite_focus=true - The most recent failed test...

type/feature

`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

flaky-tests

**Is your feature request related to a problem? Please describe.** When running KOP you miss the Schema Registry. Using a third party schema registry is possible but it won't support...

type/feature

**Describe the bug** Request metadata does not respond until the server restarts and recovers。 ![image](https://user-images.githubusercontent.com/19296967/133207582-bcd197a1-d398-4bee-b7bd-08f91a8d176f.png)

type/bug

**Describe the bug** When I use kafka-console-consumer.sh to consume KoPo and report an error, and use the --zokeeper parameter instead of --bootstrap-server, the client will exit and report an error:...

type/bug