Use java21 for pulsar 4 0 +

images/pulsar-functions-base-runner/Dockerfile

@@ -41,9 +41,12 @@ RUN echo "VERSION_TAG=${VERSION_TAG}" && \
     elif [ $VERSION_MAJOR -eq 2 ] && [ $VERSION_MINOR -eq 11 ]; then \
         echo "Pulsar version is 2.11, use java 17" && \
         export JRE_PACKAGE_NAME='openjdk17 gcompat'; \
-    else \
-        echo "Pulsar version is not in the list, use java 17 instead" && \
+    elif [ $VERSION_MAJOR -eq 3 ]; then \
+        echo "Pulsar version is 3.x, use java 17 instead" && \
         export JRE_PACKAGE_NAME='openjdk17 gcompat'; \
+    else \
+        echo "Pulsar version is not in the list, use java 21 instead" && \
+        export JRE_PACKAGE_NAME='openjdk21 gcompat'; \
     fi && \
     apk update && apk add --no-cache $JRE_PACKAGE_NAME bash
 
@@ -64,4 +67,26 @@ RUN rm -rf /pulsar/bin/pulsar-detector || true
 ENV PULSAR_ROOT_LOGGER=INFO,CONSOLE
 ENV java.io.tmpdir=/pulsar/tmp/
 
+# Copy the kinesis_producer native executable compiled for Alpine musl to the runner image
+# This is required to support the Pulsar IO Kinesis sink connector
+COPY --from=pulsar --chown=$UID:$GID /opt/amazon-kinesis-produce* /opt/amazon-kinesis-producer
+# Set the environment variable to point to the kinesis_producer native executable
+ENV PULSAR_IO_KINESIS_KPL_PATH=/opt/amazon-kinesis-producer/bin/kinesis_producer
+# Install the required dependencies for the kinesis_producer native executable
+USER 0
+RUN apk update && apk add --no-cache \
+    brotli-libs \
+    c-ares \
+    libcrypto3 \
+    libcurl \
+    libgcc \
+    libidn2 \
+    libpsl \
+    libssl3 \
+    libunistring \
+    nghttp2-libs \
+    zlib \
+    zstd-libs \
+    libuuid
+
 WORKDIR /pulsar

images/pulsar-functions-base-runner/pulsarctl.Dockerfile

@@ -1,6 +1,3 @@
-ARG PULSAR_IMAGE
-ARG PULSAR_IMAGE_TAG
-FROM ${PULSAR_IMAGE}:${PULSAR_IMAGE_TAG} as pulsar
 FROM alpine:3.20 as functions-runner
 
 ENV GID=10001

images/pulsar-functions-java-runner/pulsarctl.Dockerfile

@@ -25,9 +25,12 @@ RUN echo "VERSION_TAG=${VERSION_TAG}" && \
     elif [ $VERSION_MAJOR -eq 2 ] && [ $VERSION_MINOR -eq 11 ]; then \
         echo "Pulsar version is 2.11, use java 17" && \
         export JRE_PACKAGE_NAME='openjdk17 gcompat'; \
-    else \
-        echo "Pulsar version is not in the list, use java 17 instead" && \
+    elif [ $VERSION_MAJOR -eq 3 ]; then \
+        echo "Pulsar version is 3.x, use java 17" && \
         export JRE_PACKAGE_NAME='openjdk17 gcompat'; \
+    else \
+        echo "Pulsar version is not in the list, use java 21 instead" && \
+        export JRE_PACKAGE_NAME='openjdk21 gcompat'; \
     fi && \
     apk update && apk add --no-cache $JRE_PACKAGE_NAME
 
@@ -53,4 +56,26 @@ ENV java.io.tmpdir=/pulsar/tmp/
 
 WORKDIR /pulsar
 
+# Copy the kinesis_producer native executable compiled for Alpine musl to the pulsar-all image
+# This is required to support the Pulsar IO Kinesis sink connector
+COPY --from=pulsar --chown=$UID:$GID /opt/amazon-kinesis-produce* /opt/amazon-kinesis-producer
+# Set the environment variable to point to the kinesis_producer native executable
+ENV PULSAR_IO_KINESIS_KPL_PATH=/opt/amazon-kinesis-producer/bin/kinesis_producer
+# Install the required dependencies for the kinesis_producer native executable
+USER 0
+RUN apk update && apk add --no-cache \
+    brotli-libs \
+    c-ares \
+    libcrypto3 \
+    libcurl \
+    libgcc \
+    libidn2 \
+    libpsl \
+    libssl3 \
+    libunistring \
+    nghttp2-libs \
+    zlib \
+    zstd-libs \
+    libuuid
+
 USER $USER