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

Kafka client Java API wrapper #762

Closed
wants to merge 1 commit into from
Closed

Conversation

merlimat
Copy link
Contributor

Recreated PR from #753

Motivation

Add a Kafka API wrapper based on Pulsar client library.

This will allow existing application using the Kafka client library to publish or suscbribe to a Pulsar topic without any code change.

This first iteration is targeting the Kafka high-level consumer with managed offsets, with or without auto-commit.

Examples and documentation on the website will follow this PR.

Modifications

  • Add implementation of Kafka Producer and Consumer interfaces that internally use Pulsar client library
  • Use Maven shading plugin to replace KafkaProducer class with PulsarKafkaProducer in the jar

Result

The org.apache.pulsar:pulsar-client-kafka-compact artifact will be a drop-in replacement for org.apache.kafka:kafka-clients.

@merlimat merlimat added the type/feature The PR added a new feature or issue requested a new feature label Sep 17, 2017
@merlimat merlimat added this to the 1.20.0-incubating milestone Sep 17, 2017
@merlimat merlimat self-assigned this Sep 17, 2017
@merlimat merlimat requested a review from rdhabalia September 17, 2017 01:26
@merlimat merlimat removed this from the 1.20.0-incubating milestone Sep 17, 2017
@merlimat merlimat closed this Sep 17, 2017
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
type/feature The PR added a new feature or issue requested a new feature
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant