(pulsar-client-reactive) branch main updated: [Release 0.5.1] Update next snapshot version to 0.5.2-SNAPSHOT (#150)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git The following commit(s) were added to refs/heads/main by this push: new 5d4f74e [Release 0.5.1] Update next snapshot version to 0.5.2-SNAPSHOT (#150) 5d4f74e is described below commit 5d4f74e8969e7fc4ea6030392f2c361b06ccc3c2 Author: Chris Bono AuthorDate: Sun Dec 17 17:26:21 2023 -0600 [Release 0.5.1] Update next snapshot version to 0.5.2-SNAPSHOT (#150) --- gradle.properties | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gradle.properties b/gradle.properties index f6207e8..c815fb9 100644 --- a/gradle.properties +++ b/gradle.properties @@ -17,4 +17,4 @@ # under the License. # -version=0.5.1 +version=0.5.2-SNAPSHOT
(pulsar-client-reactive) branch main updated: Upgrade latest released version to 0.5.0 in README.adoc (#147)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git The following commit(s) were added to refs/heads/main by this push: new a10af46 Upgrade latest released version to 0.5.0 in README.adoc (#147) a10af46 is described below commit a10af4633857e2577ac48ec4fcebd0a5aaa5b733 Author: Lari Hotari AuthorDate: Thu Dec 14 14:42:11 2023 +0200 Upgrade latest released version to 0.5.0 in README.adoc (#147) --- README.adoc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.adoc b/README.adoc index 131543b..37de63a 100644 --- a/README.adoc +++ b/README.adoc @@ -19,7 +19,7 @@ = Reactive client for Apache Pulsar :github: https://github.com/apache/pulsar-client-reactive -:latest_version: 0.3.0 +:latest_version: 0.5.0 Reactive client for Apache Pulsar which is compatible with the Reactive Streams specification. This uses Project Reactor as the Reactive Streams implementation.
(pulsar-client-reactive) branch main updated: Bump Pulsar version to 3.1.1 (#144)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git
The following commit(s) were added to refs/heads/main by this push:
new 92a1e39 Bump Pulsar version to 3.1.1 (#144)
92a1e39 is described below
commit 92a1e390e854876b54936bd0e6d21bf1e5071aeb
Author: Lari Hotari
AuthorDate: Wed Dec 13 10:26:11 2023 +0200
Bump Pulsar version to 3.1.1 (#144)
---
gradle/libs.versions.toml | 2 +-
.../apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
index ac44663..cf4268b 100644
--- a/gradle/libs.versions.toml
+++ b/gradle/libs.versions.toml
@@ -17,7 +17,7 @@
# under the License.
#
[versions]
-pulsar = "3.1.0"
+pulsar = "3.1.1"
junit-jupiter = "5.8.2"
log4j = "2.18.0"
slf4j = "1.7.36"
diff --git
a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
index fe79e13..868e06b 100644
---
a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
+++
b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
@@ -44,7 +44,7 @@ final class SingletonPulsarContainer {
}
static DockerImageName getPulsarImage() {
- return DockerImageName.parse("apachepulsar/pulsar:3.1.0");
+ return DockerImageName.parse("apachepulsar/pulsar:3.1.1");
}
}
(pulsar-client-reactive) annotated tag v0.5.0 updated (b8294e4 -> 51c09dd)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.5.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.5.0 was modified! *** from b8294e4 (commit) to 51c09dd (tag) tagging b8294e41540d0932f7c9b235369e429fe5d44915 (commit) replaces v0.4.0 by Christophe Bornet on Sat Nov 18 02:15:03 2023 +0100 - Log - Release v0.5.0 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZVgQFxMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSe9OUBAPzttqRfaEaz0NAh90F5R+Rkrc6W0bKM LMAs+/X2etVwAQCA+SDVDLKXqiTeU2Cg8ebMEC39YK7HNLsPb6wQBoaSBA== =bw1Y -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r65297 - in /dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2: pulsar-client-reactive-0.5.0-src.tar.gz pulsar-client-reactive-0.5.0-src.tar.gz.asc pulsar-client-reactive-0.5.0-src.tar.g
Author: cbornet Date: Wed Nov 15 08:55:01 2023 New Revision: 65297 Log: Add files for pulsar-client-reactive 0.5.0-candidate-2 release Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz (with props) dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz.asc dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz.sha512 Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz == Binary file - no diff available. Propchange: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz.asc == --- dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz.asc (added) +++ dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz.asc Wed Nov 15 08:55:01 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmVUh1IACgkQFo1l3cYE +67KLqA/+PQ8ZB2gXoNwA1gza01huhkUxC7FdbzNiXwO0dMr1IUtT8BkUzAVS6fQe +kL7nIIMQsME7fnvDYJ8qkOZnLDYFZzlwhNDkgelUb9MuearKbW70PrfNvsJZpyel +9cr21kwRZiULd5qBKOR+H1chLZtYTk3/hkYtuTUGzyuabpFvMCrWSfjCTAUzeSUH +S5iCUbW2aMdXDrws3WEWbOA6Cs3ckLGA+pi0NX3LMeKlUqgAUMWwTjvhQEwK6iao +PIhVCB7mUamvreJzYLw3iuPvKW6+oGEBRLIIS2kPiHBPiicIvXRj/ieIM0O9oG/K +3bkOzYZML/MTqrAnH8vfsUhrd9T7sSGWoZGdPTZbvlku6NkhcmlvWmVSsCLlLAcA +/DGn8M+qRPLudnHISMvW03YtBUPBzRRo4hfzTma9zrIWXr3LBiKzpt6UIJm5FIVf +iH36Hfxkg8+bPR52BmvNG+az/q9qOrqKmvn6h8F0lONdnbapJH56w3mpKF3z2bKM +TX+E1YLEXOP9wsjFY+mz1F3uKpdZywuWk86J1cyHQxA+5yCXNDAsaK2pSCx2wiT7 +sq4dklpyFNbcBcCRQDYfBt9FlNj9Wa7Mhxx1vG595XWVD8YZQyeQsUw659NUqmgt +mfv0t2I3qeLmDmSQxSw3Rp87HVhpz7qcua3neU9e3rSiXpDhoNo= +=b88i +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz.sha512 == --- dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz.sha512 (added) +++ dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/pulsar-client-reactive-0.5.0-src.tar.gz.sha512 Wed Nov 15 08:55:01 2023 @@ -0,0 +1 @@ +932a8942a1c6249d7cf85ee657633ebf2d38fac24aa5e5c5821ba99e665aa7e3ea785b1e2587688920fe8878a8f24318dc1aaa40ad5b3eb4b234a46425270660 pulsar-client-reactive-0.5.0-src.tar.gz
svn commit: r65296 - /dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/
Author: cbornet Date: Wed Nov 15 08:54:11 2023 New Revision: 65296 Log: Add directory for pulsar-client-reactive 0.5.0-candidate-2 release Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-2/
(pulsar-client-reactive) annotated tag v0.5.0-candidate-2 updated (b8294e4 -> 5c09c1f)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.5.0-candidate-2 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.5.0-candidate-2 was modified! *** from b8294e4 (commit) to 5c09c1f (tag) tagging b8294e41540d0932f7c9b235369e429fe5d44915 (commit) replaces v0.4.0 by Christophe Bornet on Wed Nov 15 09:53:20 2023 +0100 - Log - Release v0.5.0-candidate-2 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZVSHABMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeW2wBAIKhSNULetX+oTZNBccG3Yxny4o2M9yW M0csTgZ7fIECAQDAT/JqFolg6DNbMG6bHK4az28S77L/BMTmnoc5PWuWAQ== =DfFf -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r65295 - in /dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1: pulsar-client-reactive-0.5.0-src.tar.gz pulsar-client-reactive-0.5.0-src.tar.gz.asc pulsar-client-reactive-0.5.0-src.tar.g
Author: cbornet Date: Wed Nov 15 08:36:41 2023 New Revision: 65295 Log: Add files for pulsar-client-reactive 0.5.0-candidate-1 release Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz (with props) dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz.asc dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz.sha512 Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz == Binary file - no diff available. Propchange: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz.asc == --- dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz.asc (added) +++ dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz.asc Wed Nov 15 08:36:41 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmVUgv4ACgkQFo1l3cYE +67LlBA/+LO02Kv7JCHMbR9399Y3VrQZYhGApJi+c6k3F/XBB3LS5WFnwfTvmW4oI +i0+HR5wl1Qymi/WRvZg3kH0BZDHcju4fXAbWviQnUOWCGBpzeS0nNTORvmPDW5CN +DQS5V12L49SrC0EQz329697gKn81WtZEgf6M4n6EtgOoyg9BfXM+edhN4cxDiXzr +eguXO27Wr6x9Djomx7sl7dORmogqPUo+W8sRZf+3uyjsi9VoGg79zf1MzS43QND1 +FJBgN5UdHtAv05TIzJtub4JuFwCLUJ9xsoJ1BxuxkQT0NLctEzKkaRLh43miCOji +qj/RSw3LTQ4iud9nSYC+R30vwxhdxZS6PjKN2jNtEL2fM/H1bqQG/48tN6XYOtpZ +Enfn98ylYye0+UH/0i9V8P5kxXGS9mlUdzcyt+dTQzgJKHYSoEZt1PR/RVGigRQl +pu4WnC0fFhWsrooIfguCNd3YFsgvHQ71ttEPlSb9gE7/MiJLA+oUffhLv812h7jM +iqB6bY68zJXbeO/enXIQjqsBlAzjZKFOaPZzX34vHgzs9Rdk3fumuWpC6kknvKbp +vKzG79WpzpU9LE+vNqT/Rzru/k89kAJ9KefYDkzb8BiMvQzmd0siJ+QNF+Xzj77i +QoLIZNXDaG0hbrIzJM5v4/j14wqng/9ex6skwd/u0cvUmjQ9YQ4= +=Lgyd +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz.sha512 == --- dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz.sha512 (added) +++ dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/pulsar-client-reactive-0.5.0-src.tar.gz.sha512 Wed Nov 15 08:36:41 2023 @@ -0,0 +1 @@ +932a8942a1c6249d7cf85ee657633ebf2d38fac24aa5e5c5821ba99e665aa7e3ea785b1e2587688920fe8878a8f24318dc1aaa40ad5b3eb4b234a46425270660 pulsar-client-reactive-0.5.0-src.tar.gz
svn commit: r65294 - /dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/
Author: cbornet Date: Wed Nov 15 08:35:15 2023 New Revision: 65294 Log: Add directory for pulsar-client-reactive 0.5.0-candidate-1 release Added: dev/pulsar/pulsar-client-reactive-0.5.0-candidate-1/
(pulsar-client-reactive) annotated tag v0.5.0-candidate-1 updated (3318229 -> 3f3b1d5)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.5.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.5.0-candidate-1 was modified! *** from 3318229 (commit) to 3f3b1d5 (tag) tagging 331822978af9e62bc196c222a388c6385cac4378 (commit) replaces v0.4.0 by Christophe Bornet on Wed Nov 15 09:32:53 2023 +0100 - Log - Release v0.5.0-candidate-1 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZVSCNhMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeqrkBAKDXKvq3b2tOm1e1W6LdaUT1v8oBfcZQ GelwHwR8U40lAQDdhEAtJPR4I30Jkzajk2IUMIuGXYzdQgbalb/xd7V+DQ== =dpfi -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
(pulsar-client-reactive) branch main updated: Bump version to 0.5.0 (#139)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git The following commit(s) were added to refs/heads/main by this push: new b8294e4 Bump version to 0.5.0 (#139) b8294e4 is described below commit b8294e41540d0932f7c9b235369e429fe5d44915 Author: Christophe Bornet AuthorDate: Wed Nov 15 09:31:00 2023 +0100 Bump version to 0.5.0 (#139) --- gradle.properties | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gradle.properties b/gradle.properties index 13ba976..d7f6de4 100644 --- a/gradle.properties +++ b/gradle.properties @@ -17,4 +17,4 @@ # under the License. # -version=0.5.0-SNAPSHOT +version=0.5.0
[pulsar-client-reactive] annotated tag v0.4.0 updated (01bf7dc -> 7d445b8)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.4.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.4.0 was modified! *** from 01bf7dc (commit) to 7d445b8 (tag) tagging 01bf7dcf9a7379e4b325c2f6d0d43ec6c451a670 (commit) replaces v0.2.0 by Christophe Bornet on Mon Oct 9 14:20:26 2023 -0300 - Log - Release v0.4.0 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZSQ2WxMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeWM4BAIEUPTXg6NqKHeQYOq1xR9Mo5M/ztabm gVQs/cdRNL1NAP9VoVIlZwMSwRzlkrHgZXvszxq1KJiHeOOZ2h5mrc2QBQ== =tmnD -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r64204 - in /dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1: pulsar-client-reactive-0.4.0-src.tar.gz pulsar-client-reactive-0.4.0-src.tar.gz.asc pulsar-client-reactive-0.4.0-src.tar.g
Author: cbornet Date: Tue Sep 26 09:50:03 2023 New Revision: 64204 Log: Add files for pulsar-client-reactive 0.4.0-candidate-1 release Added: dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz (with props) dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz.asc dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz.sha512 Added: dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz == Binary file - no diff available. Propchange: dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz.asc == --- dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz.asc (added) +++ dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz.asc Tue Sep 26 09:50:03 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmUSqQIACgkQFo1l3cYE +67LhJw/+MeI40Wl/l3/YpM35GtthBsVPvQFsOyw8sPedzoApvMVYC4LB0RZLkmXv +wqDS5UWSW6dTG7XyqHHvzWNrH2mJepddQf9HBuB1dSOTTT1IfKHdGe/e/0KHolnW +M62VUt7SzbDCQ054zcW4qCWasQt0aTg/YkeyB5GScJIMQyakN2X2tT2oNqxM9VXo +/VXOyQ9Ad8qC/TL1DLpbYLtSRrT1clu8gzUzbtmxW4qR8dLdRfDW/S5j6IZN6sTh +rC1IKlhwI7XfyUfV66pP+xPqbcETu12sQNDPs317QWiA9EcNRJwkPvFO2BnNdvgK +lBnimIjYgL/qc/iq6JBPSRePsOhrVkXX74RmBre3tVsU8pi0P5+WUZzYigoUQEBh +HLlXAB5GEo7WqAimNK0yejf0r8iVHV8/mzzefsvw4iFutPxXwMCLajOJXe7Rpy/O +s5TdMLb1lKs0g5gc9FZQn2lrX+0Hz/SykkYbZ62u/KJ7giiKegWJJqYiG8yuD9Rl +4bFmYSw0NaDqpy2b1riZL7pVr8nhw0IeWOzIglM2bLoqEOVqve86PmrL4xdPlOtv +fURmdY5gvOqwuPrH+U6HtXxP3v0vGMl5jUuHD6oKEGSgkiDLE9waLinWTq9jEN9u +CRaLkJ9ZJl3Rlr2LOe5aESe6b97+j3ZpVVlcLcSR6FiCfno0Nds= +=2T70 +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz.sha512 == --- dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz.sha512 (added) +++ dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/pulsar-client-reactive-0.4.0-src.tar.gz.sha512 Tue Sep 26 09:50:03 2023 @@ -0,0 +1 @@ +289589bd6c37e0ddb3903c0d628e1edb9bb33a7868a86d99af82770cb13a9414f049ff7db0317366e245de2eb89320a5a483a5d0e7381739d303f4e84a166607 pulsar-client-reactive-0.4.0-src.tar.gz
svn commit: r64203 - /dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/
Author: cbornet Date: Tue Sep 26 09:43:29 2023 New Revision: 64203 Log: Add directory for pulsar-client-reactive 0.4.0-candidate-1 release Added: dev/pulsar/pulsar-client-reactive-0.4.0-candidate-1/
[pulsar-client-reactive] annotated tag v0.4.0-candidate-1 updated (01bf7dc -> b0e5fb1)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.4.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.4.0-candidate-1 was modified! *** from 01bf7dc (commit) to b0e5fb1 (tag) tagging 01bf7dcf9a7379e4b325c2f6d0d43ec6c451a670 (commit) replaces v0.2.0 by Christophe Bornet on Tue Sep 26 11:38:19 2023 +0200 - Log - Release v0.4.0-candidate-1 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZRKmixMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSe7UEBAOjITPFLDTTtxKgdYTwxZh5g2etIhn6T PQ5htnI5LjO2AP95nuxXreF08HcxTNbIjDQ/FK//J6f5wBcyfaxUrZU2Bg== =cvpL -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
[pulsar-client-reactive] branch main updated: Bump version to 0.4.0 (#135)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git The following commit(s) were added to refs/heads/main by this push: new 01bf7dc Bump version to 0.4.0 (#135) 01bf7dc is described below commit 01bf7dcf9a7379e4b325c2f6d0d43ec6c451a670 Author: Christophe Bornet AuthorDate: Tue Sep 26 11:36:26 2023 +0200 Bump version to 0.4.0 (#135) --- gradle.properties | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gradle.properties b/gradle.properties index 25a8113..f72f201 100644 --- a/gradle.properties +++ b/gradle.properties @@ -17,4 +17,4 @@ # under the License. # -version=0.3.1-SNAPSHOT +version=0.4.0
[pulsar-client-reactive] branch cbornet-patch-1 deleted (was 4e43e8c)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch cbornet-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git was 4e43e8c Update snapshot version The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
[pulsar-client-reactive] branch main updated: Update to Pulsar 3.1.0 (#134)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git
The following commit(s) were added to refs/heads/main by this push:
new 3ecb59f Update to Pulsar 3.1.0 (#134)
3ecb59f is described below
commit 3ecb59fc7f385893f4a1280dd9133626800884fc
Author: Chris Bono
AuthorDate: Mon Aug 28 02:55:56 2023 -0500
Update to Pulsar 3.1.0 (#134)
Fixes #133
---
gradle/libs.versions.toml | 2 +-
.../apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
index 58fe2f4..d298b2c 100644
--- a/gradle/libs.versions.toml
+++ b/gradle/libs.versions.toml
@@ -17,7 +17,7 @@
# under the License.
#
[versions]
-pulsar = "3.0.1"
+pulsar = "3.1.0"
junit-jupiter = "5.8.2"
log4j = "2.18.0"
slf4j = "1.7.36"
diff --git
a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
index 2d51927..fe79e13 100644
---
a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
+++
b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java
@@ -44,7 +44,7 @@ final class SingletonPulsarContainer {
}
static DockerImageName getPulsarImage() {
- return DockerImageName.parse("apachepulsar/pulsar:3.0.1");
+ return DockerImageName.parse("apachepulsar/pulsar:3.1.0");
}
}
[pulsar-client-reactive] branch cbornet-patch-1 created (now 4e43e8c)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch cbornet-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git at 4e43e8c Update snapshot version This branch includes the following new commits: new 4e43e8c Update snapshot version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[pulsar-client-reactive] 01/01: Update snapshot version
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch cbornet-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git commit 4e43e8c7a4ba59cf4e9d453f8891cca60a250eac Author: Christophe Bornet AuthorDate: Mon Aug 14 21:06:11 2023 +0200 Update snapshot version --- gradle.properties | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gradle.properties b/gradle.properties index 8cbe804..25a8113 100644 --- a/gradle.properties +++ b/gradle.properties @@ -17,4 +17,4 @@ # under the License. # -version=0.2.1-SNAPSHOT +version=0.3.1-SNAPSHOT
[pulsar] branch master updated: [cleanup][io] Cleanup Kafka connector (#20721)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 54f0ca1c769 [cleanup][io] Cleanup Kafka connector (#20721)
54f0ca1c769 is described below
commit 54f0ca1c769638000fbeb4d73a565216c0992c32
Author: Christophe Bornet
AuthorDate: Sat Jul 22 21:40:47 2023 +0200
[cleanup][io] Cleanup Kafka connector (#20721)
---
.../org/apache/pulsar/functions/api/Record.java| 2 +-
.../apache/pulsar/io/kafka/AvroSchemaCache.java| 4 +-
.../pulsar/io/kafka/ByteBufferSchemaWrapper.java | 2 +-
.../pulsar/io/kafka/BytesWithKafkaSchema.java | 4 +-
.../apache/pulsar/io/kafka/KafkaAbstractSink.java | 2 +-
.../pulsar/io/kafka/KafkaAbstractSource.java | 25 +--
.../org/apache/pulsar/io/kafka/KafkaBytesSink.java | 2 +-
.../apache/pulsar/io/kafka/KafkaBytesSource.java | 36 ++--
.../apache/pulsar/io/kafka/KafkaSinkConfig.java| 7 -
.../apache/pulsar/io/kafka/KafkaSourceConfig.java | 7 -
.../apache/pulsar/io/kafka/KafkaStringSource.java | 6 +-
.../io/kafka/ByteBufferSchemaWrapperTest.java | 8 +-
.../pulsar/io/kafka/KafkaBytesSourceTest.java | 201 +++--
.../io/kafka/sink/KafkaAbstractSinkTest.java | 4 +-
.../io/kafka/source/KafkaAbstractSourceTest.java | 19 +-
15 files changed, 158 insertions(+), 171 deletions(-)
diff --git
a/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Record.java
b/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Record.java
index ea6987e5f03..0487b3d02b3 100644
---
a/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Record.java
+++
b/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Record.java
@@ -27,7 +27,7 @@ import
org.apache.pulsar.common.classification.InterfaceAudience;
import org.apache.pulsar.common.classification.InterfaceStability;
/**
- * Pulsar Connect's Record interface. Record encapsulates the information
about a record being read from a Source.
+ * Pulsar IO's Record interface. Record encapsulates the information about a
record being read from a Source.
*/
@InterfaceAudience.Public
@InterfaceStability.Stable
diff --git
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/AvroSchemaCache.java
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/AvroSchemaCache.java
index f0ad79549eb..4e3abe245be 100644
---
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/AvroSchemaCache.java
+++
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/AvroSchemaCache.java
@@ -38,9 +38,9 @@ final class AvroSchemaCache {
private final LoadingCache> cache =
CacheBuilder
.newBuilder()
.maximumSize(100)
-.build(new CacheLoader>() {
+.build(new CacheLoader<>() {
@Override
-public Schema load(Integer schemaId) throws
Exception {
+public Schema load(Integer schemaId) {
return fetchSchema(schemaId);
}
});
diff --git
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/ByteBufferSchemaWrapper.java
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/ByteBufferSchemaWrapper.java
index fb4683e511d..aefe62e3857 100644
---
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/ByteBufferSchemaWrapper.java
+++
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/ByteBufferSchemaWrapper.java
@@ -29,7 +29,7 @@ import org.apache.pulsar.common.schema.SchemaInfo;
class ByteBufferSchemaWrapper implements Schema {
private final Supplier original;
-public ByteBufferSchemaWrapper(Schema original) {
+public ByteBufferSchemaWrapper(Schema original) {
this(original::getSchemaInfo);
}
diff --git
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java
index f0429c92eed..585cd927c30 100644
---
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java
+++
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/BytesWithKafkaSchema.java
@@ -26,6 +26,6 @@ import lombok.Value;
*/
@Value
public class BytesWithKafkaSchema {
-private final ByteBuffer value;
-private final int schemaId;
+ByteBuffer value;
+int schemaId;
}
diff --git
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java
index 8fbd6c81861..5ceea4dec8d 100644
---
a/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java
+++
b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java
@@ -44,7 +44
[pulsar] branch master updated: [cleanup][broker] Various cleanups (#20658)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 8d5303514ef [cleanup][broker] Various cleanups (#20658)
8d5303514ef is described below
commit 8d5303514efa6cf0fa98c7285339a11821c7cf79
Author: Christophe Bornet
AuthorDate: Fri Jun 30 14:35:21 2023 +0200
[cleanup][broker] Various cleanups (#20658)
---
.../pulsar/broker/BookKeeperClientFactoryImpl.java | 3 +-
.../pulsar/broker/ManagedLedgerClientFactory.java | 18 +--
.../org/apache/pulsar/broker/PulsarService.java| 51 ---
.../broker/TransactionMetadataStoreService.java| 32 ++--
.../pulsar/broker/loadbalance/LoadManager.java | 17 +--
.../pulsar/broker/namespace/NamespaceService.java | 169 ++---
.../pulsar/broker/web/PulsarWebResource.java | 27 ++--
.../apache/pulsar/broker/web/RequestWrapper.java | 2 +-
.../pulsar/broker/web/ResponseHandlerFilter.java | 8 +-
.../apache/pulsar/broker/web/RestException.java| 4 +-
.../org/apache/pulsar/broker/web/WebService.java | 4 +-
11 files changed, 152 insertions(+), 183 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
index 0259dfc7a58..0ecca755956 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
@@ -49,7 +49,6 @@ import
org.apache.pulsar.metadata.api.extended.MetadataStoreExtended;
import org.apache.pulsar.metadata.bookkeeper.AbstractMetadataDriver;
import org.apache.pulsar.metadata.bookkeeper.PulsarMetadataClientDriver;
-@SuppressWarnings("deprecation")
@Slf4j
public class BookKeeperClientFactoryImpl implements BookKeeperClientFactory {
@@ -71,7 +70,7 @@ public class BookKeeperClientFactoryImpl implements
BookKeeperClientFactory {
ClientConfiguration bkConf = createBkClientConfiguration(store, conf);
if (properties != null) {
-properties.forEach((key, value) -> bkConf.setProperty(key, value));
+properties.forEach(bkConf::setProperty);
}
if (ensemblePlacementPolicyClass.isPresent()) {
setEnsemblePlacementPolicy(bkConf, conf, store,
ensemblePlacementPolicyClass.get());
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java
index d86649abd3c..51fb8bc1ae3 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java
@@ -158,17 +158,15 @@ public class ManagedLedgerClientFactory implements
ManagedLedgerStorage {
// factory, however that might be introducing more unknowns.
log.warn("Encountered exceptions on closing bookkeeper
client", ree);
}
-if (bkEnsemblePolicyToBkClientMap != null) {
-bkEnsemblePolicyToBkClientMap.forEach((policy, bk) -> {
-try {
-if (bk != null) {
-bk.close();
-}
-} catch (Exception e) {
-log.warn("Failed to close bookkeeper-client for policy
{}", policy, e);
+bkEnsemblePolicyToBkClientMap.forEach((policy, bk) -> {
+try {
+if (bk != null) {
+bk.close();
}
-});
-}
+} catch (Exception e) {
+log.warn("Failed to close bookkeeper-client for policy
{}", policy, e);
+}
+});
log.info("Closed BookKeeper client");
} catch (Exception e) {
log.warn(e.getMessage(), e);
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
index 2b64a8cfb5c..3d1254eec42 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -185,13 +185,12 @@ import org.slf4j.LoggerFactory;
/**
* Main class for Pulsar broker service.
*/
-
@Getter(AccessLevel.PUBLIC)
@Setter(AccessLevel.PROTECTED)
public class PulsarService implements AutoCloseable, ShutdownService {
private static final Logger LOG =
LoggerFactory.getLogger(PulsarService.class);
private static final double
GRACEFUL_SHUTDOWN_TIMEOUT_RATIO_OF_TOT
[pulsar-site] 01/01: Add PIP 193 to 3.0 release note
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch rn-pip-193 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git commit 098ca12bb426001d8bc7deb42ce39b42a63de87e Author: Christophe Bornet AuthorDate: Sat May 6 17:16:55 2023 +0200 Add PIP 193 to 3.0 release note --- release-notes/versioned/pulsar-3.0.0.md | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/release-notes/versioned/pulsar-3.0.0.md b/release-notes/versioned/pulsar-3.0.0.md index 17ac149db98..b02ba2a8739 100644 --- a/release-notes/versioned/pulsar-3.0.0.md +++ b/release-notes/versioned/pulsar-3.0.0.md @@ -34,10 +34,11 @@ sidebar_label: Apache Pulsar 3.0.0 - PIP-169 Support split bundle by flow or qps [#16782](https://github.com/apache/pulsar/pull/16782) - PIP-188: Cluster migration or Blue-Green cluster deployment support in Pulsar [#16551](https://github.com/apache/pulsar/pull/16551) - PIP-192: New Pulsar Broker Load Balancer [#16691](https://github.com/apache/pulsar/pull/16691) +- PIP-193: Sink preprocessing Function [#16739](https://github.com/apache/pulsar/issues/16739) - PIP-214: Add broker level metrics statistics and expose to prometheus [#18056](https://github.com/apache/pulsar/pull/18056) - PIP-218: Consumer batchReceive() single partition every receive [#18182](https://github.com/apache/pulsar/pull/18182) -- PIP-229: Add a common interface to get fields of the MessageIdData #18950(https://github.com/apache/pulsar/pull/18950) -- PIP-250: Add proxyVersion to CommandConnect #19623(https://github.com/apache/pulsar/pull/19623) +- PIP-229: Add a common interface to get fields of the MessageIdData [#18950](https://github.com/apache/pulsar/pull/18950) +- PIP-250: Add proxyVersion to CommandConnect [#19623](https://github.com/apache/pulsar/pull/19623) - PIP-257: Add Open ID Connect Support to Server Components [#19771](https://github.com/apache/pulsar/pull/19771) ### Broker
[pulsar-site] branch rn-pip-193 created (now 098ca12bb42)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch rn-pip-193 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git at 098ca12bb42 Add PIP 193 to 3.0 release note This branch includes the following new commits: new 098ca12bb42 Add PIP 193 to 3.0 release note The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
svn commit: r61505 [1/2] - in /dev/pulsar/pulsar-3.0.0-candidate-4: ./ connectors/
Author: cbornet Date: Thu Apr 27 08:00:21 2023 New Revision: 61505 Log: Staging artifacts and signature for Pulsar release 3.0.0 Added: dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-3.0.0-bin.tar.gz (with props) dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-3.0.0-bin.tar.gz.asc dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-3.0.0-bin.tar.gz.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-3.0.0-src.tar.gz (with props) dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-3.0.0-src.tar.gz.asc dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-3.0.0-src.tar.gz.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-offloaders-3.0.0-bin.tar.gz (with props) dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-offloaders-3.0.0-bin.tar.gz.asc dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-offloaders-3.0.0-bin.tar.gz.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-shell-3.0.0-bin.tar.gz (with props) dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-shell-3.0.0-bin.tar.gz.asc dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-shell-3.0.0-bin.tar.gz.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-shell-3.0.0-bin.zip (with props) dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-shell-3.0.0-bin.zip.asc dev/pulsar/pulsar-3.0.0-candidate-4/apache-pulsar-shell-3.0.0-bin.zip.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/ dev/pulsar/pulsar-3.0.0-candidate-4/connectors/LICENSE dev/pulsar/pulsar-3.0.0-candidate-4/connectors/README dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-aerospike-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-aerospike-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-aerospike-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-alluxio-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-alluxio-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-alluxio-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-batch-data-generator-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-batch-data-generator-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-batch-data-generator-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-canal-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-canal-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-canal-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-cassandra-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-cassandra-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-cassandra-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-data-generator-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-data-generator-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-data-generator-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mongodb-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mongodb-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mongodb-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mssql-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mssql-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mssql-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mysql-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mysql-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-mysql-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-oracle-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-oracle-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-oracle-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-postgres-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-postgres-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-debezium-postgres-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-dynamodb-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-dynamodb-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-dynamodb-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0
svn commit: r61505 [2/2] - in /dev/pulsar/pulsar-3.0.0-candidate-4: ./ connectors/
Added: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar == Binary file - no diff available. Propchange: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.asc == --- dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.asc (added) +++ dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.asc Thu Apr 27 08:00:21 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmRKKawACgkQFo1l3cYE +67IXqRAAnQSa20/dA59mnC8PgIvFCB3Y0gNH/HhpGcHm3fCWEDGg3A4JDeuskazm ++w9S84xByex13rMUIPueEXupRO1ZXJ8hEKiPIaM8WHjN4DHpvfPTVYrh0mR6I7fx +ngB+nvC4Qvby+m4H5rxJdwba9iwJ/f8I/aEJ8Jxr2KViiG32HscEToI9mrYVJunK +f0J6TrHdP4CNC60+cPkf9OoOxPNQ/+E+QhS9Qbu62VaCmg8SxaPtkKhvk5Dl3mlW +bfZUziaIz0rrpsEE6vq969TRsN23WnvMufaCOjEsnh+0kJrgj2GValPbgpd6od/U +EvIeqf6ng9oVjxmQ7vk6Y5WmU0ZVFdpNHnvPJKgX7P4nyQB0D+17lrddsf+o38z0 +qEYRgJvJMwHIjWukUVSalrEc/AxtHymjMoOgbdMSCxNrRSpbBfk8+GaiTLRnoje4 +LYclDTvTeMlUY3S5O8+5KmPre/qSLfZ5u4NFSmWd7RAWhCoeWKt657j5QcbLCeG0 +DDutU2Ax4ClHIr+WzIrUShLDO24xudJRTjtUBamhN4e+lQS7htHeFyj4Jbdi8VC5 +qIfsvQTPWAUlqC0lcuNqi0lXTft/CApgXGTngGr9S1UzEoJ+sITPpV2VrV/Cc9xZ +Tc/B+C/US6Iij+RId1MTzvFz8T04oRiDDzF+X7Ekg643oBPrH6E= +=ZNSs +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.sha512 == --- dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.sha512 (added) +++ dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.sha512 Thu Apr 27 08:00:21 2023 @@ -0,0 +1 @@ +5c58b33169550a90408c5defbe8944ba028f2a1454be953fe6b65290e4effc8334a617a613e9eb92893a74af977f0823b5c7c6b0ed68e6350e75198018620bdd ./connectors/pulsar-io-jdbc-sqlite-3.0.0.nar Added: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-3.0.0.nar == Binary file - no diff available. Propchange: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-3.0.0.nar -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-3.0.0.nar.asc == --- dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-3.0.0.nar.asc (added) +++ dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-3.0.0.nar.asc Thu Apr 27 08:00:21 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmRKKaIACgkQFo1l3cYE +67IP2w/+Nip2rdx7hk0ekvTpNbn3dts7tvDsKNNUl+gkgO+4uB3Mf93i4D1mZUvK +5/I/+9qUoAtYs6oO3aoLcuIIzj19GpTF05eOjb0l9trrSdJzQMjuQ3lwwWpZi20F +xd3xZD5oa7sahj6t0neAcfTFfYlxJyvhpYD1BLbT2v3QuBTxNQ4NNvTt2czTKaVO +TcBh1fFsHaERidIH66ilpH/Jkb6c7Tm7Swq8A8BVLge7Yq32LGqt7XVRlYXYG9yq +AImejVyKefgoPYR02anUAfNWPw91UFOSUER8PQwKB429Vmoc7YSq4FtTvs0lLQ5k +MJrMwoMIQfV1Hhu1UjXBKId9hRzbvLdk9/KkOwUimPMUVxjWPMSKXEtsU3MFM2uH +zbCKwdKRZqIdz/UGIuAZ4Dg5uDF6bITZSDDXHXLygvvP4WBjgFukfdQPyZOxod04 +xs2ZEoujHFNv9504HOueH87ImUaFjD4sRGUye/GNNISq3piC1zDQBhdPzC2ECwp0 +eRNY6N0v14MciaxfePqYvPbKOwDJJWOwOoTZ5GgjOgaDjotKbLHSiyrkn0kkl1xr +meVgF+FDuJBR/9K4YlhkkoOrYBySLKCMyDwZvDjqDMRBDPsDzCTCPVMWSdijeCDF +eo9g9K0VIxGcHjucAQvr7PPRiDqUdVbRXTbldKB6PBgo/O6JQUk= +=KfX0 +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-3.0.0.nar.sha512 == --- dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-3.0.0.nar.sha512 (added) +++ dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-3.0.0.nar.sha512 Thu Apr 27 08:00:21 2023 @@ -0,0 +1 @@ +a63b3bb2bdf8992f116a1d0b91836095bdfecd9d5427f44a2325c3e224bc6616eb8d9327ca374f1ae6d0a6dec9e52fdc8a0bf93e2a588838177c2b4fc5571444 ./connectors/pulsar-io-kafka-3.0.0.nar Added: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-connect-adaptor-3.0.0.nar == Binary file - no diff available. Propchange: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-connect-adaptor-3.0.0.nar -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-3.0.0-candidate-4/connectors/pulsar-io-kafka-connect-adaptor-3.0.0.nar.asc
svn commit: r61504 - /dev/pulsar/pulsar-3.0.0-candidate-4/
Author: cbornet Date: Thu Apr 27 07:47:58 2023 New Revision: 61504 Log: Add directory for pulsar 3.0.0-candidate-4 release Added: dev/pulsar/pulsar-3.0.0-candidate-4/
[pulsar] annotated tag v3.0.0-candidate-4 updated (7636e8989f4 -> cc8815da611)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v3.0.0-candidate-4 in repository https://gitbox.apache.org/repos/asf/pulsar.git *** WARNING: tag v3.0.0-candidate-4 was modified! *** from 7636e8989f4 (commit) to cc8815da611 (tag) tagging 7636e8989f4d3fc24fce69a356d54e1c550945ed (commit) replaces v3.0.0-candidate-3 by Christophe Bornet on Thu Apr 27 09:30:27 2023 +0200 - Log - Release v3.0.0-candidate-4 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZEokkxMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeD3sA/2Iy/Jpi/lgOy7iESi5Qq/vhO41D5dcH +XeYRSAjgq9YAQDTSh5WGWPgEOdaQbkTKzhLbp5Tne80RH/RAPEWxmM7Dg== =dXJk -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
[pulsar-client-reactive] 01/01: Update README.adoc
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch readme-0.3.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git commit d8dd180ebebea9c6e0ed3e64909b9dce741df3ba Author: Christophe Bornet AuthorDate: Wed Apr 26 15:57:51 2023 +0200 Update README.adoc --- README.adoc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.adoc b/README.adoc index 92af685..131543b 100644 --- a/README.adoc +++ b/README.adoc @@ -19,7 +19,7 @@ = Reactive client for Apache Pulsar :github: https://github.com/apache/pulsar-client-reactive -:latest_version: 0.2.0 +:latest_version: 0.3.0 Reactive client for Apache Pulsar which is compatible with the Reactive Streams specification. This uses Project Reactor as the Reactive Streams implementation.
[pulsar-client-reactive] branch readme-0.3.0 created (now d8dd180)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch readme-0.3.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git at d8dd180 Update README.adoc This branch includes the following new commits: new d8dd180 Update README.adoc The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[pulsar-client-reactive] annotated tag v0.3.0 updated (277d004 -> ffa1d45)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.3.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.3.0 was modified! *** from 277d004 (commit) to ffa1d45 (tag) tagging 277d004cfb16379ccbfea8da87a933c7670475b7 (commit) replaces v0.2.0 by Christophe Bornet on Wed Apr 26 13:59:08 2023 +0200 - Log - Release v0.3.0 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZEkSDBMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeiGUA/jUJfecyMvH7iUCXjGGKOwc2HjUsiZFm PKfMDef2KnjMAPkBwY0rX/IVb4lKyS8lPP4y43GMpCWG4KgWEyJYIm05Ag== =ZDoz -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r61468 [1/2] - in /dev/pulsar/pulsar-3.0.0-candidate-3: ./ connectors/
Author: cbornet Date: Tue Apr 25 08:47:10 2023 New Revision: 61468 Log: Staging artifacts and signature for Pulsar release 3.0.0 Added: dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-3.0.0-bin.tar.gz (with props) dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-3.0.0-bin.tar.gz.asc dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-3.0.0-bin.tar.gz.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-3.0.0-src.tar.gz (with props) dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-3.0.0-src.tar.gz.asc dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-3.0.0-src.tar.gz.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-offloaders-3.0.0-bin.tar.gz (with props) dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-offloaders-3.0.0-bin.tar.gz.asc dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-offloaders-3.0.0-bin.tar.gz.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-shell-3.0.0-bin.tar.gz (with props) dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-shell-3.0.0-bin.tar.gz.asc dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-shell-3.0.0-bin.tar.gz.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-shell-3.0.0-bin.zip (with props) dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-shell-3.0.0-bin.zip.asc dev/pulsar/pulsar-3.0.0-candidate-3/apache-pulsar-shell-3.0.0-bin.zip.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/ dev/pulsar/pulsar-3.0.0-candidate-3/connectors/LICENSE dev/pulsar/pulsar-3.0.0-candidate-3/connectors/README dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-aerospike-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-aerospike-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-aerospike-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-alluxio-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-alluxio-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-alluxio-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-batch-data-generator-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-batch-data-generator-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-batch-data-generator-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-canal-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-canal-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-canal-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-cassandra-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-cassandra-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-cassandra-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-data-generator-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-data-generator-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-data-generator-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mongodb-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mongodb-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mongodb-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mssql-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mssql-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mssql-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mysql-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mysql-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-mysql-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-oracle-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-oracle-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-oracle-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-postgres-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-postgres-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-debezium-postgres-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-dynamodb-3.0.0.nar (with props) dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-dynamodb-3.0.0.nar.asc dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-dynamodb-3.0.0.nar.sha512 dev/pulsar/pulsar-3.0.0
svn commit: r61468 [2/2] - in /dev/pulsar/pulsar-3.0.0-candidate-3: ./ connectors/
Added: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar == Binary file - no diff available. Propchange: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.asc == --- dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.asc (added) +++ dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.asc Tue Apr 25 08:47:10 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmRHj9EACgkQFo1l3cYE +67JvDQ/+M5lpQZjPxgBURC7owIOaxNw/2LlR21zw9GxUb21lLjOEQRAuPDt7RFQy +6MxyAnxUa0LN2xWRQ1pQcKU3MazK3vwToNPWfkwG+tUvenpjsiGc6TcZd2WTz3Bl +mMNrLTFx3+4hBJQ14aMxSXczPlKz8ZsrS0mwBiDzkdUK57jC4OsyHA3GBgDfMlFO +6eobace3vBQyYBn/xGMIhwfpKvlju47Y4okUiFbzDY3yRrkj64RIhxTG7lEezqtp +8LRlKyEvbU7yddY50RTXFThft1htm54kjJx8fJr7qvKXsGBTGCvVhwYIpy6S9OWh +TNekS9lmwbybeu4G/6T2EFEZy3oFCCK1KsUShzPzEgrk7a735ZEevlOZX9+ey0oz +7F2jqSzvA3xU2yZlAcd9zA5tUXNxKd6jMCtym5m6gsmYBRNcg4BQTa3xCoFYeEDj +XlKqXjlnG++B5hJf6T7N385G7ltx7g6CQA2EsMreVDoCPYPyiEVTA1y6+4lDxqla +e0WzRvxS9PZHG98RwT6DUYgkqEuvtsqAW5O7/zSsWIkslJ8jpFhJ/SmIZC5pj4zv +vh+truYghG61bUaWbMR7PKQy0Djk6BdiIVbcx2bD8J0GU+3+JCyu1eVCEE7e6HtA +HQdb6a89vnhEhZGQIQhD1u9sjm3rORO5xN2p+pRjGddQT9vT0E0= +=rgJa +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.sha512 == --- dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.sha512 (added) +++ dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-jdbc-sqlite-3.0.0.nar.sha512 Tue Apr 25 08:47:10 2023 @@ -0,0 +1 @@ +5c58b33169550a90408c5defbe8944ba028f2a1454be953fe6b65290e4effc8334a617a613e9eb92893a74af977f0823b5c7c6b0ed68e6350e75198018620bdd ./connectors/pulsar-io-jdbc-sqlite-3.0.0.nar Added: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-3.0.0.nar == Binary file - no diff available. Propchange: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-3.0.0.nar -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-3.0.0.nar.asc == --- dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-3.0.0.nar.asc (added) +++ dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-3.0.0.nar.asc Tue Apr 25 08:47:10 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmRHj8gACgkQFo1l3cYE +67JDMA//W6GXii9/2ra1hvyTgNcaPnt2L1rSPHsr0bVkL7HpDfrc7D3OunVBeYZM +UNOZomM6afv1RxP4ISfPGg8Z22Zx8qwxGa+O7ajaOuXgIGBNc5j+eBI4zNYN/QWB +IQDfgXLMgmPaMGudZZZF0beoFfhmKWhzrPUyQi/lcd/gZ8XEGt4uwJvhnSvtO/Xb +AbjfOts4fQhIo5X9oFRTO0WAJ+JNktf6tNwUqSrD1P56QlqgXfcVFD9Y/tBYFGXu +ctwPeB5YcqrhmFGFdaL7xs0ageObXkltpyaVLHNAGoSzhaiFagL5b1jOd5pipQaS +VEaSPqZb+kaw6L5MHPRIlZ56Y4fLWX1HJzYwG1hO8b0hM+k+nqq7oEv3dYnR1C2X +ZQDkj61TDBLk8tf0syA7TxqkUer/HoXLy3yIIwQQL3hglkPj45SNFTWK0OJ+uTcT +mnziaZlU4VjARpI1XDvr5n1rLn21BFYLVjRY+TGHDeENsIyjgmA0pBxO9Hj8LBf5 +WzBsUR6hMm5ib8cmwIoxNcEj3uTBbbGSx1NuVuwRwWmCTcrKPLQ6TILwkVJon9xO +ehXE0XMqKiAr9s0cEBd7kCXqZD3kngi74SzGcGH3o/SRir0hA6IWp0Suq4AAZ+2e +d0hkqbpw5xIEGSFrlT2ZGrtjOBYewp4tarvIxOPGYKEVORiZJE8= +=cHds +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-3.0.0.nar.sha512 == --- dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-3.0.0.nar.sha512 (added) +++ dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-3.0.0.nar.sha512 Tue Apr 25 08:47:10 2023 @@ -0,0 +1 @@ +dfad8a5c9f782b6e482ec160265d44eb7ac5306ad8839f1dabfe32e45b8257889a5db589d6630b08c55fbf4c8659aba7131cfaedf177de80c694ad1102d60adf ./connectors/pulsar-io-kafka-3.0.0.nar Added: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-connect-adaptor-3.0.0.nar == Binary file - no diff available. Propchange: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-connect-adaptor-3.0.0.nar -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-3.0.0-candidate-3/connectors/pulsar-io-kafka-connect-adaptor-3.0.0.nar.asc
svn commit: r61467 - /dev/pulsar/pulsar-3.0.0-candidate-3/
Author: cbornet Date: Tue Apr 25 08:29:07 2023 New Revision: 61467 Log: Add directory for pulsar 3.0.0-candidate-3 release Added: dev/pulsar/pulsar-3.0.0-candidate-3/
[pulsar] annotated tag v3.0.0-candidate-3 updated (e8261fcef8d -> 67eb1b866ab)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v3.0.0-candidate-3 in repository https://gitbox.apache.org/repos/asf/pulsar.git *** WARNING: tag v3.0.0-candidate-3 was modified! *** from e8261fcef8d (commit) to 67eb1b866ab (tag) tagging e8261fcef8d76061d378d8a9f3b05a5d115013fe (commit) replaces v3.0.0-candidate-2 by Christophe Bornet on Tue Apr 25 09:58:10 2023 +0200 - Log - Release v3.0.0-candidate-3 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZEeIEhMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeDUkA/0PJyP8rS/hw7UuMNBVYI1d7jz77S+nl Tx+rL1uW6zlrAP9hXDDCTr9Y3mSyMW+9xgOgEnYvloISOwMkcJNjzy0qDw== =C8uK -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
[pulsar] branch branch-3.0 updated: Revert "[fix][broker] Fix entry filter feature for the non-persistent topic (#20141)"
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new e8261fcef8d Revert "[fix][broker] Fix entry filter feature for the
non-persistent topic (#20141)"
e8261fcef8d is described below
commit e8261fcef8d76061d378d8a9f3b05a5d115013fe
Author: Christophe Bornet
AuthorDate: Mon Apr 24 12:10:50 2023 +0200
Revert "[fix][broker] Fix entry filter feature for the non-persistent topic
(#20141)"
This reverts commit e27abe9e128fb71b65ffe06417574c9a7f3facbd.
---
.../service/nonpersistent/NonPersistentTopic.java | 5 ++-
.../broker/service/plugin/FilterEntryTest.java | 15 +++-
.../pulsar/broker/stats/SubscriptionStatsTest.java | 42 +++---
3 files changed, 26 insertions(+), 36 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
index 33258b06726..317b8df6b9a 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
@@ -26,7 +26,7 @@ import com.carrotsearch.hppc.ObjectObjectHashMap;
import io.netty.buffer.ByteBuf;
import io.netty.util.concurrent.FastThreadLocal;
import java.util.ArrayList;
-import java.util.Arrays;
+import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
@@ -199,8 +199,7 @@ public class NonPersistentTopic extends AbstractTopic
implements Topic, TopicPol
// entry internally retains data so, duplicateBuffer should be
release here
duplicateBuffer.release();
if (subscription.getDispatcher() != null) {
-// Dispatcher needs to call the set method to support entry
filter feature.
-
subscription.getDispatcher().sendMessages(Arrays.asList(entry));
+
subscription.getDispatcher().sendMessages(Collections.singletonList(entry));
} else {
// it happens when subscription is created but dispatcher is
not created as consumer is not added
// yet
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/plugin/FilterEntryTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/plugin/FilterEntryTest.java
index b868858646c..4b9d91fbde2 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/plugin/FilterEntryTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/plugin/FilterEntryTest.java
@@ -51,7 +51,6 @@ import org.apache.pulsar.broker.service.AbstractTopic;
import org.apache.pulsar.broker.service.BrokerTestBase;
import org.apache.pulsar.broker.service.Dispatcher;
import org.apache.pulsar.broker.service.EntryFilterSupport;
-import org.apache.pulsar.broker.service.Subscription;
import org.apache.pulsar.broker.service.persistent.PersistentSubscription;
import org.apache.pulsar.broker.service.persistent.PersistentTopic;
import org.apache.pulsar.broker.testcontext.PulsarTestContext;
@@ -287,16 +286,10 @@ public class FilterEntryTest extends BrokerTestBase {
}
-@DataProvider(name = "topicProvider")
-public Object[][] topicProvider() {
-return new Object[][]{
-{"persistent://prop/ns-abc/topic" + UUID.randomUUID()},
-{"non-persistent://prop/ns-abc/topic" + UUID.randomUUID()},
-};
-}
-@Test(dataProvider = "topicProvider")
-public void testFilteredMsgCount(String topic) throws Throwable {
+@Test
+public void testFilteredMsgCount() throws Throwable {
+String topic = "persistent://prop/ns-abc/topic" + UUID.randomUUID();
String subName = "sub";
try (Producer producer =
pulsarClient.newProducer(Schema.STRING)
@@ -305,7 +298,7 @@ public class FilterEntryTest extends BrokerTestBase {
.subscriptionName(subName).subscribe()) {
// mock entry filters
-Subscription subscription = pulsar.getBrokerService()
+PersistentSubscription subscription = (PersistentSubscription)
pulsar.getBrokerService()
.getTopicReference(topic).get().getSubscription(subName);
Dispatcher dispatcher = subscription.getDispatcher();
Field field =
EntryFilterSupport.class.getDeclaredField("entryFilters");
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/SubscriptionStatsTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/SubscriptionStatsTest.java
index d5e0066
[pulsar] 02/04: Revert "[improve][broker] Optimize delayed metadata index bitmap (#20136)"
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit f3572574b132dfb6d5a67011f7fb68096e69e1c7
Author: Christophe Bornet
AuthorDate: Mon Apr 24 11:48:03 2023 +0200
Revert "[improve][broker] Optimize delayed metadata index bitmap (#20136)"
This reverts commit ff59240165c73a9c3a3dcca20702ab44b0b18d33.
---
.../bucket/BucketDelayedDeliveryTracker.java | 3 --
.../broker/delayed/bucket/ImmutableBucket.java | 53 +-
.../broker/delayed/bucket/MutableBucket.java | 11 ++---
3 files changed, 25 insertions(+), 42 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
index b17387e276e..b4d1745e22f 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
@@ -485,9 +485,6 @@ public class BucketDelayedDeliveryTracker extends
AbstractDelayedDeliveryTracker
});
});
}
-
-// optimize bm
-
delayedIndexBitMap.values().forEach(RoaringBitmap::runOptimize);
immutableBucketDelayedIndexPair.getLeft().setDelayedIndexBitMap(delayedIndexBitMap);
afterCreateImmutableBucket(immutableBucketDelayedIndexPair, createStartTime);
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/ImmutableBucket.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/ImmutableBucket.java
index 57de5c84fcd..82e98cefa5d 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/ImmutableBucket.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/ImmutableBucket.java
@@ -20,10 +20,11 @@ package org.apache.pulsar.broker.delayed.bucket;
import static org.apache.bookkeeper.mledger.util.Futures.executeWithRetry;
import static
org.apache.pulsar.broker.delayed.bucket.BucketDelayedDeliveryTracker.NULL_LONG_PROMISE;
-import java.io.IOException;
+import com.google.protobuf.ByteString;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
+import java.util.Map;
import java.util.Optional;
import java.util.concurrent.CompletableFuture;
import java.util.function.Supplier;
@@ -36,8 +37,8 @@ import
org.apache.pulsar.broker.delayed.proto.DelayedMessageIndexBucketSnapshotF
import
org.apache.pulsar.broker.delayed.proto.DelayedMessageIndexBucketSnapshotFormat.DelayedIndex;
import
org.apache.pulsar.broker.delayed.proto.DelayedMessageIndexBucketSnapshotFormat.SnapshotSegmentMetadata;
import org.apache.pulsar.common.util.FutureUtil;
-import org.roaringbitmap.InvalidRoaringFormat;
import org.roaringbitmap.RoaringBitmap;
+import org.roaringbitmap.buffer.ImmutableRoaringBitmap;
@Slf4j
class ImmutableBucket extends Bucket {
@@ -97,7 +98,7 @@ class ImmutableBucket extends Bucket {
this.setLastSegmentEntryId(metadataList.size());
this.recoverDelayedIndexBitMapAndNumber(nextSnapshotEntryIndex, metadataList);
List firstScheduleTimestamps =
metadataList.stream().map(
-
SnapshotSegmentMetadata::getMinScheduleTimestamp).toList();
+
SnapshotSegmentMetadata::getMinScheduleTimestamp).toList();
this.setFirstScheduleTimestamps(firstScheduleTimestamps);
return nextSnapshotEntryIndex + 1;
@@ -138,37 +139,25 @@ class ImmutableBucket extends Bucket {
});
}
-/**
- * Recover delayed index bit map and message numbers.
- * @throws InvalidRoaringFormat invalid bitmap serialization format
- */
private void recoverDelayedIndexBitMapAndNumber(int startSnapshotIndex,
-
List segmentMetaList) {
-delayedIndexBitMap.clear(); // cleanup dirty bm
-final var numberMessages = new MutableLong(0);
-for (int i = startSnapshotIndex; i < segmentMetaList.size(); i++) {
-for (final var entry :
segmentMetaList.get(i).getDelayedIndexBitMapMap().entrySet()) {
-final var ledgerId = entry.getKey();
-final var bs = entry.getValue();
-final var sbm = new RoaringBitmap();
-try {
-sbm.deserialize(bs.asReadOnlyByteBuffer());
-} catch (IOException e) {
-throw new InvalidRoaringFormat
[pulsar] 01/04: Revert "[improve][broker] Cache LedgerHandle in BookkeeperBucketSnapshotStorage (#20117)"
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 49539c20bea1d8b10b8465be5ee632c1c4bdc7ce
Author: Christophe Bornet
AuthorDate: Mon Apr 24 11:46:27 2023 +0200
Revert "[improve][broker] Cache LedgerHandle in
BookkeeperBucketSnapshotStorage (#20117)"
This reverts commit e1d63990644700bf61b3d7af1ef6d4d62145c2bb.
---
.../bucket/BookkeeperBucketSnapshotStorage.java| 52 +++---
.../BookkeeperBucketSnapshotStorageTest.java | 43 --
2 files changed, 26 insertions(+), 69 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java
index 18a4c322f7b..9c30ccf1c0b 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java
@@ -26,7 +26,6 @@ import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ConcurrentHashMap;
import javax.validation.constraints.NotNull;
import lombok.extern.slf4j.Slf4j;
import org.apache.bookkeeper.client.BKException;
@@ -49,8 +48,6 @@ public class BookkeeperBucketSnapshotStorage implements
BucketSnapshotStorage {
private final ServiceConfiguration config;
private BookKeeper bookKeeper;
-private final Map>
ledgerHandleFutureCache = new ConcurrentHashMap<>();
-
public BookkeeperBucketSnapshotStorage(PulsarService pulsar) {
this.pulsar = pulsar;
this.config = pulsar.getConfig();
@@ -69,30 +66,45 @@ public class BookkeeperBucketSnapshotStorage implements
BucketSnapshotStorage {
@Override
public CompletableFuture getBucketSnapshotMetadata(long
bucketId) {
-return getLedgerHandle(bucketId).thenCompose(ledgerHandle ->
getLedgerEntry(ledgerHandle, 0, 0)
-.thenApply(entryEnumeration ->
parseSnapshotMetadataEntry(entryEnumeration.nextElement(;
+return openLedger(bucketId).thenCompose(ledgerHandle -> {
+CompletableFuture snapshotFuture =
+getLedgerEntry(ledgerHandle, 0, 0)
+.thenApply(entryEnumeration ->
parseSnapshotMetadataEntry(entryEnumeration.nextElement()));
+
+snapshotFuture.whenComplete((__, e) -> closeLedger(ledgerHandle));
+
+return snapshotFuture;
+});
}
@Override
public CompletableFuture>
getBucketSnapshotSegment(long bucketId, long firstSegmentEntryId,
long lastSegmentEntryId) {
-return getLedgerHandle(bucketId).thenCompose(
-ledgerHandle -> getLedgerEntry(ledgerHandle,
firstSegmentEntryId, lastSegmentEntryId)
-.thenApply(this::parseSnapshotSegmentEntries));
+return openLedger(bucketId).thenCompose(ledgerHandle -> {
+CompletableFuture> parseFuture =
+getLedgerEntry(ledgerHandle, firstSegmentEntryId,
lastSegmentEntryId)
+.thenApply(this::parseSnapshotSegmentEntries);
+
+parseFuture.whenComplete((__, e) -> closeLedger(ledgerHandle));
+
+return parseFuture;
+});
}
@Override
public CompletableFuture getBucketSnapshotLength(long bucketId) {
-return getLedgerHandle(bucketId).thenCompose(
-ledgerHandle ->
CompletableFuture.completedFuture(ledgerHandle.getLength()));
+return openLedger(bucketId).thenCompose(ledgerHandle -> {
+CompletableFuture lengthFuture =
+
CompletableFuture.completedFuture(ledgerHandle.getLength());
+
+lengthFuture.whenComplete((__, e) -> closeLedger(ledgerHandle));
+
+return lengthFuture;
+});
}
@Override
public CompletableFuture deleteBucketSnapshot(long bucketId) {
-CompletableFuture ledgerHandleFuture =
ledgerHandleFutureCache.remove(bucketId);
-if (ledgerHandleFuture != null) {
-ledgerHandleFuture.whenComplete((lh, ex) -> closeLedger(lh));
-}
return deleteLedger(bucketId);
}
@@ -166,18 +178,6 @@ public class BookkeeperBucketSnapshotStorage implements
BucketSnapshotStorage {
return future;
}
-private CompletableFuture getLedgerHandle(Long ledgerId) {
-CompletableFuture ledgerHandleCompletableFuture =
-ledgerHandleFutureCache.computeIfAbsent(ledgerId, k ->
openLedger(ledgerId));
-// remove future of completed exception
[pulsar] branch branch-3.0 updated (89e4d46f4a5 -> 254f09b70d8)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git from 89e4d46f4a5 [fix] [broker] Make `LeastResourceUsageWithWeight` thread safe (#20159) new 49539c20bea Revert "[improve][broker] Cache LedgerHandle in BookkeeperBucketSnapshotStorage (#20117)" new f3572574b13 Revert "[improve][broker] Optimize delayed metadata index bitmap (#20136)" new 610c5f15143 Revert "[improve][broker] Make timer execute immediately after load index (#20126)" new 254f09b70d8 Revert "[improve] [broker] Close temporary open ledger in BookkeeperBucketSnapshotStorage (#20111)" The 4 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../bucket/BookkeeperBucketSnapshotStorage.java| 33 +++--- .../bucket/BucketDelayedDeliveryTracker.java | 11 ++--- .../broker/delayed/bucket/ImmutableBucket.java | 53 +- .../broker/delayed/bucket/MutableBucket.java | 11 ++--- .../BookkeeperBucketSnapshotStorageTest.java | 43 -- 5 files changed, 36 insertions(+), 115 deletions(-)
[pulsar] 04/04: Revert "[improve] [broker] Close temporary open ledger in BookkeeperBucketSnapshotStorage (#20111)"
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 254f09b70d80640095f2fe6d12ed79f046fb3241
Author: Christophe Bornet
AuthorDate: Mon Apr 24 11:50:50 2023 +0200
Revert "[improve] [broker] Close temporary open ledger in
BookkeeperBucketSnapshotStorage (#20111)"
This reverts commit 1d1a3ef864a65c995ceda4b7875ed934c2574298.
---
.../bucket/BookkeeperBucketSnapshotStorage.java| 33 +-
1 file changed, 7 insertions(+), 26 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java
index 9c30ccf1c0b..e7d4f9301dd 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java
@@ -66,41 +66,22 @@ public class BookkeeperBucketSnapshotStorage implements
BucketSnapshotStorage {
@Override
public CompletableFuture getBucketSnapshotMetadata(long
bucketId) {
-return openLedger(bucketId).thenCompose(ledgerHandle -> {
-CompletableFuture snapshotFuture =
-getLedgerEntry(ledgerHandle, 0, 0)
-.thenApply(entryEnumeration ->
parseSnapshotMetadataEntry(entryEnumeration.nextElement()));
-
-snapshotFuture.whenComplete((__, e) -> closeLedger(ledgerHandle));
-
-return snapshotFuture;
-});
+return openLedger(bucketId).thenCompose(
+ledgerHandle -> getLedgerEntry(ledgerHandle, 0, 0).
+thenApply(entryEnumeration ->
parseSnapshotMetadataEntry(entryEnumeration.nextElement(;
}
@Override
public CompletableFuture>
getBucketSnapshotSegment(long bucketId, long firstSegmentEntryId,
long lastSegmentEntryId) {
-return openLedger(bucketId).thenCompose(ledgerHandle -> {
-CompletableFuture> parseFuture =
-getLedgerEntry(ledgerHandle, firstSegmentEntryId,
lastSegmentEntryId)
-.thenApply(this::parseSnapshotSegmentEntries);
-
-parseFuture.whenComplete((__, e) -> closeLedger(ledgerHandle));
-
-return parseFuture;
-});
+return openLedger(bucketId).thenCompose(
+ledgerHandle -> getLedgerEntry(ledgerHandle,
firstSegmentEntryId,
+
lastSegmentEntryId).thenApply(this::parseSnapshotSegmentEntries));
}
@Override
public CompletableFuture getBucketSnapshotLength(long bucketId) {
-return openLedger(bucketId).thenCompose(ledgerHandle -> {
-CompletableFuture lengthFuture =
-
CompletableFuture.completedFuture(ledgerHandle.getLength());
-
-lengthFuture.whenComplete((__, e) -> closeLedger(ledgerHandle));
-
-return lengthFuture;
-});
+return openLedger(bucketId).thenApply(LedgerHandle::getLength);
}
@Override
[pulsar] 03/04: Revert "[improve][broker] Make timer execute immediately after load index (#20126)"
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 610c5f151436557d51b56e06a97ba422553592d7
Author: Christophe Bornet
AuthorDate: Mon Apr 24 11:49:13 2023 +0200
Revert "[improve][broker] Make timer execute immediately after load index
(#20126)"
This reverts commit 49480ea558e647169e8df01bfd2e871a5386e19e.
---
.../broker/delayed/bucket/BucketDelayedDeliveryTracker.java | 8
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
index b4d1745e22f..f57248acbb7 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
@@ -541,7 +541,7 @@ public class BucketDelayedDeliveryTracker extends
AbstractDelayedDeliveryTracker
@Override
public synchronized NavigableSet getScheduledMessages(int
maxMessages) {
-if (!checkPendingLoadDone()) {
+if (!checkPendingOpDone()) {
if (log.isDebugEnabled()) {
log.debug("[{}] Skip getScheduledMessages to wait for bucket
snapshot load finish.",
dispatcher.getName());
@@ -628,11 +628,11 @@ public class BucketDelayedDeliveryTracker extends
AbstractDelayedDeliveryTracker
if (timeout != null) {
timeout.cancel();
}
-timeout = timer.newTimeout(this, 0,
TimeUnit.MILLISECONDS);
+timeout = timer.newTimeout(this, tickTimeMillis,
TimeUnit.MILLISECONDS);
}
});
-if (!checkPendingLoadDone() ||
loadFuture.isCompletedExceptionally()) {
+if (!checkPendingOpDone() ||
loadFuture.isCompletedExceptionally()) {
break;
}
}
@@ -651,7 +651,7 @@ public class BucketDelayedDeliveryTracker extends
AbstractDelayedDeliveryTracker
return positions;
}
-private synchronized boolean checkPendingLoadDone() {
+private synchronized boolean checkPendingOpDone() {
if (pendingLoad == null || pendingLoad.isDone()) {
pendingLoad = null;
return true;
[pulsar] 02/02: [improve] [broker] Upgrade the BookKeeper dependency to 4.16.1 (#20127)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 13eb2a75f3dc72bed21fdeb4fb0f211a7a0dd3fb Author: Hang Chen AuthorDate: Wed Apr 19 03:01:31 2023 +0800 [improve] [broker] Upgrade the BookKeeper dependency to 4.16.1 (#20127) --- distribution/server/src/assemble/LICENSE.bin.txt | 56 distribution/shell/src/assemble/LICENSE.bin.txt | 6 +-- pom.xml | 2 +- pulsar-sql/presto-distribution/LICENSE | 30 ++--- 4 files changed, 47 insertions(+), 47 deletions(-) diff --git a/distribution/server/src/assemble/LICENSE.bin.txt b/distribution/server/src/assemble/LICENSE.bin.txt index c321e54de2e..c5e69f5cde9 100644 --- a/distribution/server/src/assemble/LICENSE.bin.txt +++ b/distribution/server/src/assemble/LICENSE.bin.txt @@ -346,34 +346,34 @@ The Apache Software License, Version 2.0 - net.java.dev.jna-jna-jpms-5.12.1.jar - net.java.dev.jna-jna-platform-jpms-5.12.1.jar * BookKeeper -- org.apache.bookkeeper-bookkeeper-common-4.16.0.jar -- org.apache.bookkeeper-bookkeeper-common-allocator-4.16.0.jar -- org.apache.bookkeeper-bookkeeper-proto-4.16.0.jar -- org.apache.bookkeeper-bookkeeper-server-4.16.0.jar -- org.apache.bookkeeper-bookkeeper-tools-framework-4.16.0.jar -- org.apache.bookkeeper-circe-checksum-4.16.0.jar -- org.apache.bookkeeper-cpu-affinity-4.16.0.jar -- org.apache.bookkeeper-statelib-4.16.0.jar -- org.apache.bookkeeper-stream-storage-api-4.16.0.jar -- org.apache.bookkeeper-stream-storage-common-4.16.0.jar -- org.apache.bookkeeper-stream-storage-java-client-4.16.0.jar -- org.apache.bookkeeper-stream-storage-java-client-base-4.16.0.jar -- org.apache.bookkeeper-stream-storage-proto-4.16.0.jar -- org.apache.bookkeeper-stream-storage-server-4.16.0.jar -- org.apache.bookkeeper-stream-storage-service-api-4.16.0.jar -- org.apache.bookkeeper-stream-storage-service-impl-4.16.0.jar -- org.apache.bookkeeper.http-http-server-4.16.0.jar -- org.apache.bookkeeper.http-vertx-http-server-4.16.0.jar -- org.apache.bookkeeper.stats-bookkeeper-stats-api-4.16.0.jar -- org.apache.bookkeeper.stats-prometheus-metrics-provider-4.16.0.jar -- org.apache.distributedlog-distributedlog-common-4.16.0.jar -- org.apache.distributedlog-distributedlog-core-4.16.0-tests.jar -- org.apache.distributedlog-distributedlog-core-4.16.0.jar -- org.apache.distributedlog-distributedlog-protocol-4.16.0.jar -- org.apache.bookkeeper.stats-codahale-metrics-provider-4.16.0.jar -- org.apache.bookkeeper-bookkeeper-slogger-api-4.16.0.jar -- org.apache.bookkeeper-bookkeeper-slogger-slf4j-4.16.0.jar -- org.apache.bookkeeper-native-io-4.16.0.jar +- org.apache.bookkeeper-bookkeeper-common-4.16.1.jar +- org.apache.bookkeeper-bookkeeper-common-allocator-4.16.1.jar +- org.apache.bookkeeper-bookkeeper-proto-4.16.1.jar +- org.apache.bookkeeper-bookkeeper-server-4.16.1.jar +- org.apache.bookkeeper-bookkeeper-tools-framework-4.16.1.jar +- org.apache.bookkeeper-circe-checksum-4.16.1.jar +- org.apache.bookkeeper-cpu-affinity-4.16.1.jar +- org.apache.bookkeeper-statelib-4.16.1.jar +- org.apache.bookkeeper-stream-storage-api-4.16.1.jar +- org.apache.bookkeeper-stream-storage-common-4.16.1.jar +- org.apache.bookkeeper-stream-storage-java-client-4.16.1.jar +- org.apache.bookkeeper-stream-storage-java-client-base-4.16.1.jar +- org.apache.bookkeeper-stream-storage-proto-4.16.1.jar +- org.apache.bookkeeper-stream-storage-server-4.16.1.jar +- org.apache.bookkeeper-stream-storage-service-api-4.16.1.jar +- org.apache.bookkeeper-stream-storage-service-impl-4.16.1.jar +- org.apache.bookkeeper.http-http-server-4.16.1.jar +- org.apache.bookkeeper.http-vertx-http-server-4.16.1.jar +- org.apache.bookkeeper.stats-bookkeeper-stats-api-4.16.1.jar +- org.apache.bookkeeper.stats-prometheus-metrics-provider-4.16.1.jar +- org.apache.distributedlog-distributedlog-common-4.16.1.jar +- org.apache.distributedlog-distributedlog-core-4.16.1-tests.jar +- org.apache.distributedlog-distributedlog-core-4.16.1.jar +- org.apache.distributedlog-distributedlog-protocol-4.16.1.jar +- org.apache.bookkeeper.stats-codahale-metrics-provider-4.16.1.jar +- org.apache.bookkeeper-bookkeeper-slogger-api-4.16.1.jar +- org.apache.bookkeeper-bookkeeper-slogger-slf4j-4.16.1.jar +- org.apache.bookkeeper-native-io-4.16.1.jar * Apache HTTP Client - org.apache.httpcomponents-httpclient-4.5.13.jar - org.apache.httpcomponents-httpcore-4.4.15.jar diff --git a/distribution/shell/src/assemble/LICENSE.bin.txt b/distribution/shell/src/assemble/LICENSE.bin.txt index 0ac08caa1c0..cf741622c75 100644 --- a/distribution/shell/src/assemble/LICENSE.bin.txt +++ b
[pulsar] 01/02: [fix][admin] Add javax.xml.bind:jaxb-api to shade (#20106)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 43ef457f2927d2e8276e9e8b0e60e9b004ec2a72 Author: Zixuan Liu AuthorDate: Wed Apr 19 01:27:39 2023 +0800 [fix][admin] Add javax.xml.bind:jaxb-api to shade (#20106) Signed-off-by: nodece --- pulsar-client-admin-shaded/pom.xml | 5 + pulsar-client-all/pom.xml | 5 + 2 files changed, 10 insertions(+) diff --git a/pulsar-client-admin-shaded/pom.xml b/pulsar-client-admin-shaded/pom.xml index ae92f1c7a0d..cdf74cb8eb8 100644 --- a/pulsar-client-admin-shaded/pom.xml +++ b/pulsar-client-admin-shaded/pom.xml @@ -131,6 +131,7 @@ com.yahoo.datasketches:sketches-core org.glassfish.jersey*:* javax.ws.rs:* + javax.xml.bind:jaxb-api jakarta.annotation:* org.glassfish.hk2*:* io.grpc:* @@ -230,6 +231,10 @@ javax.annotation org.apache.pulsar.shade.javax.annotation + + javax.xml.bind + org.apache.pulsar.shade.javax.xml.bind + jersey org.apache.pulsar.shade.jersey diff --git a/pulsar-client-all/pom.xml b/pulsar-client-all/pom.xml index 20be552aed1..5bdc97c3624 100644 --- a/pulsar-client-all/pom.xml +++ b/pulsar-client-all/pom.xml @@ -182,6 +182,7 @@ com.yahoo.datasketches:sketches-core org.glassfish.jersey*:* javax.ws.rs:* + javax.xml.bind:jaxb-api jakarta.annotation:* org.glassfish.hk2*:* io.grpc:* @@ -285,6 +286,10 @@ javax.annotation org.apache.pulsar.shade.javax.annotation + + javax.xml.bind + org.apache.pulsar.shade.javax.xml.bind + jersey org.apache.pulsar.shade.jersey
[pulsar] branch branch-3.0 updated (ad831d159ed -> 13eb2a75f3d)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git from ad831d159ed [improve][broker] Fix ServiceUnitStateCompactionStrategy to cover fast-forward cursor behavior after compaction (#20110) new 43ef457f292 [fix][admin] Add javax.xml.bind:jaxb-api to shade (#20106) new 13eb2a75f3d [improve] [broker] Upgrade the BookKeeper dependency to 4.16.1 (#20127) The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: distribution/server/src/assemble/LICENSE.bin.txt | 56 distribution/shell/src/assemble/LICENSE.bin.txt | 6 +-- pom.xml | 2 +- pulsar-client-admin-shaded/pom.xml | 5 +++ pulsar-client-all/pom.xml| 5 +++ pulsar-sql/presto-distribution/LICENSE | 30 ++--- 6 files changed, 57 insertions(+), 47 deletions(-)
svn commit: r61344 - in /dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1: pulsar-client-reactive-0.3.0-src.tar.gz pulsar-client-reactive-0.3.0-src.tar.gz.asc pulsar-client-reactive-0.3.0-src.tar.g
Author: cbornet Date: Tue Apr 18 13:08:21 2023 New Revision: 61344 Log: Add files for pulsar-client-reactive 0.3.0-candidate-1 release Added: dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz (with props) dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz.asc dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz.sha512 Added: dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz == Binary file - no diff available. Propchange: dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz.asc == --- dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz.asc (added) +++ dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz.asc Tue Apr 18 13:08:21 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmQ+li8ACgkQFo1l3cYE +67I5KxAAok4oc/JQjgdqOwrLO7Jrd0SuZX03xCuaqUZvCdQZBtr6rX66s5CoNwq8 +F1B9B06niDqGZ7jKy4F1BcYlbXP07lpU5+LEOzgb4OYgIvHs3NOibiC5D2POCJbl +BwPoLzRF/rSmjRFk8Heh4KbdNo0qGOej96DGGQKEuy3RYd6V+UmKIRHTCoHAKcOo +9P6Na51TGYZVRnFt5MxazkcPqHF+/vGQzHwFHdnUHy5ZGlr/Pbw+3JKz1bnYTVNR +UXA1rUXYbFMKf/yhulC6mVPEQjiqaafd5zwAl0qhTbBeB7SN0+2YMMyCqmaOja8E +YtqS1QnwikDKy1/1kyT1v6N7f5OVigqLwsIW/UxYItdmcqo0Qq/91F33OV2l3i7h +tSzdRt7vDKVgPs7+2DQBKvph1DRWB7ybnIdwKfxKyS758RcR4xof975CVqyjy2HT +tvzxHSv0hYJPdWUxazvQIKwEY124rGyI7mELJwzLtzRYRrkpyrhWnogrKKYAkUks +Nl2A2aVdyor19T1hrQqiqhHZ0TM4rugzKDsS3k6u8EINRv7a30Odfi4PidE2Seew +Peex8TNyWZwT/tYjXK81iCIRS5sPWAadLH7Cont6j2ktKIHt3IMBrz/ymCGvsx4j +1AIpIDmAUhqihFRlILybQB1BIEXJbsNxY6Z7fWZk1zQj3H8JAvs= +=C668 +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz.sha512 == --- dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz.sha512 (added) +++ dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/pulsar-client-reactive-0.3.0-src.tar.gz.sha512 Tue Apr 18 13:08:21 2023 @@ -0,0 +1 @@ +fbc927bdaaba2873f7e2fff7fa4f778c79294b09b8098ca290bf7f095a42770a2fabece9c5d2ca5212a0b14c30e6f5d02561333804252cff85a0216214c25ff4 pulsar-client-reactive-0.3.0-src.tar.gz
[pulsar-client-reactive] annotated tag v0.3.0-candidate-1 updated (277d004 -> 8b342d9)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.3.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.3.0-candidate-1 was modified! *** from 277d004 (commit) to 8b342d9 (tag) tagging 277d004cfb16379ccbfea8da87a933c7670475b7 (commit) replaces v0.2.0 by Christophe Bornet on Tue Apr 18 15:06:35 2023 +0200 - Log - Release v0.3.0-candidate-1 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZD6V2xMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSe4TgA/RfFr1KExnSyHmhAhtQvj52jv3LH8YVv 8KR2QgY73M7sAQCCFaM9h+zWeMPgfAu6EHXjulcexzZY7BseTQsixJHmDQ== =4LD+ -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r61343 - /dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/
Author: cbornet Date: Tue Apr 18 12:55:35 2023 New Revision: 61343 Log: Add directory for pulsar-client-reactive 0.3.0-candidate-1 release Added: dev/pulsar/pulsar-client-reactive-0.3.0-candidate-1/
[pulsar-client-reactive] annotated tag v0.3.0-candidate-1 updated (64ea60d -> cefa52f)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.3.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.3.0-candidate-1 was modified! *** from 64ea60d (commit) to cefa52f (tag) tagging 64ea60d5c3422d36b5da8c9fbc0224cf0c330428 (commit) replaces v0.2.0 by Christophe Bornet on Tue Apr 18 14:52:44 2023 +0200 - Log - Release v0.3.0-candidate-1 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZD6SnhMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeoaQBAPmcbXlXFhqgtzvDvWBSoLuExtKVslCw 4hZVevHcSUYYAQCFS5WjUZMWnQP4U7nBdro5lLmY1DbWglGJpFcGegUgAw== =RFjM -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r61185 - /dev/pulsar/pulsar-3.0.0-candidate-1/
Author: cbornet Date: Tue Apr 11 21:57:24 2023 New Revision: 61185 Log: Add directory for pulsar 3.0.0-candidate-1 release Added: dev/pulsar/pulsar-3.0.0-candidate-1/
[pulsar] annotated tag v3.0.0-candidate-1 updated (4ef1e00b34a -> 09c7fad1150)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v3.0.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar.git *** WARNING: tag v3.0.0-candidate-1 was modified! *** from 4ef1e00b34a (commit) to 09c7fad1150 (tag) tagging 4ef1e00b34af97a3e7ad8aae86224701e43f101d (commit) replaces vx.y.z.m by Christophe Bornet on Tue Apr 11 23:20:54 2023 +0200 - Log - Release v3.0.0-candidate-1 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZDXPOBMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeIykBAOPrFzHB8K81dcvgEvNVVxYhCfqX/5pz FK6No3zUrLNpAPsHIYKh67KunaW72wfupnKP4fHcxs1CnUSU6zPatnrPAw== =jXto -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
[pulsar] 01/01: Release 3.0.0
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 4ef1e00b34af97a3e7ad8aae86224701e43f101d Author: Christophe Bornet AuthorDate: Tue Apr 11 23:20:12 2023 +0200 Release 3.0.0 --- bouncy-castle/bc/pom.xml | 2 +- bouncy-castle/bcfips-include-test/pom.xml | 2 +- bouncy-castle/bcfips/pom.xml | 2 +- bouncy-castle/pom.xml | 2 +- buildtools/pom.xml| 4 ++-- distribution/io/pom.xml | 2 +- distribution/offloaders/pom.xml | 2 +- distribution/pom.xml | 2 +- distribution/server/pom.xml | 2 +- distribution/shell/pom.xml| 2 +- docker/pom.xml| 2 +- docker/pulsar-all/pom.xml | 2 +- docker/pulsar/pom.xml | 2 +- jclouds-shaded/pom.xml| 2 +- managed-ledger/pom.xml| 2 +- pom.xml | 4 ++-- pulsar-broker-auth-athenz/pom.xml | 2 +- pulsar-broker-auth-oidc/pom.xml | 2 +- pulsar-broker-auth-sasl/pom.xml | 2 +- pulsar-broker-common/pom.xml | 2 +- pulsar-broker/pom.xml | 2 +- pulsar-client-1x-base/pom.xml | 2 +- pulsar-client-1x-base/pulsar-client-1x/pom.xml| 2 +- pulsar-client-1x-base/pulsar-client-2x-shaded/pom.xml | 2 +- pulsar-client-admin-api/pom.xml | 2 +- pulsar-client-admin-shaded/pom.xml| 2 +- pulsar-client-admin/pom.xml | 2 +- pulsar-client-all/pom.xml | 2 +- pulsar-client-api/pom.xml | 2 +- pulsar-client-auth-athenz/pom.xml | 2 +- pulsar-client-auth-sasl/pom.xml | 2 +- pulsar-client-messagecrypto-bc/pom.xml| 2 +- pulsar-client-shaded/pom.xml | 2 +- pulsar-client-tools-api/pom.xml | 2 +- pulsar-client-tools-customcommand-example/pom.xml | 2 +- pulsar-client-tools-test/pom.xml | 2 +- pulsar-client-tools/pom.xml | 2 +- pulsar-client/pom.xml | 2 +- pulsar-common/pom.xml | 2 +- pulsar-config-validation/pom.xml | 2 +- pulsar-functions/api-java/pom.xml | 2 +- pulsar-functions/instance/pom.xml | 2 +- pulsar-functions/java-examples-builtin/pom.xml| 2 +- pulsar-functions/java-examples/pom.xml| 2 +- pulsar-functions/localrun-shaded/pom.xml | 2 +- pulsar-functions/localrun/pom.xml | 2 +- pulsar-functions/pom.xml | 2 +- pulsar-functions/proto/pom.xml| 2 +- pulsar-functions/runtime-all/pom.xml | 2 +- pulsar-functions/runtime/pom.xml | 2 +- pulsar-functions/secrets/pom.xml | 2 +- pulsar-functions/utils/pom.xml| 2 +- pulsar-functions/worker/pom.xml | 2 +- pulsar-io/aerospike/pom.xml | 2 +- pulsar-io/alluxio/pom.xml | 2 +- pulsar-io/aws/pom.xml | 2 +- pulsar-io/batch-data-generator/pom.xml| 2 +- pulsar-io/batch-discovery-triggerers/pom.xml | 2 +- pulsar-io/canal/pom.xml | 2 +- pulsar-io/cassandra/pom.xml | 2 +- pulsar-io/common/pom.xml | 2 +- pulsar-io/core/pom.xml| 2 +- pulsar-io/data-generator/pom.xml | 2 +- pulsar-io/debezium/core/pom.xml | 2 +- pulsar-io/debezium/mongodb/pom.xml| 2 +- pulsar-io/debezium/mssql/pom.xml | 2 +- pulsar-io/debezium/mysql/pom.xml | 2 +- pulsar-io/debezium/oracle/pom.xml | 2 +- pulsar-io/debezium/pom.xml| 2 +- pulsar-io/debezium/postgres/pom.xml | 2 +- pulsar-io/docs/pom.xml| 2 +- pulsar-io/dynamodb/pom.xml| 2 +- pulsar-io/elastic-search/pom.xml | 2 +- pulsar-io/file/pom.xml| 2 +- pulsar-io/flume/pom.xml | 2 +- pulsar-io/hbase/pom.xml
[pulsar] branch branch-3.0 created (now 4ef1e00b34a)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git at 4ef1e00b34a Release 3.0.0 This branch includes the following new commits: new 4ef1e00b34a Release 3.0.0 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[pulsar] branch master updated (4f503fd886c -> f2076b44764)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git from 4f503fd886c [fix] [cli] Fix Broker crashed by too much memory usage of pulsar tools (#20031) add f2076b44764 [fix][test] Fix flaky testCreateTopicWithZombieReplicatorCursor (#20037) No new revisions were added by this update. Summary of changes: .../service/persistent/PersistentTopicTest.java| 29 -- 1 file changed, 22 insertions(+), 7 deletions(-)
[pulsar-site] branch main updated: Add Pulsar Adapters 2.11.0 release (#463)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new ac7876b5600 Add Pulsar Adapters 2.11.0 release (#463)
ac7876b5600 is described below
commit ac7876b56004776a44e215960a97575cb7b4b183
Author: Christophe Bornet
AuthorDate: Thu Mar 9 09:25:52 2023 -0400
Add Pulsar Adapters 2.11.0 release (#463)
---
data/release-pulsar-adapters.js | 1 +
src/components/downloads.tsx| 30 +++---
src/pages/download.mdx | 15 ++-
3 files changed, 38 insertions(+), 8 deletions(-)
diff --git a/data/release-pulsar-adapters.js b/data/release-pulsar-adapters.js
index e92cb8a740f..b2616394b4b 100644
--- a/data/release-pulsar-adapters.js
+++ b/data/release-pulsar-adapters.js
@@ -1,3 +1,4 @@
module.exports = [
+ "2.11.0",
"2.8.0"
]
diff --git a/src/components/downloads.tsx b/src/components/downloads.tsx
index 5054ab0343c..d688805897c 100644
--- a/src/components/downloads.tsx
+++ b/src/components/downloads.tsx
@@ -17,7 +17,7 @@ export function CurrentPulsarManagerVersion(): JSX.Element {
return <>{pulsarManagerReleases[0]}
}
-export function CurrentPulsarAdapterVersion(): JSX.Element {
+export function CurrentPulsarAdaptersVersion(): JSX.Element {
return <>{pulsarAdaptersReleases[0]}
}
@@ -192,11 +192,11 @@ export function CppReleasesDownloadTable(): JSX.Element {
}
-export function CurrentPulsarAdapterDownloadTable(): JSX.Element {
+export function CurrentPulsarAdaptersDownloadTable(): JSX.Element {
const latestPulsarAdaptersVersion = pulsarAdaptersReleases[0]
const data = [
{
-release: "Source",
+release: latestPulsarAdaptersVersion,
link: getLatestAdaptersMirrorUrl(latestPulsarAdaptersVersion),
linkText:
`apache-pulsar-adapters-${latestPulsarAdaptersVersion}-src.tar.gz`,
asc: `${distAdaptersUrl(latestPulsarAdaptersVersion)}.asc`,
@@ -208,6 +208,30 @@ export function CurrentPulsarAdapterDownloadTable():
JSX.Element {
}
+export function ArchivedPulsarAdaptersDownloadTable(): JSX.Element {
+const { siteConfig } = useDocusaurusContext()
+const latestPulsarAdaptersVersion = pulsarAdaptersReleases[0]
+const pulsarAdaptersReleaseInfo = pulsarAdaptersReleases.map((version) =>
({
+version: version,
+srcArchiveUrl: distAdaptersUrl(version),
+}))
+const data = pulsarAdaptersReleaseInfo
+.filter((info) => info.version !== latestPulsarAdaptersVersion)
+.map((info) => {
+const sha = "sha512";
+return {
+release: info.version,
+link: info.srcArchiveUrl,
+linkText: `apache-pulsar-adapters-${info.version}-src.tar.gz`,
+asc: `${info.srcArchiveUrl}.asc`,
+sha512: `${info.srcArchiveUrl}.${sha}`,
+};
+})
+return
+
+
+}
+
export function CurrentPulsarManagerDownloadTable(): JSX.Element {
const latestPulsarManagerVersion = pulsarManagerReleases[0]
const latestPulsarManagerArchiveMirrorUrl =
getLatestPulsarManagerArchiveMirrorUrl(latestPulsarManagerVersion, "bin")
diff --git a/src/pages/download.mdx b/src/pages/download.mdx
index 78a6c0f9548..428db1b6e60 100644
--- a/src/pages/download.mdx
+++ b/src/pages/download.mdx
@@ -8,14 +8,15 @@ hide_table_of_contents: true
import {
CurrentPulsarVersion,
CurrentPulsarManagerVersion,
-CurrentPulsarAdapterVersion,
+CurrentPulsarAdaptersVersion,
CurrentPulsarDownloadTable,
CurrentPulsarOffloadersDownloadTable,
CurrentPulsarConnectorsDownloadTable,
CurrentPulsarShellDownloadTable,
ArchivedPulsarDownloadTable,
CppReleasesDownloadTable,
-CurrentPulsarAdapterDownloadTable,
+CurrentPulsarAdaptersDownloadTable,
+ArchivedPulsarAdaptersDownloadTable,
CurrentPulsarManagerDownloadTable,
ArchivedPulsarManagerDownloadTable,
} from '../components/downloads';
@@ -76,10 +77,14 @@ You must
[verify](https://www.apache.org/info/verification.html) the integrity o
-# Pulsar Adapter
+# Pulsar Adapters
-## Current version
+## Current version
Pulsar Adapters are available on Maven Central, there is no binary package.
-
+
+
+## Older releases
+
+
[pulsar-adapters] annotated tag v2.11.0 updated (3fbd932 -> 77e0c44)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v2.11.0 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git *** WARNING: tag v2.11.0 was modified! *** from 3fbd932 (commit) to 77e0c44 (tag) tagging 3fbd9325920ff3eec3f32d539e1df81603e319f3 (commit) replaces v2.11.0-candidate-2 by Christophe Bornet on Thu Mar 9 11:10:55 2023 +0100 - Log - Release v2.11.0 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCZAmwsBMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSe/EYBAMX9H8u4uZipkbTix5KVlGTq2tGOJ+MG W3d+B39Ci3Q0AP9XixDeaX9wSp5BKX/Fw/An7T3Lc4jZuTMD0zwphpjiDQ== =cY5s -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r60417 - /dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum
Author: cbornet Date: Thu Mar 2 16:52:29 2023 New Revision: 60417 Log: Staging artifacts and signature for Pulsar Adapter 2.11.0-candidate-3 Modified: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum Modified: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum == --- dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum (original) +++ dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum Thu Mar 2 16:52:29 2023 @@ -1 +1 @@ -e476a3e89d66d59f60de874b85c803bac4acf06a871649e86eb2c817c5b7ce115bacd4ceccbf2e78fcb1eb27dbd4f95d081337743d5b2bd7496326348156c212 apache-pulsar-adapters-2.11.0-src.tar.gz +8272f786cb64caa34f8df0e07ea5ce7901e18c67ebf6f3c3cb6d887a7b0b44c6087279ddb5be8abbc62b56600a34060d556937ad9156266fd9d8c6314dc4dcd0 apache-pulsar-adapters-2.11.0-src.tar.gz
svn commit: r60416 - in /dev/pulsar/pulsar-adapters-2.11.0-candidate-3: apache-pulsar-adapters-2.11.0-src.tar.gz apache-pulsar-adapters-2.11.0-src.tar.gz.asc
Author: cbornet Date: Thu Mar 2 16:51:16 2023 New Revision: 60416 Log: Staging artifacts and signature for Pulsar Adapter 2.11.0-candidate-3 Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.asc Modified: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz Modified: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz == Binary files - no diff available. Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.asc == --- dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.asc (added) +++ dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.asc Thu Mar 2 16:51:16 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmQA0VYACgkQFo1l3cYE +67JFsBAAk6wEbwEkOp1Ka58luAyQSkTPHb+xop4p3g9AKFwrtOJ6a/XdXExkXjaX +gGo/+1OOTOPwgCFYBjxzUYOaM583n9R7mNHrJpbeZl+Q7P83AmFYA9Te2y/FTY1V +IU3kdUzHDC6fhfzYqaF5sMcAOOgKrzcIDE8CgNWrcHmGf/GcBtnDKF7qSeAKvxe8 +aSN21pvTTfo+dzcIzrpLssJxIwmJ0YgitfHP5T1XhGy6UgIsjn5jvUuuVX01O6u7 +V7jMVyLiXcBD2lHx91OHads1G/NWxIo7Rx7U2uBI1e5fgL/zK930+rla/C2vNdXU +Opklm6yNkjESP/oE5FpZlz98FTA2SuexosubXxE8936dJXY0Q5SJJzQcCn4jHr3l +CkWdVhil71BpGEhDCCro5U3TUOwvDIULjGj519pVrxklhKXnQ28uPScFao4hgW6p +JRAMe1HICfQNhggSfI7LhlDobduxLeIa/JLeiwsOOqF54xYdX6A5ziaT3mzTvhg9 +Q3Z8EYARCKaeT3Ct9J2241J5GakKoyLZmZggcK6XRM58ngLckSfTIUY5xsZv0p/X +raWfnndZ75yrGEVWHDEu4zgNfzlXvvlX1Nd6hlK+C1VuI70UQ0RO4hfHjHO3kOe7 ++7MINu1AHok6bDduIDF3t1dS6OVJRwTgtjGYMySp8dAguVdOMfs= +=Ggp+ +-END PGP SIGNATURE-
[pulsar-adapters] branch branch-2.11 updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git The following commit(s) were added to refs/heads/branch-2.11 by this push: new 4b25356 [maven-release-plugin] prepare for next development iteration 4b25356 is described below commit 4b2535620377276e1cb9297f27c10681f50bcc25 Author: Christophe Bornet AuthorDate: Thu Mar 2 17:42:00 2023 +0100 [maven-release-plugin] prepare for next development iteration --- examples/kafka-streams/pom.xml| 4 ++-- examples/pom.xml | 2 +- examples/spark/pom.xml| 2 +- pom.xml | 4 ++-- pulsar-client-kafka-compat/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml| 2 +- pulsar-log4j2-appender/pom.xml| 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- tests/pom.xml | 2 +- tests/pulsar-kafka-compat-client-test/pom.xml | 2 +- tests/pulsar-spark-test/pom.xml | 4 ++-- tests/pulsar-storm-test/pom.xml | 4 ++-- 21 files changed, 25 insertions(+), 25 deletions(-) diff --git a/examples/kafka-streams/pom.xml b/examples/kafka-streams/pom.xml index c7b9cf1..4d11dcb 100644 --- a/examples/kafka-streams/pom.xml +++ b/examples/kafka-streams/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT kafka-streams @@ -34,7 +34,7 @@ org.apache.pulsar pulsar-client-kafka - 2.11.0 + 2.11.1-SNAPSHOT diff --git a/examples/pom.xml b/examples/pom.xml index 34c5abf..fe4ec3c 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -24,7 +24,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT org.apache.pulsar.examples diff --git a/examples/spark/pom.xml b/examples/spark/pom.xml index 94b856e..0059887 100644 --- a/examples/spark/pom.xml +++ b/examples/spark/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT spark diff --git a/pom.xml b/pom.xml index 1329418..733b0a7 100644 --- a/pom.xml +++ b/pom.xml @@ -31,7 +31,7 @@ org.apache.pulsar pulsar-adapters - 2.11.0 + 2.11.1-SNAPSHOT Pulsar Adapters A collections of Pulsar adapters. @@ -99,7 +99,7 @@ UTF-8 UTF-8 -165159 +165319 true true diff --git a/pulsar-client-kafka-compat/pom.xml b/pulsar-client-kafka-compat/pom.xml index f5f28d2..539604e 100644 --- a/pulsar-client-kafka-compat/pom.xml +++ b/pulsar-client-kafka-compat/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml index 1b40bfc..791d17b 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml index f0ace9a..59fa9f2 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml index 2056d6c..8a0b602 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml +++ b/pulsar-client-kafka-compat/pulsar
[pulsar-adapters] annotated tag v2.11.0-candidate-3 updated (3fbd932 -> f05d589)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v2.11.0-candidate-3 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git *** WARNING: tag v2.11.0-candidate-3 was modified! *** from 3fbd932 (commit) to f05d589 (tag) tagging 3fbd9325920ff3eec3f32d539e1df81603e319f3 (commit) replaces v2.11.0-candidate-2 by Christophe Bornet on Thu Mar 2 17:41:58 2023 +0100 - Log - [maven-release-plugin] copy for tag v2.11.0-candidate-3 --- No new revisions were added by this update. Summary of changes:
[pulsar-adapters] branch branch-2.11 updated (0a8883b -> 3fbd932)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git from 0a8883b Update Flink Pulsar connector link (#43) add 3fbd932 [maven-release-plugin] prepare release v2.11.0-candidate-3 No new revisions were added by this update. Summary of changes: examples/kafka-streams/pom.xml| 4 ++-- examples/pom.xml | 2 +- examples/spark/pom.xml| 2 +- pom.xml | 6 +++--- pulsar-client-kafka-compat/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml| 2 +- pulsar-log4j2-appender/pom.xml| 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- tests/pom.xml | 2 +- tests/pulsar-kafka-compat-client-test/pom.xml | 2 +- tests/pulsar-spark-test/pom.xml | 4 ++-- tests/pulsar-storm-test/pom.xml | 4 ++-- 21 files changed, 26 insertions(+), 26 deletions(-)
[pulsar-adapters] branch branch-2.11 updated (5ae021d -> 0a8883b)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git discard 5ae021d [maven-release-plugin] prepare for next development iteration omit 9e33bad [maven-release-plugin] prepare release v2.11.0-candidate-3 This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/branch-2.11 (0a8883b) \ O -- O -- O (5ae021d) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
svn commit: r60414 - in /dev/pulsar/pulsar-adapters-2.11.0-candidate-3: apache-pulsar-adapters-2.11.0-src.tar.gz apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum
Author: cbornet Date: Thu Mar 2 16:16:29 2023 New Revision: 60414 Log: Staging artifacts and signature for Pulsar Adapter 2.11.0-candidate-3 Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz (with props) dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz == Binary file - no diff available. Propchange: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum == --- dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum (added) +++ dev/pulsar/pulsar-adapters-2.11.0-candidate-3/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum Thu Mar 2 16:16:29 2023 @@ -0,0 +1 @@ +e476a3e89d66d59f60de874b85c803bac4acf06a871649e86eb2c817c5b7ce115bacd4ceccbf2e78fcb1eb27dbd4f95d081337743d5b2bd7496326348156c212 apache-pulsar-adapters-2.11.0-src.tar.gz
svn commit: r60413 - /dev/pulsar/pulsar-adapters-2.11.0-candidate-3/
Author: cbornet Date: Thu Mar 2 16:16:26 2023 New Revision: 60413 Log: Add directory for pulsar-adapters 2.11.0-candidate-3 release Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-3/
[pulsar-adapters] annotated tag v2.11.0-candidate-3 updated (9e33bad -> 148c9ae)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v2.11.0-candidate-3 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git *** WARNING: tag v2.11.0-candidate-3 was modified! *** from 9e33bad (commit) to 148c9ae (tag) tagging 9e33baddaa6e2076649f7ffc7bbad9c1d1d204ef (commit) replaces v2.11.0-candidate-2 by Christophe Bornet on Thu Mar 2 16:01:25 2023 +0100 - Log - [maven-release-plugin] copy for tag v2.11.0-candidate-3 --- No new revisions were added by this update. Summary of changes:
[pulsar-adapters] branch branch-2.11 updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git The following commit(s) were added to refs/heads/branch-2.11 by this push: new 5ae021d [maven-release-plugin] prepare for next development iteration 5ae021d is described below commit 5ae021d35144f358381303c7dea2834e968675a8 Author: Christophe Bornet AuthorDate: Thu Mar 2 16:01:27 2023 +0100 [maven-release-plugin] prepare for next development iteration --- examples/kafka-streams/pom.xml| 4 ++-- examples/pom.xml | 2 +- examples/spark/pom.xml| 2 +- pom.xml | 4 ++-- pulsar-client-kafka-compat/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml| 2 +- pulsar-log4j2-appender/pom.xml| 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- tests/pom.xml | 2 +- tests/pulsar-kafka-compat-client-test/pom.xml | 2 +- tests/pulsar-spark-test/pom.xml | 4 ++-- tests/pulsar-storm-test/pom.xml | 4 ++-- 21 files changed, 25 insertions(+), 25 deletions(-) diff --git a/examples/kafka-streams/pom.xml b/examples/kafka-streams/pom.xml index c7b9cf1..4d11dcb 100644 --- a/examples/kafka-streams/pom.xml +++ b/examples/kafka-streams/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT kafka-streams @@ -34,7 +34,7 @@ org.apache.pulsar pulsar-client-kafka - 2.11.0 + 2.11.1-SNAPSHOT diff --git a/examples/pom.xml b/examples/pom.xml index 34c5abf..fe4ec3c 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -24,7 +24,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT org.apache.pulsar.examples diff --git a/examples/spark/pom.xml b/examples/spark/pom.xml index 94b856e..0059887 100644 --- a/examples/spark/pom.xml +++ b/examples/spark/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT spark diff --git a/pom.xml b/pom.xml index f84d594..79a3dc0 100644 --- a/pom.xml +++ b/pom.xml @@ -31,7 +31,7 @@ org.apache.pulsar pulsar-adapters - 2.11.0 + 2.11.1-SNAPSHOT Pulsar Adapters A collections of Pulsar adapters. @@ -99,7 +99,7 @@ UTF-8 UTF-8 -1677769133 +1677769286 true true diff --git a/pulsar-client-kafka-compat/pom.xml b/pulsar-client-kafka-compat/pom.xml index f5f28d2..539604e 100644 --- a/pulsar-client-kafka-compat/pom.xml +++ b/pulsar-client-kafka-compat/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml index 1b40bfc..791d17b 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml index f0ace9a..59fa9f2 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml index 2056d6c..8a0b602 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml +++ b/pulsar-client-kafka-compat/pulsar
[pulsar-adapters] branch branch-2.11 updated (0a8883b -> 9e33bad)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git from 0a8883b Update Flink Pulsar connector link (#43) add 9e33bad [maven-release-plugin] prepare release v2.11.0-candidate-3 No new revisions were added by this update. Summary of changes: examples/kafka-streams/pom.xml| 4 ++-- examples/pom.xml | 2 +- examples/spark/pom.xml| 2 +- pom.xml | 6 +++--- pulsar-client-kafka-compat/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml| 2 +- pulsar-log4j2-appender/pom.xml| 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- tests/pom.xml | 2 +- tests/pulsar-kafka-compat-client-test/pom.xml | 2 +- tests/pulsar-spark-test/pom.xml | 4 ++-- tests/pulsar-storm-test/pom.xml | 4 ++-- 21 files changed, 26 insertions(+), 26 deletions(-)
[pulsar-adapters] 02/02: Update Flink Pulsar connector link (#43)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git commit 0a8883b2ee8082843e17345f2f869469ec95dd7a Author: tison AuthorDate: Thu Mar 2 22:51:20 2023 +0800 Update Flink Pulsar connector link (#43) --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 3a72d9f..ce62338 100644 --- a/README.md +++ b/README.md @@ -23,7 +23,7 @@ This repository is used for hosting all the adapters maintained and supported by Apache Pulsar PMC. -[Apache Flink adapter](https://github.com/apache/flink/tree/master/flink-connectors/flink-connector-pulsar) is supported and maintained by Apache Flink Community. +[Apache Flink adapter](https://github.com/apache/flink-connector-pulsar) is supported and maintained by Apache Flink Community. ## Building
[pulsar-adapters] 01/02: Remove dependency on org.apache.pulsar.functions.utils.FunctionCommon in kafka-compat (#44)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git
commit 056104b5e8b3d8e262e0088827a280da6ce61ee2
Author: Christophe Bornet
AuthorDate: Thu Mar 2 10:51:04 2023 -0400
Remove dependency on org.apache.pulsar.functions.utils.FunctionCommon in
kafka-compat (#44)
This class is part of pulsar-functions and is built with a more recent JDK
than the clients
---
.../apache/kafka/clients/admin/PulsarKafkaAdminClient.java | 13 +++--
.../kafka/clients/consumer/PulsarConsumerCoordinator.java | 2 --
2 files changed, 11 insertions(+), 4 deletions(-)
diff --git
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java
index 8196a39..7d3f328 100644
---
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java
+++
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java
@@ -35,10 +35,12 @@ import org.apache.kafka.common.quota.ClientQuotaFilter;
import org.apache.pulsar.client.admin.PulsarAdmin;
import org.apache.pulsar.client.admin.PulsarAdminBuilder;
import org.apache.pulsar.client.admin.PulsarAdminException;
+import org.apache.pulsar.client.api.MessageId;
import org.apache.pulsar.client.api.PulsarClientException;
+import org.apache.pulsar.client.impl.MessageIdImpl;
+import org.apache.pulsar.client.impl.TopicMessageIdImpl;
import org.apache.pulsar.client.kafka.compat.PulsarClientKafkaConfig;
import org.apache.pulsar.common.naming.TopicName;
-import org.apache.pulsar.functions.utils.FunctionCommon;
import java.time.Duration;
import java.util.Collection;
@@ -155,7 +157,7 @@ public class PulsarKafkaAdminClient implements Admin {
.getLastMessageIdAsync(topicName)
.whenComplete((msgId, ex) -> {
if (ex == null) {
-long offset =
FunctionCommon.getSequenceId(msgId);
+long offset = getSequenceId(msgId);
future.complete(new
ListOffsetsResult.ListOffsetsResultInfo(
offset,
System.currentTimeMillis(),
@@ -169,6 +171,13 @@ public class PulsarKafkaAdminClient implements Admin {
return new ListOffsetsResult(new HashMap<>(futures));
}
+private static long getSequenceId(MessageId messageId) {
+MessageIdImpl msgId = (MessageIdImpl)(messageId instanceof
TopicMessageIdImpl ? ((TopicMessageIdImpl)messageId).getInnerMessageId() :
messageId);
+long ledgerId = msgId.getLedgerId();
+long entryId = msgId.getEntryId();
+return ledgerId << 28 | entryId;
+}
+
@Override
public DeleteRecordsResult deleteRecords(Map map, DeleteRecordsOptions deleteRecordsOptions) {
final Map> futures =
diff --git
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarConsumerCoordinator.java
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarConsumerCoordinator.java
index 81f7c49..4e7bd18 100644
---
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarConsumerCoordinator.java
+++
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarConsumerCoordinator.java
@@ -18,10 +18,8 @@
*/
package org.apache.kafka.clients.consumer;
-import com.google.api.client.util.Maps;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
-import org.apache.kafka.clients.GroupRebalanceConfig;
import org.apache.kafka.clients.consumer.internals.PartitionAssignorAdapter;
import org.apache.kafka.common.TopicPartition;
[pulsar-adapters] branch branch-2.11 updated (edf7fe2 -> 0a8883b)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git from edf7fe2 [maven-release-plugin] prepare for next development iteration new 056104b Remove dependency on org.apache.pulsar.functions.utils.FunctionCommon in kafka-compat (#44) new 0a8883b Update Flink Pulsar connector link (#43) The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: README.md | 2 +- .../apache/kafka/clients/admin/PulsarKafkaAdminClient.java | 13 +++-- .../kafka/clients/consumer/PulsarConsumerCoordinator.java | 2 -- 3 files changed, 12 insertions(+), 5 deletions(-)
[pulsar-adapters] branch master updated: Remove dependency on org.apache.pulsar.functions.utils.FunctionCommon in kafka-compat (#44)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git
The following commit(s) were added to refs/heads/master by this push:
new f7f4a9b Remove dependency on
org.apache.pulsar.functions.utils.FunctionCommon in kafka-compat (#44)
f7f4a9b is described below
commit f7f4a9b4ca11037b7235e0522847da053e5c74a9
Author: Christophe Bornet
AuthorDate: Thu Mar 2 10:51:04 2023 -0400
Remove dependency on org.apache.pulsar.functions.utils.FunctionCommon in
kafka-compat (#44)
This class is part of pulsar-functions and is built with a more recent JDK
than the clients
---
.../apache/kafka/clients/admin/PulsarKafkaAdminClient.java | 13 +++--
.../kafka/clients/consumer/PulsarConsumerCoordinator.java | 2 --
2 files changed, 11 insertions(+), 4 deletions(-)
diff --git
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java
index 8196a39..7d3f328 100644
---
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java
+++
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/admin/PulsarKafkaAdminClient.java
@@ -35,10 +35,12 @@ import org.apache.kafka.common.quota.ClientQuotaFilter;
import org.apache.pulsar.client.admin.PulsarAdmin;
import org.apache.pulsar.client.admin.PulsarAdminBuilder;
import org.apache.pulsar.client.admin.PulsarAdminException;
+import org.apache.pulsar.client.api.MessageId;
import org.apache.pulsar.client.api.PulsarClientException;
+import org.apache.pulsar.client.impl.MessageIdImpl;
+import org.apache.pulsar.client.impl.TopicMessageIdImpl;
import org.apache.pulsar.client.kafka.compat.PulsarClientKafkaConfig;
import org.apache.pulsar.common.naming.TopicName;
-import org.apache.pulsar.functions.utils.FunctionCommon;
import java.time.Duration;
import java.util.Collection;
@@ -155,7 +157,7 @@ public class PulsarKafkaAdminClient implements Admin {
.getLastMessageIdAsync(topicName)
.whenComplete((msgId, ex) -> {
if (ex == null) {
-long offset =
FunctionCommon.getSequenceId(msgId);
+long offset = getSequenceId(msgId);
future.complete(new
ListOffsetsResult.ListOffsetsResultInfo(
offset,
System.currentTimeMillis(),
@@ -169,6 +171,13 @@ public class PulsarKafkaAdminClient implements Admin {
return new ListOffsetsResult(new HashMap<>(futures));
}
+private static long getSequenceId(MessageId messageId) {
+MessageIdImpl msgId = (MessageIdImpl)(messageId instanceof
TopicMessageIdImpl ? ((TopicMessageIdImpl)messageId).getInnerMessageId() :
messageId);
+long ledgerId = msgId.getLedgerId();
+long entryId = msgId.getEntryId();
+return ledgerId << 28 | entryId;
+}
+
@Override
public DeleteRecordsResult deleteRecords(Map map, DeleteRecordsOptions deleteRecordsOptions) {
final Map> futures =
diff --git
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarConsumerCoordinator.java
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarConsumerCoordinator.java
index 81f7c49..4e7bd18 100644
---
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarConsumerCoordinator.java
+++
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarConsumerCoordinator.java
@@ -18,10 +18,8 @@
*/
package org.apache.kafka.clients.consumer;
-import com.google.api.client.util.Maps;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
-import org.apache.kafka.clients.GroupRebalanceConfig;
import org.apache.kafka.clients.consumer.internals.PartitionAssignorAdapter;
import org.apache.kafka.common.TopicPartition;
[pulsar-adapters] branch master updated: Update Flink Pulsar connector link (#43)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git The following commit(s) were added to refs/heads/master by this push: new 9c1f67c Update Flink Pulsar connector link (#43) 9c1f67c is described below commit 9c1f67c750cc647a6ce7956db3ab8565e55ee67e Author: tison AuthorDate: Thu Mar 2 22:51:20 2023 +0800 Update Flink Pulsar connector link (#43) --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 3a72d9f..ce62338 100644 --- a/README.md +++ b/README.md @@ -23,7 +23,7 @@ This repository is used for hosting all the adapters maintained and supported by Apache Pulsar PMC. -[Apache Flink adapter](https://github.com/apache/flink/tree/master/flink-connectors/flink-connector-pulsar) is supported and maintained by Apache Flink Community. +[Apache Flink adapter](https://github.com/apache/flink-connector-pulsar) is supported and maintained by Apache Flink Community. ## Building
svn commit: r60411 - in /dev/pulsar/pulsar-adapters-2.11.0-candidate-2: apache-pulsar-adapters-2.11.0-src.tar.gz apache-pulsar-adapters-2.11.0-src.tar.gz.asc apache-pulsar-adapters-2.11.0-src.tar.gz.s
Author: cbornet Date: Thu Mar 2 11:16:14 2023 New Revision: 60411 Log: Staging artifacts and signature for Pulsar Adapter release 2.11.0 Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz (with props) dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz.asc dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz == Binary file - no diff available. Propchange: dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz.asc == --- dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz.asc (added) +++ dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz.asc Thu Mar 2 11:16:14 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmQAgo4ACgkQFo1l3cYE +67L+9w//T3kfjs7mNxx88JWS3qJbHRp9+Y6h1YMmzC3ZzQtbNU9uXUm0rcUpu2XG +CS85cfnXIFWk5+3u6cQKHmRd9RG4bhoVzDdyLNEEP5oQ6RvCJ9v8DVk4qnf7DdWD +3XzNcpcAWu4Jh1yc3YYKrWSPRKOPjG2QLuHh7d3+FvmIY4OtFbGq6qM15ml8y3gk +KtBjsGlvNxfHXNZFRg/Z9QZOtLmztvf7P5YF4IaYJ23TS1F+PGfasGT3EvQ4FHfe +XGOh4YbtnIHOw4f+6CFWTwjt0Ir8MJ9+YQIjPknN33qI3+thAGbpZVcg9s8CDYIc +G3GHkoJrao9GxYe38C2wiKrxarMn6a9nTAG2THKtKyTy9sN1YV9s6EHhPDwdud6F +SnOr7HUXSMxIOOXV4Xak0nghlM1Q6/juzP4zq36lHmTfNdfFwlO+xlv8uCqEgIg0 +FZwONXs/8RJ1qhJMhrshs+QaYdvWySYhdsbnuZPjFgtTuvu5Tb/8tLsklo5vLeyp +Y6NzNath38Z9hi8h/dT2uR3oX0RqG7TkFbbF1FdcwUUoa9wVdA6L4j+DDatwH629 +rBJIbg/kAXGO4hL0Y2CF0opJ+dSRPk1paA+GuxitUoyFKqQWWDZY/p05/30e2er1 +uqGB8jSIsjTXY4brNGNdNk+QL9Yj2vcYE96naWcE7pFeIVY5VpU= +=QDiI +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum == --- dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum (added) +++ dev/pulsar/pulsar-adapters-2.11.0-candidate-2/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum Thu Mar 2 11:16:14 2023 @@ -0,0 +1 @@ +0f46ca28ac0f1f53914969519ebc1c73bf00d8130a8d92f29333e3b22fc429ec7cdb3390b6b85d6c9aec9143a269f76d8f6a68706b802648babac4422d7c77ce apache-pulsar-adapters-2.11.0-src.tar.gz
svn commit: r60408 - /dev/pulsar/pulsar-adapters-2.11.0-candidate-2/
Author: cbornet Date: Thu Mar 2 11:10:12 2023 New Revision: 60408 Log: Add directory for pulsar-adapters 2.11.0-candidate-2 release Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-2/
[pulsar-adapters] annotated tag v2.11.0-candidate-2 updated (663663d -> ca1f3e4)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v2.11.0-candidate-2 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git *** WARNING: tag v2.11.0-candidate-2 was modified! *** from 663663d (commit) to ca1f3e4 (tag) tagging 663663d791887b9884af8b6584591fa64f556af3 (commit) replaces v2.11.0-candidate-1 by Christophe Bornet on Thu Mar 2 12:05:32 2023 +0100 - Log - [maven-release-plugin] copy for tag v2.11.0-candidate-2 --- No new revisions were added by this update. Summary of changes:
[pulsar-adapters] branch branch-2.11 updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git The following commit(s) were added to refs/heads/branch-2.11 by this push: new edf7fe2 [maven-release-plugin] prepare for next development iteration edf7fe2 is described below commit edf7fe2d360aa896d14ce5fb1a2fef3813ba6d92 Author: Christophe Bornet AuthorDate: Thu Mar 2 12:05:34 2023 +0100 [maven-release-plugin] prepare for next development iteration --- examples/kafka-streams/pom.xml| 4 ++-- examples/pom.xml | 2 +- examples/spark/pom.xml| 2 +- pom.xml | 4 ++-- pulsar-client-kafka-compat/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml| 2 +- pulsar-log4j2-appender/pom.xml| 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- tests/pom.xml | 2 +- tests/pulsar-kafka-compat-client-test/pom.xml | 2 +- tests/pulsar-spark-test/pom.xml | 4 ++-- tests/pulsar-storm-test/pom.xml | 4 ++-- 21 files changed, 25 insertions(+), 25 deletions(-) diff --git a/examples/kafka-streams/pom.xml b/examples/kafka-streams/pom.xml index c7b9cf1..4d11dcb 100644 --- a/examples/kafka-streams/pom.xml +++ b/examples/kafka-streams/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT kafka-streams @@ -34,7 +34,7 @@ org.apache.pulsar pulsar-client-kafka - 2.11.0 + 2.11.1-SNAPSHOT diff --git a/examples/pom.xml b/examples/pom.xml index 34c5abf..fe4ec3c 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -24,7 +24,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT org.apache.pulsar.examples diff --git a/examples/spark/pom.xml b/examples/spark/pom.xml index 94b856e..0059887 100644 --- a/examples/spark/pom.xml +++ b/examples/spark/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT spark diff --git a/pom.xml b/pom.xml index 6403852..1239d89 100644 --- a/pom.xml +++ b/pom.xml @@ -31,7 +31,7 @@ org.apache.pulsar pulsar-adapters - 2.11.0 + 2.11.1-SNAPSHOT Pulsar Adapters A collections of Pulsar adapters. @@ -99,7 +99,7 @@ UTF-8 UTF-8 -1677754966 +1677755133 true true diff --git a/pulsar-client-kafka-compat/pom.xml b/pulsar-client-kafka-compat/pom.xml index f5f28d2..539604e 100644 --- a/pulsar-client-kafka-compat/pom.xml +++ b/pulsar-client-kafka-compat/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml index 1b40bfc..791d17b 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml index f0ace9a..59fa9f2 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml index 2056d6c..8a0b602 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml +++ b/pulsar-client-kafka-compat/pulsar
[pulsar-adapters] branch branch-2.11 updated (3e98ed1 -> 663663d)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git from 3e98ed1 [maven-release-plugin] prepare for next development iteration add 8993778 Use an assembly descriptor to configure permissions (#42) add 663663d [maven-release-plugin] prepare release v2.11.0-candidate-2 No new revisions were added by this update. Summary of changes: examples/kafka-streams/pom.xml | 4 +- examples/pom.xml | 2 +- examples/spark/pom.xml | 2 +- pom.xml| 22 ++--- pulsar-client-kafka-compat/pom.xml | 2 +- .../pulsar-client-kafka-shaded/pom.xml | 2 +- .../pulsar-client-kafka-shaded_0_8/pom.xml | 2 +- .../pulsar-client-kafka-shaded_0_9/pom.xml | 2 +- .../pulsar-client-kafka-tests/pom.xml | 2 +- .../pulsar-client-kafka-tests_0_8/pom.xml | 2 +- .../pulsar-client-kafka-tests_0_9/pom.xml | 2 +- .../pulsar-client-kafka/pom.xml| 2 +- .../pulsar-client-kafka_0_8/pom.xml| 2 +- .../pulsar-client-kafka_0_9/pom.xml| 2 +- pulsar-log4j2-appender/pom.xml | 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- src/assembly-source-package.xml| 95 ++ tests/pom.xml | 2 +- tests/pulsar-kafka-compat-client-test/pom.xml | 2 +- tests/pulsar-spark-test/pom.xml| 4 +- tests/pulsar-storm-test/pom.xml| 4 +- 22 files changed, 125 insertions(+), 38 deletions(-) create mode 100644 src/assembly-source-package.xml
[pulsar-adapters] branch master updated: Use an assembly descriptor to configure permissions (#42)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git
The following commit(s) were added to refs/heads/master by this push:
new 45b0d45 Use an assembly descriptor to configure permissions (#42)
45b0d45 is described below
commit 45b0d454781eb38c2485b085ada46ddf9341f7ed
Author: Christophe Bornet
AuthorDate: Thu Mar 2 06:58:32 2023 -0400
Use an assembly descriptor to configure permissions (#42)
---
pom.xml | 16 ++-
src/assembly-source-package.xml | 95 +
2 files changed, 99 insertions(+), 12 deletions(-)
diff --git a/pom.xml b/pom.xml
index fb63323..249585f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -712,13 +712,6 @@
maven-assembly-plugin
${maven-assembly-plugin.version}
false
-
-
- org.apache.apache.resources
-
apache-source-release-assembly-descriptor
- 1.0.6
-
-
source-release-assembly-tar-gz
@@ -729,11 +722,10 @@
${skipSourceReleaseAssembly}
true
-
-
-
${sourceReleaseAssemblyDescriptor}
-
-
apache-pulsar-${project.version}-src
+
+
src/assembly-source-package.xml
+
+
apache-pulsar-adapters-${project.version}-src
false
tar.gz
diff --git a/src/assembly-source-package.xml b/src/assembly-source-package.xml
new file mode 100644
index 000..aba8887
--- /dev/null
+++ b/src/assembly-source-package.xml
@@ -0,0 +1,95 @@
+
+
+
+
+ source-release
+
+tar.gz
+
+
+
+
+ .
+
+ true
+
+
+src/*.sh
+src/*.py
+
+
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/).*${project.build.directory}.*]
+
+
+
+
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?maven-eclipse\.xml]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?\.project]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?\.classpath]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?[^/]*\.iws]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?\.idea(/.*)?]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?out(/.*)?]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?[^/]*\.ipr]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?[^/]*\.iml]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?\.settings(/.*)?]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?\.externalToolBuilders(/.*)?]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?\.deployables(/.*)?]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?\.wtpmodules(/.*)?]
+
+
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?cobertura\.ser]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?pom\.xml\.versionsBackup]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?dependency-reduced-pom\.xml]
+
+
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?pom\.xml\.releaseBackup]
+
%regex[(?!((?!${project.build.directory}/)[^/]+/)*src/)(.*/)?release\.properties]
+
+
+
+
+
${project.build.directory}/maven-shared-archive-resources/META-INF
+
+
+
+ src
+ /src
+
+*.sh
+*.py
+
+ 0755
+
+
+
\ No newline at end of file
svn commit: r60397 - in /dev/pulsar/pulsar-adapters-2.11.0-candidate-1: apache-pulsar-adapters-2.11.0-src.tar.gz apache-pulsar-adapters-2.11.0-src.tar.gz.asc apache-pulsar-adapters-2.11.0-src.tar.gz.s
Author: cbornet Date: Wed Mar 1 12:08:27 2023 New Revision: 60397 Log: Staging artifacts and signature for Pulsar Adapter release 2.11.0 Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz (with props) dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz.asc dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz == Binary file - no diff available. Propchange: dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz.asc == --- dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz.asc (added) +++ dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz.asc Wed Mar 1 12:08:27 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmP/NrMACgkQFo1l3cYE +67IeMw/9E7miFrwdbrlj2qoc6Z1j3U2hLn1Mb1MgCi15YI28MxHmoMsEkO8EkO56 +tAYHRX30ARFm5jzCGv8/JMMRkOf2bKJjHTBknrxw6bM/UEdRE1EVxOKZjyDWEvWx +2BDRja3WWe97XoSfJTHxd8Ml4dIG4dMniX13bPhOnX3grEj1lSgb4GhY7gYLSRva +Le/pjbuiSfE7ewfSOTtUQclvjvC0u8sutGIoS5tng8lx8y1BJYsvJlHuMze/8Geh +uOJeCTvqbX4AYmO34Kwzhw/VuxKhCPmEKSWUHQJ2c65DgUv/hNlAXB1bsxOuO4rH +BbgNdOLOLR7zM7CW0qi4WXJiGdbQbtkIQE6Tvoe4OW108Skj4QDNUPpbyUI37PFP +c4Z56FP0ED6RksDG/ZDv1I8eIrYtzscqj2O8IBs1GzIFv9FE/jW9R7NOFmfmIG4M +1AksoaD7PE/Gpir7FUnB6MHwqtPfjDelaNWK2wKPjU4MK/jAM1bnkIUJ+QLONfLK +a4lY2c9RN0iQg/OsPItOBqs67N7ZBOJ0jku/tfxFNAoRPoG5dynacjsfDYF/Sipu +ROcSR2wp30UufvNPNlCx1AAoQwWsMEm6PLbBXgtgrN4bQGGV2KZZTlgh4wYlfhb6 +wVoi0fVdsL2Nh0J0paYe1VQrJGWIzxa0e4cSH5kdhDqVXcE7OUw= +=c7Sd +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum == --- dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum (added) +++ dev/pulsar/pulsar-adapters-2.11.0-candidate-1/apache-pulsar-adapters-2.11.0-src.tar.gz.sha512sum Wed Mar 1 12:08:27 2023 @@ -0,0 +1 @@ +c5fd43fbfbbc2a848f74f68da7ebcf9a958d7b327237ad7eff2f43e3b747ea5477b839a427cc89b3906ad9ed6f6d9e2268bcdda50815739b4024e311467fc943 apache-pulsar-adapters-2.11.0-src.tar.gz
svn commit: r60396 - /dev/pulsar/pulsar-adapters-2.11.0-candidate-1/
Author: cbornet Date: Wed Mar 1 12:01:19 2023 New Revision: 60396 Log: Add directory for pulsar-adapters 2.11.0-candidate-1 release Added: dev/pulsar/pulsar-adapters-2.11.0-candidate-1/
[pulsar-adapters] branch branch-2.11 updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git The following commit(s) were added to refs/heads/branch-2.11 by this push: new 3e98ed1 [maven-release-plugin] prepare for next development iteration 3e98ed1 is described below commit 3e98ed1ff02492695b33570f10aa882b59c2b392 Author: Christophe Bornet AuthorDate: Wed Mar 1 12:29:55 2023 +0100 [maven-release-plugin] prepare for next development iteration --- examples/kafka-streams/pom.xml| 4 ++-- examples/pom.xml | 2 +- examples/spark/pom.xml| 2 +- pom.xml | 6 +++--- pulsar-client-kafka-compat/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml| 2 +- pulsar-log4j2-appender/pom.xml| 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- tests/pom.xml | 2 +- tests/pulsar-kafka-compat-client-test/pom.xml | 2 +- tests/pulsar-spark-test/pom.xml | 4 ++-- tests/pulsar-storm-test/pom.xml | 4 ++-- 21 files changed, 26 insertions(+), 26 deletions(-) diff --git a/examples/kafka-streams/pom.xml b/examples/kafka-streams/pom.xml index c7b9cf1..4d11dcb 100644 --- a/examples/kafka-streams/pom.xml +++ b/examples/kafka-streams/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT kafka-streams @@ -34,7 +34,7 @@ org.apache.pulsar pulsar-client-kafka - 2.11.0 + 2.11.1-SNAPSHOT diff --git a/examples/pom.xml b/examples/pom.xml index 34c5abf..fe4ec3c 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -24,7 +24,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT org.apache.pulsar.examples diff --git a/examples/spark/pom.xml b/examples/spark/pom.xml index 94b856e..0059887 100644 --- a/examples/spark/pom.xml +++ b/examples/spark/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT spark diff --git a/pom.xml b/pom.xml index ccaf621..e58eb1c 100644 --- a/pom.xml +++ b/pom.xml @@ -31,7 +31,7 @@ org.apache.pulsar pulsar-adapters - 2.11.0 + 2.11.1-SNAPSHOT Pulsar Adapters A collections of Pulsar adapters. @@ -62,7 +62,7 @@ https://github.com/apache/pulsar-adapters scm:git:https://github.com/apache/pulsar-adapters.git scm:git:https://github.com/apache/pulsar-adapters.git -v2.11.0-candidate-1 +HEAD @@ -99,7 +99,7 @@ UTF-8 UTF-8 -1677670060 +1677670194 true true diff --git a/pulsar-client-kafka-compat/pom.xml b/pulsar-client-kafka-compat/pom.xml index f5f28d2..539604e 100644 --- a/pulsar-client-kafka-compat/pom.xml +++ b/pulsar-client-kafka-compat/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml index 1b40bfc..791d17b 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml index f0ace9a..59fa9f2 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client
[pulsar-adapters] annotated tag v2.11.0-candidate-1 updated (1b1104c -> c42bee5)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v2.11.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git *** WARNING: tag v2.11.0-candidate-1 was modified! *** from 1b1104c (commit) to c42bee5 (tag) tagging 1b1104c023ff16848a69a7b1a290f4a3432cba6d (commit) by Christophe Bornet on Wed Mar 1 12:29:53 2023 +0100 - Log - [maven-release-plugin] copy for tag v2.11.0-candidate-1 --- No new revisions were added by this update. Summary of changes:
[pulsar-adapters] branch branch-2.11 updated (933279a -> 1b1104c)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git from 933279a Use scm:git:https://github.com/apache/pulsar-adapters.git as developerConnection add 1b1104c [maven-release-plugin] prepare release v2.11.0-candidate-1 No new revisions were added by this update. Summary of changes: examples/kafka-streams/pom.xml | 7 +++ examples/pom.xml | 5 ++--- examples/spark/pom.xml | 6 ++ pom.xml| 14 +++--- pulsar-client-kafka-compat/pom.xml | 6 ++ .../pulsar-client-kafka-shaded/pom.xml | 6 ++ .../pulsar-client-kafka-shaded_0_8/pom.xml | 6 ++ .../pulsar-client-kafka-shaded_0_9/pom.xml | 6 ++ .../pulsar-client-kafka-tests/pom.xml | 6 ++ .../pulsar-client-kafka-tests_0_8/pom.xml | 6 ++ .../pulsar-client-kafka-tests_0_9/pom.xml | 6 ++ pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml | 6 ++ pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml | 6 ++ pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml | 6 ++ pulsar-log4j2-appender/pom.xml | 5 ++--- pulsar-spark/pom.xml | 6 ++ pulsar-storm/pom.xml | 6 ++ tests/pom.xml | 5 ++--- tests/pulsar-kafka-compat-client-test/pom.xml | 5 ++--- tests/pulsar-spark-test/pom.xml| 8 +++- tests/pulsar-storm-test/pom.xml| 8 +++- 21 files changed, 50 insertions(+), 85 deletions(-)
[pulsar-adapters] branch branch-2.11 updated (36b11fd -> 933279a)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git discard 36b11fd [maven-release-plugin] prepare for next development iteration discard ad10a92 [maven-release-plugin] prepare release v2.11.0 This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/branch-2.11 (933279a) \ O -- O -- O (36b11fd) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: examples/kafka-streams/pom.xml | 7 --- examples/pom.xml | 5 +++-- examples/spark/pom.xml | 6 -- pom.xml| 14 +++--- pulsar-client-kafka-compat/pom.xml | 6 -- .../pulsar-client-kafka-shaded/pom.xml | 6 -- .../pulsar-client-kafka-shaded_0_8/pom.xml | 6 -- .../pulsar-client-kafka-shaded_0_9/pom.xml | 6 -- .../pulsar-client-kafka-tests/pom.xml | 6 -- .../pulsar-client-kafka-tests_0_8/pom.xml | 6 -- .../pulsar-client-kafka-tests_0_9/pom.xml | 6 -- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml | 6 -- pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml | 6 -- pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml | 6 -- pulsar-log4j2-appender/pom.xml | 5 +++-- pulsar-spark/pom.xml | 6 -- pulsar-storm/pom.xml | 6 -- tests/pom.xml | 5 +++-- tests/pulsar-kafka-compat-client-test/pom.xml | 5 +++-- tests/pulsar-spark-test/pom.xml| 8 +--- tests/pulsar-storm-test/pom.xml| 8 +--- 21 files changed, 85 insertions(+), 50 deletions(-)
[pulsar-adapters] branch branch-2.11 updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git The following commit(s) were added to refs/heads/branch-2.11 by this push: new 36b11fd [maven-release-plugin] prepare for next development iteration 36b11fd is described below commit 36b11fd435732990f9da96817633b5da6f36ba8b Author: Christophe Bornet AuthorDate: Wed Mar 1 12:22:46 2023 +0100 [maven-release-plugin] prepare for next development iteration --- examples/kafka-streams/pom.xml| 4 ++-- examples/pom.xml | 2 +- examples/spark/pom.xml| 2 +- pom.xml | 6 +++--- pulsar-client-kafka-compat/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml | 2 +- pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml| 2 +- pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml| 2 +- pulsar-log4j2-appender/pom.xml| 2 +- pulsar-spark/pom.xml | 2 +- pulsar-storm/pom.xml | 2 +- tests/pom.xml | 2 +- tests/pulsar-kafka-compat-client-test/pom.xml | 2 +- tests/pulsar-spark-test/pom.xml | 4 ++-- tests/pulsar-storm-test/pom.xml | 4 ++-- 21 files changed, 26 insertions(+), 26 deletions(-) diff --git a/examples/kafka-streams/pom.xml b/examples/kafka-streams/pom.xml index c7b9cf1..4d11dcb 100644 --- a/examples/kafka-streams/pom.xml +++ b/examples/kafka-streams/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT kafka-streams @@ -34,7 +34,7 @@ org.apache.pulsar pulsar-client-kafka - 2.11.0 + 2.11.1-SNAPSHOT diff --git a/examples/pom.xml b/examples/pom.xml index 34c5abf..fe4ec3c 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -24,7 +24,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT org.apache.pulsar.examples diff --git a/examples/spark/pom.xml b/examples/spark/pom.xml index 94b856e..0059887 100644 --- a/examples/spark/pom.xml +++ b/examples/spark/pom.xml @@ -23,7 +23,7 @@ org.apache.pulsar.examples pulsar-adapters-examples -2.11.0 +2.11.1-SNAPSHOT spark diff --git a/pom.xml b/pom.xml index 37d3152..8983d0e 100644 --- a/pom.xml +++ b/pom.xml @@ -31,7 +31,7 @@ org.apache.pulsar pulsar-adapters - 2.11.0 + 2.11.1-SNAPSHOT Pulsar Adapters A collections of Pulsar adapters. @@ -62,7 +62,7 @@ https://github.com/apache/pulsar-adapters scm:git:https://github.com/apache/pulsar-adapters.git scm:git:https://github.com/apache/pulsar-adapters.git -v2.11.0 +HEAD @@ -99,7 +99,7 @@ UTF-8 UTF-8 -1677669635 +1677669765 true true diff --git a/pulsar-client-kafka-compat/pom.xml b/pulsar-client-kafka-compat/pom.xml index f5f28d2..539604e 100644 --- a/pulsar-client-kafka-compat/pom.xml +++ b/pulsar-client-kafka-compat/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-adapters -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml index 1b40bfc..791d17b 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml index f0ace9a..59fa9f2 100644 --- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml +++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml @@ -25,7 +25,7 @@ org.apache.pulsar pulsar-client-kafka-compat -2.11.0 +2.11.1-SNAPSHOT .. diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9
[pulsar-adapters] annotated tag v2.11.0 updated (ad10a92 -> d6d5b2e)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v2.11.0 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git *** WARNING: tag v2.11.0 was modified! *** from ad10a92 (commit) to d6d5b2e (tag) tagging ad10a92fe692c0a46b553641261043b9a89c1945 (commit) by Christophe Bornet on Wed Mar 1 12:22:44 2023 +0100 - Log - [maven-release-plugin] copy for tag v2.11.0 --- No new revisions were added by this update. Summary of changes:
[pulsar-adapters] branch branch-2.11 updated (93f74c1 -> ad10a92)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git from 93f74c1 Only send notifications to commits@ mailing list (#41) add 933279a Use scm:git:https://github.com/apache/pulsar-adapters.git as developerConnection add ad10a92 [maven-release-plugin] prepare release v2.11.0 No new revisions were added by this update. Summary of changes: examples/kafka-streams/pom.xml | 7 +++ examples/pom.xml | 5 ++--- examples/spark/pom.xml | 6 ++ pom.xml | 16 pulsar-client-kafka-compat/pom.xml | 6 ++ .../pulsar-client-kafka-shaded/pom.xml | 6 ++ .../pulsar-client-kafka-shaded_0_8/pom.xml | 6 ++ .../pulsar-client-kafka-shaded_0_9/pom.xml | 6 ++ .../pulsar-client-kafka-tests/pom.xml| 6 ++ .../pulsar-client-kafka-tests_0_8/pom.xml| 6 ++ .../pulsar-client-kafka-tests_0_9/pom.xml| 6 ++ pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml | 6 ++ .../pulsar-client-kafka_0_8/pom.xml | 6 ++ .../pulsar-client-kafka_0_9/pom.xml | 6 ++ pulsar-log4j2-appender/pom.xml | 5 ++--- pulsar-spark/pom.xml | 6 ++ pulsar-storm/pom.xml | 6 ++ tests/pom.xml| 5 ++--- tests/pulsar-kafka-compat-client-test/pom.xml| 5 ++--- tests/pulsar-spark-test/pom.xml | 8 +++- tests/pulsar-storm-test/pom.xml | 8 +++- 21 files changed, 51 insertions(+), 86 deletions(-)
[pulsar-adapters] branch branch-2.11 created (now 93f74c1)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git at 93f74c1 Only send notifications to commits@ mailing list (#41) No new revisions were added by this update.
[pulsar-adapters] branch branch-2.11 created (now 93f74c1)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git at 93f74c1 Only send notifications to commits@ mailing list (#41) No new revisions were added by this update.
[pulsar-adapters] branch master updated: [pulsar-kafka] Fixed blockIfQueueFull config (#36)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git
The following commit(s) were added to refs/heads/master by this push:
new 357fa3b [pulsar-kafka] Fixed blockIfQueueFull config (#36)
357fa3b is described below
commit 357fa3bef8c3ec42201cf2aac4b3468bf240584a
Author: hailin0
AuthorDate: Wed Mar 1 16:42:15 2023 +0800
[pulsar-kafka] Fixed blockIfQueueFull config (#36)
Co-authored-by: wanghailin
---
.../org/apache/kafka/clients/producer/PulsarKafkaProducer.java | 2 +-
.../org/apache/kafka/clients/producer/PulsarKafkaProducerTest.java | 7 +++
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java
index 80ca9fd..6dbe09f 100644
---
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java
+++
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java
@@ -180,7 +180,7 @@ public class PulsarKafkaProducer implements
Producer {
// Pulsar throws error immediately when the queue is full and
blockIfQueueFull=false
// Kafka, on the other hand, still blocks for "max.block.ms" time and
then gives error.
Boolean sendTimeOutConfigured = sendTimeoutMillis > 0;
-boolean shouldBlockPulsarProducer = Boolean.getBoolean(properties
+boolean shouldBlockPulsarProducer = Boolean.parseBoolean(properties
.getProperty(PulsarProducerKafkaConfig.BLOCK_IF_PRODUCER_QUEUE_FULL,
sendTimeOutConfigured.toString()));
pulsarProducerBuilder.blockIfQueueFull(shouldBlockPulsarProducer);
diff --git
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/test/java/org/apache/kafka/clients/producer/PulsarKafkaProducerTest.java
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/test/java/org/apache/kafka/clients/producer/PulsarKafkaProducerTest.java
index 90c2f95..b4a7e79 100644
---
a/pulsar-client-kafka-compat/pulsar-client-kafka/src/test/java/org/apache/kafka/clients/producer/PulsarKafkaProducerTest.java
+++
b/pulsar-client-kafka-compat/pulsar-client-kafka/src/test/java/org/apache/kafka/clients/producer/PulsarKafkaProducerTest.java
@@ -133,6 +133,13 @@ public class PulsarKafkaProducerTest {
verify(mockClientBuilder, times(1)).keepAliveInterval(1000,
TimeUnit.SECONDS);
verify(mockProducerBuilder, times(1)).sendTimeout(100,
TimeUnit.MILLISECONDS);
verify(mockProducerBuilder, times(1)).blockIfQueueFull(false);
+
+// validate configs change
+properties.put(PulsarProducerKafkaConfig.BLOCK_IF_PRODUCER_QUEUE_FULL,
Boolean.TRUE.toString());
+producer = new PulsarKafkaProducer<>(properties);
+producer.close();
+
+verify(mockProducerBuilder, times(1)).blockIfQueueFull(true);
}
@Test
[pulsar-adapters] branch master updated (2392bfe -> 1d8ee48)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git from 2392bfe enable Reproducible Builds (#39) add 1d8ee48 [improve] Kafka adaptor - Handle partition topic. (#37) No new revisions were added by this update. Summary of changes: .../clients/consumer/PulsarKafkaConsumer.java | 59 -- 1 file changed, 33 insertions(+), 26 deletions(-)
[pulsar-adapters] branch master updated: enable Reproducible Builds (#39)
This is an automated email from the ASF dual-hosted git repository.
cbornet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git
The following commit(s) were added to refs/heads/master by this push:
new 2392bfe enable Reproducible Builds (#39)
2392bfe is described below
commit 2392bfe2f7d97f2a323014142eef0e066405eb89
Author: Hervé Boutemy
AuthorDate: Wed Mar 1 09:40:02 2023 +0100
enable Reproducible Builds (#39)
---
pom.xml | 3 ++-
src/rename-netty-native-libs.sh | 4
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/pom.xml b/pom.xml
index 3dde944..fb63323 100644
--- a/pom.xml
+++ b/pom.xml
@@ -26,7 +26,7 @@
org.apache
apache
-23
+27
org.apache.pulsar
@@ -99,6 +99,7 @@
UTF-8
UTF-8
+10
true
true
diff --git a/src/rename-netty-native-libs.sh b/src/rename-netty-native-libs.sh
index 99da5b0..eb36350 100755
--- a/src/rename-netty-native-libs.sh
+++ b/src/rename-netty-native-libs.sh
@@ -54,6 +54,10 @@ for line in "${FILES_TO_RENAME[@]}"; do
fi
done
+touch -r META-INF/MANIFEST.MF META-INF/LICENSE.netty
+touch -r META-INF/maven META-INF/native
+touch -r META-INF/maven META-INF
+
# Overwrite the original ZIP archive
rm $JAR_PATH
zip -q -r $JAR_PATH .
[pulsar-client-reactive] branch main updated: Update copyright years (#122)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git The following commit(s) were added to refs/heads/main by this push: new a36900c Update copyright years (#122) a36900c is described below commit a36900c2246ecd87d0aeceeb8c43b8c9181131d8 Author: Christophe Bornet AuthorDate: Tue Feb 21 08:17:03 2023 -0400 Update copyright years (#122) --- NOTICE | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/NOTICE b/NOTICE index 25e3f1e..d7bea28 100644 --- a/NOTICE +++ b/NOTICE @@ -1,5 +1,5 @@ Reactive Client for Apache Pulsar -Copyright 2022 The Apache Software Foundation +Copyright 2022-2023 The Apache Software Foundation This product includes software developed at The Apache Software Foundation (http://www.apache.org/).
[pulsar-client-reactive] 01/01: Update copyright years
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch cbornet-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git commit 8f3e098bb23f73f7349a5f8785dcff57173cce32 Author: Christophe Bornet AuthorDate: Wed Feb 8 16:41:07 2023 +0100 Update copyright years --- NOTICE | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/NOTICE b/NOTICE index 25e3f1e..d7bea28 100644 --- a/NOTICE +++ b/NOTICE @@ -1,5 +1,5 @@ Reactive Client for Apache Pulsar -Copyright 2022 The Apache Software Foundation +Copyright 2022-2023 The Apache Software Foundation This product includes software developed at The Apache Software Foundation (http://www.apache.org/).
[pulsar-client-reactive] branch cbornet-patch-1 created (now 8f3e098)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch cbornet-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git at 8f3e098 Update copyright years This branch includes the following new commits: new 8f3e098 Update copyright years The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[pulsar-client-reactive] branch cbornet-patch-1 created (now f48f798)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to branch cbornet-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git at f48f798 Update README.adoc This branch includes the following new commits: new f48f798 Update README.adoc The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[pulsar-client-reactive] 01/01: Update README.adoc
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a commit to branch cbornet-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git commit f48f79874c0fe88142a2c454a1b3f0b6dc7dddb9 Author: Christophe Bornet AuthorDate: Tue Feb 7 11:24:48 2023 +0100 Update README.adoc --- README.adoc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.adoc b/README.adoc index 7c5ab30..feecce1 100644 --- a/README.adoc +++ b/README.adoc @@ -19,7 +19,7 @@ = Reactive client for Apache Pulsar :github: https://github.com/apache/pulsar-client-reactive -:latest_version: 0.1.0 +:latest_version: 0.2.0 Reactive client for Apache Pulsar which is compatible with the Reactive Streams specification. This uses Project Reactor as the Reactive Streams implementation.
[pulsar-client-reactive] annotated tag v0.2.0 updated (8c676db -> 6613bbc)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.2.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.2.0 was modified! *** from 8c676db (commit) to 6613bbc (tag) tagging 8c676db0f70604e1abb0978f966c0916d9ea3aa9 (commit) replaces v0.2.0-candidate-1 by Christophe Bornet on Mon Feb 6 21:03:01 2023 +0100 - Log - Release v0.2.0 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCY+Fc9RMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeaaMA/iENtgz9qxkMWrX7u8bt84kQT/GfpzO0 r5R+KIhH3M06AP9Y0nOC5DnBUVG3Hvk3UzD66qg0GegbTt3abd+KwwetAQ== =0Bxb -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r59828 - in /dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2: pulsar-client-reactive-0.2.0-src.tar.gz pulsar-client-reactive-0.2.0-src.tar.gz.asc pulsar-client-reactive-0.2.0-src.tar.g
Author: cbornet Date: Wed Feb 1 22:04:10 2023 New Revision: 59828 Log: Add files for pulsar-client-reactive 0.2.0-candidate-2 release Added: dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz (with props) dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz.asc dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz.sha512 Added: dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz == Binary file - no diff available. Propchange: dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz.asc == --- dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz.asc (added) +++ dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz.asc Wed Feb 1 22:04:10 2023 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEof+yNNmpbbtzoNn+Fo1l3cYE67IFAmPa4aQACgkQFo1l3cYE +67IAuQ/+PGRyTJZG+sFsLyfWOQOMbAsmcnX31m7CaD45pzW0GnturB2hfiYzbdx2 +7l3S+F+PtMfdXytXSU09W8ZdNXZJxmy/kYd5tum9u1rkz9ZKTnFEOoZI5GnuYDMy +6qD5aC4oCqMEpbHNq/wblnXd8hOs8Y/QiZ5+Tbyj66cltikV/EgxmVMpmv2g7VPp +rzzLFgZ3rYSY2yfqm6h/nDVmnJi+dP7QUUPAW0Zb03II/rndM3VSsq47xw41IEGj +fizbLG8Pb/KDvdSXgLm1ejgZtKbswPAfc8vIw+gKSv//k5MS84YKA+Iepw0OZMfg +U3dqtUtASdVpcjMFRYZsQDanQDHYkcBZNW1/+14RCM50FhpYvYfrm+RwOCv6xcP7 +66IOojSrZwSfvtY1UUAqsMpuOLH5e3edA0RwjorMmMhFrXud2hdpSJOuwDeYqv7D +/LQGMOR3lYL1ScGDI7AAhQ+rfPXQjFftFFQJo8ULBlSooTfPtoqX2VuB1yWa8Pud +BWXJsiYyoR/zxcmsC0sOohxGEFkQjFj2xLn4EVIWGHXHjlgr+dfdVnpXHAR5/mkL +81DiEunCOEtah2fD6LYbKR6Icc3e8Z1QlsoDFL/sRvroYE6IcGhZvzGZawwksbn8 +RIwW48N8MdK1d1tIDoVHQdNPcXUPzFTrna4l9gnaGAVnbDhIedk= +=TDeO +-END PGP SIGNATURE- Added: dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz.sha512 == --- dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz.sha512 (added) +++ dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/pulsar-client-reactive-0.2.0-src.tar.gz.sha512 Wed Feb 1 22:04:10 2023 @@ -0,0 +1 @@ +1498a63dd1021108baab61baae8f6f494530118a53c92bc316320878d5850de61313219255010885a9a04762a54077865a2724669f0294ec950db5b5460bedaa pulsar-client-reactive-0.2.0-src.tar.gz
svn commit: r59827 - /dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/
Author: cbornet Date: Wed Feb 1 22:01:55 2023 New Revision: 59827 Log: Add directory for pulsar-client-reactive 0.2.0-candidate-2 release Added: dev/pulsar/pulsar-client-reactive-0.2.0-candidate-2/
[pulsar-client-reactive] annotated tag v0.2.0-candidate-2 updated (8c676db -> 1f3077e)
This is an automated email from the ASF dual-hosted git repository. cbornet pushed a change to annotated tag v0.2.0-candidate-2 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.2.0-candidate-2 was modified! *** from 8c676db (commit) to 1f3077e (tag) tagging 8c676db0f70604e1abb0978f966c0916d9ea3aa9 (commit) replaces v0.2.0-candidate-1 by Christophe Bornet on Wed Feb 1 22:57:15 2023 +0100 - Log - Release v0.2.0-candidate-2 -BEGIN PGP SIGNATURE- iIkEABYKADEWIQSsJtR8kOYvBGFVou/hzYcUAI4EngUCY9rgPBMcY2Jvcm5ldEBh cGFjaGUub3JnAAoJEOHNhxQAjgSeBf0BAL5GogxAHs7jBr4+Sx8JPv+CNnL+4TW0 uWB0MVA0cWCcAP0RWeUOgGSSpX1zEto/4aENkt5kNYB28z9aETci29NHAQ== =KfXJ -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
