kop
kop copied to clipboard
Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar
[FEATURE] Build an OauthCallbackHandler optimized for SN Cloud (java, python, go, .net, c++, rust)
**Is your feature request related to a problem? Please describe.** This is related to the [Kafka on Pulsar ](https://github.com/streamnative/roadmap/issues/2)feature that is being added **Describe the solution you'd like** N/A **Describe...
**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...
**Describe the bug** Namespace and topic level publish rate limiter does not work, while broker level publish rate limiter works. **To Reproduce** `bin/pulsar-admin namespaces set-publish-rate public/default -b 500` ---- do...
**Describe the bug** Pulsar/KoP 2.9.1 generates multiple identical TYPE definitions, which causes the following error: *error parsing MF: text format parsing error in line 780: second TYPE line for metric...
This issue focus more on KoP's release. It's not a part of KoP itself, so I chose to open an issue instead of updating the document. First, see the release...
**Describe the bug** A clear and concise description of what the bug is. Use logstash for consumption, offset submission will not be submitted after a period of time normally, restarting...