Pulsar Kafka compatibility :: API

Drop-in replacement for Kafka client library that publishes and consumes messages on Pulsar topics

License

License

Categories

Categories

CLI User Interface
GroupId

GroupId

org.apache.pulsar
ArtifactId

ArtifactId

pulsar-client-kafka
Last Version

Last Version

2.8.0
Release Date

Release Date

Type

Type

jar
Description

Description

Pulsar Kafka compatibility :: API
Drop-in replacement for Kafka client library that publishes and consumes messages on Pulsar topics
Project Organization

Project Organization

Apache Software Foundation

Download pulsar-client-kafka

How to add to project

<!-- https://jarcasting.com/artifacts/org.apache.pulsar/pulsar-client-kafka/ -->
<dependency>
    <groupId>org.apache.pulsar</groupId>
    <artifactId>pulsar-client-kafka</artifactId>
    <version>2.8.0</version>
</dependency>
// https://jarcasting.com/artifacts/org.apache.pulsar/pulsar-client-kafka/
implementation 'org.apache.pulsar:pulsar-client-kafka:2.8.0'
// https://jarcasting.com/artifacts/org.apache.pulsar/pulsar-client-kafka/
implementation ("org.apache.pulsar:pulsar-client-kafka:2.8.0")
'org.apache.pulsar:pulsar-client-kafka:jar:2.8.0'
<dependency org="org.apache.pulsar" name="pulsar-client-kafka" rev="2.8.0">
  <artifact name="pulsar-client-kafka" type="jar" />
</dependency>
@Grapes(
@Grab(group='org.apache.pulsar', module='pulsar-client-kafka', version='2.8.0')
)
libraryDependencies += "org.apache.pulsar" % "pulsar-client-kafka" % "2.8.0"
[org.apache.pulsar/pulsar-client-kafka "2.8.0"]

Dependencies

compile (65)

Group / Artifact Type Version
org.apache.pulsar : pulsar-client-api jar 2.8.0
io.swagger : swagger-annotations jar 1.6.2
org.apache.bookkeeper : cpu-affinity jar 4.14.1
javax.ws.rs : javax.ws.rs-api jar 2.1
org.apache.pulsar : pulsar-transaction-common jar 2.8.0
org.apache.pulsar : bouncy-castle-bc jar 2.8.0
net.jcip : jcip-annotations jar 1.0
org.apache.pulsar : pulsar-client-admin jar 2.8.0
io.airlift : aircompressor jar 0.16
org.bouncycastle : bcpkix-jdk15on jar 1.68
org.bouncycastle : bcprov-jdk15on jar 1.68
org.bouncycastle : bcprov-ext-jdk15on jar 1.68
javax.validation : validation-api jar 1.1.0.Final
org.apache.pulsar : pulsar-client-admin-api jar 2.8.0
jakarta.ws.rs : jakarta.ws.rs-api jar 2.1.6
jakarta.xml.bind : jakarta.xml.bind-api jar 2.3.3
jakarta.activation : jakarta.activation-api jar 1.2.2
javax.xml.bind : jaxb-api jar 2.3.1
com.sun.activation : javax.activation jar 1.2.0
org.slf4j : jul-to-slf4j jar 1.7.25
org.checkerframework : checker-qual jar 3.5.0
org.apache.pulsar : pulsar-package-core jar 2.8.0
org.apache.pulsar : pulsar-functions-utils jar 2.8.0
org.apache.pulsar : pulsar-io-core jar 2.8.0
org.apache.pulsar : pulsar-functions-proto jar 2.8.0
com.google.protobuf : protobuf-java-util jar 3.11.4
io.grpc : grpc-all jar 1.33.0
io.grpc : grpc-api jar 1.33.0
io.grpc : grpc-auth jar 1.33.0
com.google.auth : google-auth-library-credentials jar 0.20.0
io.grpc : grpc-context jar 1.33.0
io.grpc : grpc-core jar 1.33.0
io.grpc : grpc-grpclb jar 1.33.0
io.grpc : grpc-netty jar 1.33.0
io.grpc : grpc-okhttp jar 1.33.0
com.squareup.okhttp : okhttp jar 2.7.4
io.grpc : grpc-protobuf jar 1.33.0
com.google.api.grpc : proto-google-common-protos jar 1.17.0
io.grpc : grpc-protobuf-lite jar 1.33.0
io.grpc : grpc-services jar 1.33.0
io.grpc : grpc-stub jar 1.33.0
io.grpc : grpc-xds jar 1.33.0
io.grpc : grpc-alts jar 1.33.0
org.conscrypt : conscrypt-openjdk-uber jar 2.5.2
com.google.auth : google-auth-library-oauth2-http jar 0.20.0
com.google.auto.value : auto-value-annotations jar 1.7
com.google.http-client : google-http-client jar 1.34.0
org.apache.httpcomponents : httpclient jar 4.5.13
org.apache.httpcomponents : httpcore jar 4.4.12
io.opencensus : opencensus-api jar 0.18.0
io.opencensus : opencensus-contrib-http-util jar 0.24.0
com.google.http-client : google-http-client-jackson2 jar 1.34.0
com.google.re2j : re2j jar 1.2
io.opencensus : opencensus-proto jar 0.2.0
io.grpc : grpc-netty-shaded jar 1.33.0
org.apache.pulsar : pulsar-functions-api jar 2.8.0
org.apache.pulsar : pulsar-config-validation jar 2.8.0
net.jodah : typetools jar 0.5.0
org.asynchttpclient : async-http-client jar 2.12.1
org.asynchttpclient : async-http-client-netty-utils jar 2.12.1
com.github.luben : zstd-jni jar 1.4.5-6
com.google.code.findbugs : jsr305 jar 3.0.2
com.google.errorprone : error_prone_annotations jar 2.5.1
com.google.j2objc : j2objc-annotations jar 1.3
org.slf4j : slf4j-api jar 1.7.25

provided (2)

Group / Artifact Type Version
org.projectlombok : lombok jar 1.18.20
javax.annotation : javax.annotation-api jar 1.3.2

runtime (4)

Group / Artifact Type Version
com.google.android : annotations jar 4.1.1.4
com.squareup.okio : okio jar 1.13.0
io.perfmark : perfmark-api jar 0.19.0
org.codehaus.mojo : animal-sniffer-annotations jar 1.14

test (6)

Group / Artifact Type Version
org.apache.pulsar : buildtools jar 2.8.0
org.testng : testng jar 7.3.0
org.mockito : mockito-core jar 3.8.0
org.powermock : powermock-api-mockito2 jar 2.0.9
org.powermock : powermock-module-testng jar 2.0.9
org.assertj : assertj-core jar 3.18.1

Project Modules

There are no modules declared in this project.
org.apache.pulsar

The Apache Software Foundation

Versions

Version
2.8.0
2.6.4
2.6.3
2.6.2
2.6.1
2.6.0
2.5.2
2.5.1
2.5.0
2.4.2
2.4.1
2.4.0
2.3.2
2.3.1
2.3.0
2.2.1
2.2.0
2.1.1-incubating
2.1.0-incubating
2.0.1-incubating
2.0.0-rc1-incubating
1.22.1-incubating
1.22.0-incubating
1.21.0-incubating
1.20.0-incubating