pulsar-client-kafka
Used in:
components
- OverviewOverview
- VersionsVersions
- DependentsDependents
- DependenciesDependencies
<dependency> <groupId>io.streamnative</groupId> <artifactId>pulsar-client-kafka</artifactId> <version>2.6.3.4</version> </dependency>
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <parent> <artifactId>pulsar-client-kafka-compat</artifactId> <groupId>io.streamnative</groupId> <version>2.6.3.4</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>pulsar-client-kafka</artifactId> <name>Pulsar Kafka compatibility :: API</name> <description>Drop-in replacement for Kafka client library that publishes and consumes messages on Pulsar topics</description> <build> <plugins> <plugin> <artifactId>maven-shade-plugin</artifactId> <executions> <execution> <phase>package</phase> <goals> <goal>shade</goal> </goals> <configuration> <createDependencyReducedPom>true</createDependencyReducedPom> <promoteTransitiveDependencies>true</promoteTransitiveDependencies> <artifactSet> <includes> <include>org.apache.kafka:kafka-clients</include> <include>io.streamnative:pulsar-client-kafka-original</include> <include>io.streamnative:pulsar-client-original</include> <include>org.apache.commons:commons-lang3</include> <include>commons-codec:commons-codec</include> <include>org.apache.bookkeeper:bookkeeper-common-allocator</include> <include>commons-collections:commons-collections</include> <include>org.asynchttpclient:*</include> <include>io.netty:netty-codec-http</include> <include>io.netty:netty-transport-native-epoll</include> <include>org.reactivestreams:reactive-streams</include> <include>com.typesafe.netty:netty-reactive-streams</include> <include>org.javassist:javassist</include> <include>com.google.protobuf:protobuf-java</include> <include>com.google.guava:guava</include> <include>com.google.code.gson:gson</include> <include>com.fasterxml.jackson.core</include> <include>com.fasterxml.jackson.module</include> <include>com.fasterxml.jackson.dataformat</include> <include>io.netty:netty</include> <include>io.netty:netty-*</include> <include>io.streamnative:pulsar-common</include> <include>org.apache.bookkeeper:circe-checksum</include> <include>com.yahoo.datasketches:sketches-core</include> <include>org.apache.httpcomponents:httpclient</include> <include>commons-logging:commons-logging</include> <include>org.apache.httpcomponents:httpcore</include> <include>org.eclipse.jetty:*</include> <include>com.yahoo.datasketches:*</include> <include>commons-*:*</include> <include>org.yaml:snakeyaml</include> <include>org.objenesis:*</include> <include>org.apache.avro:*</include> <include>org.codehaus.jackson:jackson-core-asl</include> <include>org.codehaus.jackson:jackson-mapper-asl</include> <include>com.thoughtworks.paranamer:paranamer</include> <include>org.apache.commons:commons-compress</include> <include>org.tukaani:xz</include> </includes> </artifactSet> <filters> <filter> <artifact>commons-logging:commons-logging</artifact> <includes> <include>**</include> </includes> </filter> <filter> <artifact>io.streamnative:pulsar-client-original</artifact> <includes> <include>**</include> </includes> </filter> </filters> <relocations> <relocation> <pattern>org.apache.kafka.clients.producer.KafkaProducer</pattern> <shadedPattern>org.apache.kafka.clients.producer.OriginalKafkaProducer</shadedPattern> </relocation> <relocation> <pattern>org.apache.kafka.clients.producer.PulsarKafkaProducer</pattern> <shadedPattern>org.apache.kafka.clients.producer.KafkaProducer</shadedPattern> </relocation> <relocation> <pattern>org.apache.kafka.clients.consumer.KafkaConsumer</pattern> <shadedPattern>org.apache.kafka.clients.consumer.OriginalKafkaConsumer</shadedPattern> </relocation> <relocation> <pattern>org.apache.kafka.clients.consumer.PulsarKafkaConsumer</pattern> <shadedPattern>org.apache.kafka.clients.consumer.KafkaConsumer</shadedPattern> </relocation> <relocation> <pattern>org.asynchttpclient</pattern> <shadedPattern>org.apache.pulsar.shade.org.asynchttpclient</shadedPattern> </relocation> <relocation> <pattern>org.apache.commons</pattern> <shadedPattern>org.apache.pulsar.shade.org.apache.commons</shadedPattern> </relocation> <relocation> <pattern>com.google</pattern> <shadedPattern>org.apache.pulsar.shade.com.google</shadedPattern> </relocation> <relocation> <pattern>com.fasterxml.jackson</pattern> <shadedPattern>org.apache.pulsar.shade.com.fasterxml.jackson</shadedPattern> </relocation> <relocation> <pattern>io.netty</pattern> <shadedPattern>org.apache.pulsar.shade.io.netty</shadedPattern> </relocation> <relocation> <pattern>com.yahoo.datasketches</pattern> <shadedPattern>org.apache.pulsar.shade.com.yahoo.datasketches</shadedPattern> </relocation> <relocation> <pattern>com.yahoo.sketches</pattern> <shadedPattern>org.apache.pulsar.shade.com.yahoo.sketches</shadedPattern> </relocation> <relocation> <pattern>org.apache.http</pattern> <shadedPattern>org.apache.pulsar.shade.org.apache.http</shadedPattern> </relocation> <relocation> <pattern>org.eclipse.jetty</pattern> <shadedPattern>org.apache.pulsar.shade.org.eclipse</shadedPattern> </relocation> <relocation> <pattern>org.reactivestreams</pattern> <shadedPattern>org.apache.pulsar.shade.org.reactivestreams</shadedPattern> </relocation> <relocation> <pattern>com.typesafe</pattern> <shadedPattern>org.apache.pulsar.shade.com.typesafe</shadedPattern> </relocation> <relocation> <pattern>com.yahoo.memory</pattern> <shadedPattern>org.apache.pulsar.shade.com.yahoo.memory</shadedPattern> </relocation> <relocation> <pattern>org.objenesis</pattern> <shadedPattern>org.apache.pulsar.shade.org.objenesis</shadedPattern> </relocation> <relocation> <pattern>org.yaml</pattern> <shadedPattern>org.apache.pulsar.shade.org.yaml</shadedPattern> </relocation> <relocation> <pattern>org.apache.avro</pattern> <shadedPattern>org.apache.pulsar.shade.org.apache.avro</shadedPattern> <excludes> <exclude>org.apache.avro.reflect.AvroAlias</exclude> <exclude>org.apache.avro.reflect.AvroDefault</exclude> <exclude>org.apache.avro.reflect.AvroEncode</exclude> <exclude>org.apache.avro.reflect.AvroIgnore</exclude> <exclude>org.apache.avro.reflect.AvroMeta</exclude> <exclude>org.apache.avro.reflect.AvroName</exclude> <exclude>org.apache.avro.reflect.AvroSchema</exclude> <exclude>org.apache.avro.reflect.Nullable</exclude> <exclude>org.apache.avro.reflect.Stringable</exclude> <exclude>org.apache.avro.reflect.Union</exclude> </excludes> </relocation> <relocation> <pattern>org.codehaus.jackson</pattern> <shadedPattern>org.apache.pulsar.shade.org.codehaus.jackson</shadedPattern> </relocation> <relocation> <pattern>com.thoughtworks.paranamer</pattern> <shadedPattern>org.apache.pulsar.shade.com.thoughtworks.paranamer</shadedPattern> </relocation> <relocation> <pattern>org.apache.commons</pattern> <shadedPattern>org.apache.pulsar.shade.org.apache.commons</shadedPattern> </relocation> <relocation> <pattern>org.tukaani</pattern> <shadedPattern>org.apache.pulsar.shade.org.tukaani</shadedPattern> </relocation> <relocation> <pattern>org.apache.bookkeeper</pattern> <shadedPattern>org.apache.pulsar.shade.org.apache.bookkeeper</shadedPattern> </relocation> </relocations> </configuration> </execution> </executions> </plugin> <plugin> <groupId>org.codehaus.mojo</groupId> <artifactId>exec-maven-plugin</artifactId> <executions> <execution> <id>rename-epoll-library</id> <phase>package</phase> <goals> <goal>exec</goal> </goals> <configuration> <executable>${project.parent.basedir}/../src/${rename.netty.native.libs}</executable> <arguments> <argument>${project.artifactId}</argument> </arguments> </configuration> </execution> </executions> </plugin> <plugin> <artifactId>maven-jar-plugin</artifactId> <version>3.2.0</version> <executions> <execution> <id>default-jar</id> <phase>package</phase> <goals> <goal>jar</goal> </goals> </execution> <execution> <id>javadoc-jar</id> <phase>package</phase> <goals> <goal>jar</goal> </goals> <configuration> <classifier>javadoc</classifier> </configuration> </execution> </executions> </plugin> </plugins> </build> <dependencies> <dependency> <groupId>io.streamnative</groupId> <artifactId>pulsar-client</artifactId> <version>2.6.3.4</version> <scope>compile</scope> </dependency> <dependency> <groupId>io.streamnative</groupId> <artifactId>pulsar-client-api</artifactId> <version>2.6.3.4</version> <scope>compile</scope> </dependency> <dependency> <groupId>io.streamnative</groupId> <artifactId>pulsar-transaction-common</artifactId> <version>2.6.3.4</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.google.protobuf</groupId> <artifactId>protobuf-java-util</artifactId> <version>3.5.1</version> <scope>compile</scope> </dependency> <dependency> <groupId>io.swagger</groupId> <artifactId>swagger-annotations</artifactId> <version>1.5.21</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.apache.pulsar</groupId> <artifactId>protobuf-shaded</artifactId> <version>2.1.0-incubating</version> <scope>compile</scope> </dependency> <dependency> <groupId>io.airlift</groupId> <artifactId>aircompressor</artifactId> <version>0.16</version> <scope>compile</scope> </dependency> <dependency> <groupId>javax.ws.rs</groupId> <artifactId>javax.ws.rs-api</artifactId> <version>2.1</version> <scope>compile</scope> </dependency> <dependency> <groupId>io.streamnative</groupId> <artifactId>bouncy-castle-bc-shaded</artifactId> <version>2.6.3.4</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.sun.activation</groupId> <artifactId>javax.activation</artifactId> <version>1.2.0</version> <scope>compile</scope> </dependency> <dependency> <groupId>javax.validation</groupId> <artifactId>validation-api</artifactId> <version>1.1.0.Final</version> <scope>compile</scope> </dependency> <dependency> <groupId>net.jcip</groupId> <artifactId>jcip-annotations</artifactId> <version>1.0</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.github.luben</groupId> <artifactId>zstd-jni</artifactId> <version>1.4.0-1</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.google.code.findbugs</groupId> <artifactId>jsr305</artifactId> <version>3.0.2</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.checkerframework</groupId> <artifactId>checker-qual</artifactId> <version>2.0.0</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.google.errorprone</groupId> <artifactId>error_prone_annotations</artifactId> <version>2.1.3</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.google.j2objc</groupId> <artifactId>j2objc-annotations</artifactId> <version>1.1</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.codehaus.mojo</groupId> <artifactId>animal-sniffer-annotations</artifactId> <version>1.14</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.25</version> <scope>compile</scope> </dependency> </dependencies> <properties> <kafka.version>0.10.2.1</kafka.version> </properties> </project>