kop
kop copied to clipboard
streamnative
Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar
Fixes #1419 ### Motivation When the Kafka client issues a Fetch and sets a max wait time we are already scheduling a DelayedFetch, but there is no way to trigger...
This is a PR created by snbot to trigger the check suite in each repository.
**Describe the bug** Producer code for nodejs (node-rdkafka) is not able to send events to KOP The nodejs client does not call KafkaCommandDecoder.channelRead method to send events. I am using...
**Env** - pulsar: 2.10.1 , 3 nodes cluster(broker + bookie + zk) - kop: pulsar-protocol-handler-kafka-2.10.1.4.nar - kafka: 2.0.0 **Describe the bug** I got a warn msg when using kafka-console-producer.sh write...
KafkaMessageOrderKafkaTest is flaky. The testKafkaProduceMessageOrder test method fails sporadically. [example failure](https://github.com/streamnative/kop/runs/7738563391?check_suite_focus=true#step:12:207) ``` Error: testKafkaProduceMessageOrder(io.streamnative.pulsar.handlers.kop.KafkaMessageOrderKafkaTest) Time elapsed: 0.194 s
**Describe the bug** When I enabled Kop in pulsar and setup a Kafka consumer (python) to consume from pulsar, it was failed with error. **To Reproduce** Pulsar & Kop: 2.9.2.12...
**Is your feature request related to a problem? Please describe.** Pulsar has following policies applied to namespace. This will specify the number of producers, consumers and subscriptions applied to a...
This is a PR created by snbot to trigger the check suite in each repository.
This is a PR created by snbot to trigger the check suite in each repository.
### Motivation GroupMetadataManager::removeProducerGroup() is trying to remove a group using the producerId. ### Modifications Fixed the issue by using the group ID. ### Verifying this change - [ ] Make...
Metadata
Owner
Metadata
Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar