Skip to content
This repository was archived by the owner on Jan 24, 2024. It is now read-only.
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions docs/kop.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
---
download: "https://github.com/streamnative/kop/releases/download/v{{protocol:version}}/pulsar-protocol-handler-kafka-{{protocol:version}}.nar"
download: "https://github.com/streamnative/kop/releases/download/v2.8.0.8/pulsar-protocol-handler-kafka-2.8.0.8.nar"
alias: KoP - Kafka on Pulsar
---

Expand All @@ -21,7 +21,7 @@ The following figure illustrates how the Kafka-on-Pulsar protocol handler is imp
# Get Started with KoP

If you have an Apache Pulsar cluster, you can enable Kafka-on-Pulsar on your existing Pulsar cluster by downloading and installing the KoP protocol handler to Pulsar brokers directly. It takes three steps:
1. Download KoP protocol handler, or build the `./kafka-impl/target/pulsar-protocol-handler-kafka-{{protocol:version}}.nar` file, and then copy it to your Pulsar `protocols` directory.
1. Download KoP protocol handler, or build the `./kafka-impl/target/pulsar-protocol-handler-kafka-2.8.0.8.nar` file, and then copy it to your Pulsar `protocols` directory.
2. Set the configuration of the KoP protocol handler in Pulsar `broker.conf` or `standalone.conf` files.
3. Restart Pulsar brokers to load KoP protocol handler.

Expand Down Expand Up @@ -54,7 +54,7 @@ To build the KoP protocol handler from the source, follow thse steps.
3. Get the `.nar` file in the following directory and copy it your Pulsar `protocols` directory. You need to create the `protocols` folder in Pulsar if it's the first time you use protocol handlers.

```bash
./kafka-impl/target/pulsar-protocol-handler-kafka-{{protocol:version}}.nar
./kafka-impl/target/pulsar-protocol-handler-kafka-2.8.0.8.nar
```

## Set configuration for KoP
Expand Down
4 changes: 2 additions & 2 deletions kafka-1-0/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
<parent>
<artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
<groupId>io.streamnative.pulsar.handlers</groupId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand All @@ -32,7 +32,7 @@
<dependency>
<groupId>io.streamnative.pulsar.handlers</groupId>
<artifactId>kafka-client-api</artifactId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
Expand Down
2 changes: 1 addition & 1 deletion kafka-client-api/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
<parent>
<artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
<groupId>io.streamnative.pulsar.handlers</groupId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
6 changes: 3 additions & 3 deletions kafka-client-factory/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
<parent>
<artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
<groupId>io.streamnative.pulsar.handlers</groupId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand All @@ -32,12 +32,12 @@
<dependency>
<groupId>io.streamnative.pulsar.handlers</groupId>
<artifactId>kafka-client-api</artifactId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</dependency>
<dependency>
<groupId>io.streamnative.pulsar.handlers</groupId>
<artifactId>kafka-1-0</artifactId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</dependency>
</dependencies>
</project>
2 changes: 1 addition & 1 deletion kafka-impl/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
<parent>
<groupId>io.streamnative.pulsar.handlers</groupId>
<artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</parent>

<groupId>io.streamnative.pulsar.handlers</groupId>
Expand Down
2 changes: 1 addition & 1 deletion oauth-client/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
<parent>
<artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
<groupId>io.streamnative.pulsar.handlers</groupId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</parent>

<artifactId>oauth-client</artifactId>
Expand Down
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@

<groupId>io.streamnative.pulsar.handlers</groupId>
<artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
<name>StreamNative :: Pulsar Protocol Handler :: KoP Parent</name>
<description>Parent for Kafka on Pulsar implemented using Pulsar Protocol Handler.</description>

Expand All @@ -46,7 +46,7 @@
<lombok.version>1.18.4</lombok.version>
<mockito.version>2.22.0</mockito.version>
<pulsar.group.id>io.streamnative</pulsar.group.id>
<pulsar.version>2.8.0.3</pulsar.version>
<pulsar.version>2.8.0.8</pulsar.version>
<slf4j.version>1.7.25</slf4j.version>
<spotbugs-annotations.version>3.1.8</spotbugs-annotations.version>
<testcontainers.version>1.15.1</testcontainers.version>
Expand Down
6 changes: 3 additions & 3 deletions tests/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
<parent>
<groupId>io.streamnative.pulsar.handlers</groupId>
<artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</parent>

<groupId>io.streamnative.pulsar.handlers</groupId>
Expand All @@ -39,12 +39,12 @@
<dependency>
<groupId>io.streamnative.pulsar.handlers</groupId>
<artifactId>kafka-client-api</artifactId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</dependency>
<dependency>
<groupId>io.streamnative.pulsar.handlers</groupId>
<artifactId>kafka-client-factory</artifactId>
<version>2.9.0-SNAPSHOT</version>
<version>2.8.0.8</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
Expand Down