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

Support Topic lookup using Pulsar binary protocol #105

Closed
wants to merge 1 commit into from

Conversation

rdhabalia
Copy link
Contributor

Motivation

[Test PR: (Already opened #5) ]
To improve lookup performance: adding lookup API in Pulsar binary protocol for:

  • PartitionedTopicMetadata
  • Topic-lookup: find BrokerService-Url

Modifications

  • Introduced two new protobuf-commands for partitionedMetadata and topic lookup
  • server/client api to handle lookup request/response

Result

Result: Client-library can do topic-lookup using pulsar binary protocol.

@yahoocla
Copy link

yahoocla commented Nov 9, 2016

CLA is valid!

@merlimat merlimat closed this Nov 9, 2016
@rdhabalia rdhabalia deleted the lookup_PR branch November 11, 2016 23:03
sijie pushed a commit to sijie/pulsar that referenced this pull request Mar 4, 2018
* Added Process based container factory

* Added java instance log4j

* Generate uberjar

* Added log directory for process container

* Better naming

* Corrected java command line

* More changes to get things to work

* Fixed process args

* Temp change that needs to be reverted

* Merge conflict

* Siwthced to gprc 1.5.0 for netty compat

* Getter for ProcessBuilder

* Added test

* Added container info

* Send Internal Server Error if we have trouble with the request

* Dont use unsupported apis

* Revert changes

* Make Thread container as default

* Fix build
hrsakai pushed a commit to hrsakai/pulsar that referenced this pull request Dec 10, 2020
hangc0276 pushed a commit to hangc0276/pulsar that referenced this pull request May 26, 2021
Fix apache#95.
Make Kafka OffsetCommit and Pulsar backlog align.

Add backlog tracker in GroupCoordinator.
After fetch message, ack the fetched position.

* pass tests
* add consumer when sync group
* change log level bacck
* ignore testSessionTimeout, and opened new issue to track this
* bin/kop was accidently deleted, add it back
* remove LOOKUP_CACHE when protocol close
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants