From 2145f843a1d390880dddb1e1ea3901450403f94f Mon Sep 17 00:00:00 2001 From: streamnativebot Date: Wed, 5 Jul 2023 07:06:58 +0000 Subject: [PATCH] "Created by snbot" --- docs/kop.md | 18 ++--- kafka-0-10/pom.xml | 2 +- kafka-0-9/pom.xml | 2 +- kafka-1-0/pom.xml | 2 +- kafka-2-8/pom.xml | 2 +- kafka-3-0/pom.xml | 2 +- kafka-client-api/pom.xml | 2 +- kafka-client-factory/pom.xml | 2 +- kafka-impl/pom.xml | 2 +- kafka-payload-processor-shaded-tests/pom.xml | 2 +- kafka-payload-processor-shaded/pom.xml | 2 +- kafka-payload-processor/pom.xml | 2 +- oauth-client/pom.xml | 2 +- pom.xml | 80 +++++--------------- schema-registry/pom.xml | 2 +- test-listener/pom.xml | 2 +- tests/pom.xml | 2 +- 17 files changed, 42 insertions(+), 86 deletions(-) diff --git a/docs/kop.md b/docs/kop.md index 996e4c3322..dcc4ae27da 100644 --- a/docs/kop.md +++ b/docs/kop.md @@ -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/v3.0.0.4/pulsar-protocol-handler-kafka-3.0.0.4.nar" alias: KoP - Kafka on Pulsar --- @@ -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-3.0.0.4.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. @@ -63,7 +63,7 @@ To build the KoP protocol handler from the source, follow these steps: 3. Get the `.nar` file in the following directory and copy it to 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-3.0.0.4.nar ``` ### Step 2: Set configuration for KoP @@ -202,12 +202,12 @@ You can configure and manage KoP based on your requirements. Check the following > > The following links are invalid when you check this document in the `master` branch from GitHub. You can go to the same chapter of the [README](../README.md) for the correct links. -- [Configure KoP](https://github.com/streamnative/kop/blob/branch-{{protocol:version}}/docs/configuration.md) -- [Monitor KoP](https://github.com/streamnative/kop/blob/branch-{{protocol:version}}/docs/reference-metrics.md) -- [Upgrade](https://github.com/streamnative/kop/blob/branch-{{protocol:version}}/docs/upgrade.md) -- [Secure KoP](https://github.com/streamnative/kop/blob/branch-{{protocol:version}}/docs/security.md) -- [Schema Registry](https://github.com/streamnative/kop/blob/branch-{{protocol:version}}/docs/schema.md) -- [Implementation: How to converse Pulsar and Kafka](https://github.com/streamnative/kop/blob/branch-{{protocol:version}}/docs/implementation.md) +- [Configure KoP](https://github.com/streamnative/kop/blob/branch-3.0.0.4/docs/configuration.md) +- [Monitor KoP](https://github.com/streamnative/kop/blob/branch-3.0.0.4/docs/reference-metrics.md) +- [Upgrade](https://github.com/streamnative/kop/blob/branch-3.0.0.4/docs/upgrade.md) +- [Secure KoP](https://github.com/streamnative/kop/blob/branch-3.0.0.4/docs/security.md) +- [Schema Registry](https://github.com/streamnative/kop/blob/branch-3.0.0.4/docs/schema.md) +- [Implementation: How to converse Pulsar and Kafka](https://github.com/streamnative/kop/blob/branch-3.0.0.4/docs/implementation.md) The followings are important information when you configure and use KoP. diff --git a/kafka-0-10/pom.xml b/kafka-0-10/pom.xml index 4bc47731fe..45ec5e1f4c 100644 --- a/kafka-0-10/pom.xml +++ b/kafka-0-10/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-0-9/pom.xml b/kafka-0-9/pom.xml index 4175beb50e..b6baef3001 100644 --- a/kafka-0-9/pom.xml +++ b/kafka-0-9/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-1-0/pom.xml b/kafka-1-0/pom.xml index 36dca1e4a3..9a9742c7cf 100644 --- a/kafka-1-0/pom.xml +++ b/kafka-1-0/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-2-8/pom.xml b/kafka-2-8/pom.xml index 5f35317075..e22e9fe2c3 100644 --- a/kafka-2-8/pom.xml +++ b/kafka-2-8/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-3-0/pom.xml b/kafka-3-0/pom.xml index 38f5b9641b..2917142153 100644 --- a/kafka-3-0/pom.xml +++ b/kafka-3-0/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-client-api/pom.xml b/kafka-client-api/pom.xml index e6c6c15ef5..1b53bbdae6 100644 --- a/kafka-client-api/pom.xml +++ b/kafka-client-api/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-client-factory/pom.xml b/kafka-client-factory/pom.xml index 8875d78c08..84a596af5c 100644 --- a/kafka-client-factory/pom.xml +++ b/kafka-client-factory/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-impl/pom.xml b/kafka-impl/pom.xml index 694dacf2ff..1104d7f976 100644 --- a/kafka-impl/pom.xml +++ b/kafka-impl/pom.xml @@ -22,7 +22,7 @@ io.streamnative.pulsar.handlers pulsar-protocol-handler-kafka-parent - 2.11.0-SNAPSHOT + 3.0.0.4 io.streamnative.pulsar.handlers diff --git a/kafka-payload-processor-shaded-tests/pom.xml b/kafka-payload-processor-shaded-tests/pom.xml index 5c7ba7742d..d973209c0b 100644 --- a/kafka-payload-processor-shaded-tests/pom.xml +++ b/kafka-payload-processor-shaded-tests/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-payload-processor-shaded/pom.xml b/kafka-payload-processor-shaded/pom.xml index a4de3d441b..309054a39a 100644 --- a/kafka-payload-processor-shaded/pom.xml +++ b/kafka-payload-processor-shaded/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/kafka-payload-processor/pom.xml b/kafka-payload-processor/pom.xml index 19823ae323..a46203fd27 100644 --- a/kafka-payload-processor/pom.xml +++ b/kafka-payload-processor/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/oauth-client/pom.xml b/oauth-client/pom.xml index 91abb91e21..8562e874c2 100644 --- a/oauth-client/pom.xml +++ b/oauth-client/pom.xml @@ -22,7 +22,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 oauth-client diff --git a/pom.xml b/pom.xml index f2d2dc7b81..d05932f985 100644 --- a/pom.xml +++ b/pom.xml @@ -1,4 +1,4 @@ - + - - + org.apache apache 18 4.0.0 - pom - io.streamnative.pulsar.handlers pulsar-protocol-handler-kafka-parent - 2.11.0-SNAPSHOT + 3.0.0.4 StreamNative :: Pulsar Protocol Handler :: KoP Parent Parent for Kafka on Pulsar implemented using Pulsar Protocol Handler. - 17 true @@ -52,7 +46,7 @@ 1.18.24 4.11.0 io.streamnative - 3.0.0.1 + 3.0.0.4 1.7.25 3.1.12 2.1.3.Final @@ -64,7 +58,6 @@ 5.2.1 1.32 1.5.2-4 - 3.0.rc1 3.1.1 @@ -81,7 +74,6 @@ 1.8.10 20230227 - Apache License, Version 2.0 @@ -89,7 +81,6 @@ repo - kafka-0-9 kafka-0-10 @@ -107,7 +98,6 @@ kafka-payload-processor-shaded-tests test-listener - @@ -116,7 +106,6 @@ kafka-clients ${kafka.version} - ${pulsar.group.id} pulsar-broker @@ -140,14 +129,12 @@ - io.grpc grpc-all ${grpc.version} provided - com.google.protobuf protobuf-bom @@ -155,143 +142,119 @@ pom import - - junit junit ${junit.version} provided - ${pulsar.group.id} pulsar-broker ${pulsar.version} test-jar - ${pulsar.group.id} pulsar-client-original ${pulsar.version} - ${pulsar.group.id} pulsar-common ${pulsar.version} - ${pulsar.group.id} pulsar-client-admin-original ${pulsar.version} - ${pulsar.group.id} managed-ledger test-jar ${pulsar.version} - ${pulsar.group.id} testmocks ${pulsar.version} - org.projectlombok lombok ${lombok.version} - com.fasterxml.jackson.core jackson-core ${jackson.version} - com.fasterxml.jackson.core jackson-annotations ${jackson.version} - com.fasterxml.jackson.core jackson-databind ${jackson-databind.version} - com.fasterxml.jackson.dataformat jackson-dataformat-yaml ${jackson.version} - com.github.spotbugs spotbugs-annotations ${spotbugs-annotations.version} - org.testng testng ${testng.version} - org.mockito mockito-core ${mockito.version} - org.mockito mockito-inline ${mockito.version} - org.awaitility awaitility ${awaitility.version} - io.fusionauth fusionauth-jwt ${fusionauth-jwt.version} - io.streamnative.pulsar.handlers test-listener ${project.version} - org.yaml snakeyaml ${snakeyaml.version} - com.github.luben zstd-jni ${zstd-jni.version} - com.charleskorn.kaml kaml ${kaml.version} - org.jetbrains.kotlinx kotlinx-serialization-bom @@ -299,7 +262,6 @@ pom import - org.jetbrains.kotlinx kotlinx-coroutines-bom @@ -307,7 +269,6 @@ pom import - org.jetbrains.kotlin kotlin-bom @@ -315,7 +276,6 @@ pom import - org.json json @@ -323,7 +283,6 @@ - @@ -369,7 +328,6 @@ none - com.github.spotbugs spotbugs-maven-plugin @@ -378,7 +336,6 @@ resources/findbugsExclude.xml - maven-compiler-plugin ${maven-compiler-plugin.version} @@ -396,7 +353,6 @@ - maven-surefire-plugin ${maven-surefire-plugin.version} @@ -414,7 +370,8 @@ usedefaultlisteners - false + false + listener @@ -423,14 +380,12 @@ - com.mycila license-maven-plugin ${license-maven-plugin.version}
resources/license.template
- LICENSE NOTICE @@ -461,7 +416,6 @@ - org.codehaus.mojo templating-maven-plugin @@ -475,7 +429,6 @@ - pl.project13.maven git-commit-id-plugin @@ -503,7 +456,6 @@ true - org.jacoco jacoco-maven-plugin @@ -531,7 +483,6 @@ - central @@ -550,19 +501,25 @@ nexus-snapshot01 https://s01.oss.sonatype.org/content/repositories/snapshots + + ossrh + https://s01.oss.sonatype.org/service/local/repositories/iostreamnative-2347/content + + + nexus-snapshot + https://s01.oss.sonatype.org/content/repositories/snapshots + - - ossrh - https://s01.oss.sonatype.org/content/repositories/snapshots + ossrh + https://s01.oss.sonatype.org/content/repositories/snapshots - ossrh - https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/ + ossrh + https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/ - release @@ -629,5 +586,4 @@ - diff --git a/schema-registry/pom.xml b/schema-registry/pom.xml index 3687fa1a72..7d838401e5 100644 --- a/schema-registry/pom.xml +++ b/schema-registry/pom.xml @@ -20,7 +20,7 @@ io.streamnative.pulsar.handlers pulsar-protocol-handler-kafka-parent - 2.11.0-SNAPSHOT + 3.0.0.4 io.streamnative.pulsar.handlers diff --git a/test-listener/pom.xml b/test-listener/pom.xml index 2ef8f00c11..8305eb178c 100644 --- a/test-listener/pom.xml +++ b/test-listener/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-kafka-parent io.streamnative.pulsar.handlers - 2.11.0-SNAPSHOT + 3.0.0.4 4.0.0 diff --git a/tests/pom.xml b/tests/pom.xml index 28be6417c5..37fe7095c6 100644 --- a/tests/pom.xml +++ b/tests/pom.xml @@ -22,7 +22,7 @@ io.streamnative.pulsar.handlers pulsar-protocol-handler-kafka-parent - 2.11.0-SNAPSHOT + 3.0.0.4 io.streamnative.pulsar.handlers