Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Intermittent test failure in ProxyPublishConsumeTest #206

Closed
merlimat opened this issue Feb 13, 2017 · 0 comments
Closed

Intermittent test failure in ProxyPublishConsumeTest #206

merlimat opened this issue Feb 13, 2017 · 0 comments
Assignees
Milestone

Comments

@merlimat
Copy link
Contributor

socketTest(com.yahoo.pulsar.websocket.proxy.ProxyPublishConsumeTest)  Time elapsed: 3.029 sec  <<< FAILURE!
java.lang.AssertionError: null: lists don't have the same size expected [0] but found [10]
	at com.yahoo.pulsar.websocket.proxy.ProxyPublishConsumeTest.socketTest(ProxyPublishConsumeTest.java:100)

@merlimat merlimat added this to the 1.17 milestone Feb 13, 2017
merlimat added a commit to merlimat/pulsar that referenced this issue Feb 14, 2017
merlimat added a commit to merlimat/pulsar that referenced this issue Feb 15, 2017
@merlimat merlimat self-assigned this Sep 20, 2017
sijie pushed a commit to sijie/pulsar that referenced this issue Mar 4, 2018
hrsakai pushed a commit to hrsakai/pulsar that referenced this issue Dec 10, 2020
Signed-off-by: xiaolong.ran <rxl@apache.org>
hangc0276 pushed a commit to hangc0276/pulsar that referenced this issue May 26, 2021
Currently KoP only support produce or consume topics in the configured namespace by `kafkaTenant` and `kafkaNamespace`. If we want to make use of Pulsar's multi-tenancy, we need to enable SASL authentication and encode the namespace info into the `sasl.jaas.config` property.

This PR is to use Pulsar topic name as Kafka topic name, the topic mapping from topic in Kafka client to the real Pulsar topic is:

- my-topic => `persistent://<kafkaTenant>/<kafkaNamespace>/my-topic`
- my-tenant/my-ns/my-topic => `persistent://my-tenant/my-ns/my-topic`

This work is done by the new added `KopTopic`.

Besides, if client want to fetch the metadata of all topics, before this PR, only the topics of `<kafkaTenant>/<kafkaNamespace>` would be returned, now the topics of all namespaces would be returned.

Following unit tests are added:

- `KopTopicTest`: test the basic functions of `KopTopic`;
- `DifferentNamespaceTest`: test the newly supported topic name version to specify a custom namespace
* Add KopTopic

* Support parse tenant/namespace from topic name

* Fix auto topic creation error

* Fix topic metadata response error

* Add test for specify topics with different namespaces

* Fix test error of testBrokerPublishByteThrotting

* Remove redundant check for numPartitions

* Make get all topics async

* Fix checkstyle failure

* Add test for commit offset in another namespace

* Add a TODO to the authentication issue after multi-tenancy was supported

* Rollback the refactor of handleTopicMetadataRequest

* Rollback indent style changes
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant