kop

kop copied to clipboard

[BUG] Broker with transactionCoordinatorEnabled property as True has error.

1

**Describe the bug** There is an error constantly coming up on the brokers logs Based on the description Transaction Coordinator property must be enabled. Broker config contains the value of...

rillo-carrillo

Change comments on private fields with @Getter or @Setter to Javadoc

1

**Is your feature request related to a problem? Please describe.** There are a lot of private fields that are annotated with `@Getter` or `@Setter` and have regular comments, e.g., in...

ZiyaoWei

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...

BewareMyPower

[BUG] Pulsar Consumer can't read message from Kafka Client.

3

**Describe the bug** We have a Pulsar cluster with KOP enabled. When a Pulsar Producer sends messages to a topic used by a Kafka consumer, Kafka's consumer is able to...

rillo-carrillo

[BUG] `DeleteRecords` returns "Unknown Topic or Partition" for existing partition

9

**Describe the bug** KOP answers `DeleteRecords` requests with "Unknown Topic or Partition" even when the partition clearly exists. **To Reproduce** When using KOP based on the following Dockerfile: ```dockerfile FROM...

crepererum

[BUG] Namespace bundle for topic not served by this instance. Please redo the lookup.

11

**Describe the bug** Producer and Consumer throw errors when trying to publish/consume messages from topics created with bin/pulsar-admin and autoCreatedTopics. This error seems to be intermittent, some times when publishing...

rillo-carrillo

[BUG] Delete Topics doesn't throw PulsarAdminException or ERROR

5

**Describe the bug** Kop just throw ERROR.UNKNOWN_TOPIC_OR_PARTITION when deleting topics，not throw PulsarAdminException or Error，is not friendly to upper client. **To Reproduce** Steps to reproduce the behavior: 1. Frequently thow ERROR...

zhouxy0809

[BUG] KTable doesn't work against KoP enabled cluster.

10

**Describe the bug** When attempting to use the KTable feature from the latest version (3.1.0) of the `kafka-streams` library, no results are produced. **To Reproduce** Steps to reproduce the behavior:...

david-streamlio

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...

BewareMyPower

[FEATURE] Automatically encode Kafka entries using Confluent Avro Serialiser format

1

**Is your feature request related to a problem? Please describe.** When I consume data from a Pulsar topic with AVRO or KeyValue format using KOP I cannot leverage the Schema...

eolivelli