add kafkacat with apt

.github/workflows/test.yaml

@@ -13,8 +13,7 @@ jobs:
     strategy:
       matrix:
         features:
-          - color
-          - hello
+          - kcat-apt
         baseImage:
           - debian:latest
           - ubuntu:latest
@@ -34,8 +33,7 @@ jobs:
     strategy:
       matrix:
         features:
-          - color
-          - hello
+          - kcat-apt
     steps:
       - uses: actions/checkout@v4
 
@@ -44,15 +42,3 @@ jobs:
 
       - name: "Generating tests for '${{ matrix.features }}' scenarios"
         run: devcontainer features test -f ${{ matrix.features }} --skip-autogenerated --skip-duplicated .
-
-  test-global:
-    runs-on: ubuntu-latest
-    continue-on-error: true
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: "Install latest devcontainer CLI"
-        run: npm install -g @devcontainers/cli
-
-      - name: "Testing global scenarios"
-        run: devcontainer features test --global-scenarios-only .

src/kcat-apt/NOTES.md

@@ -0,0 +1,43 @@
+# kcat (formerly kafkacat)
+
+A command-line utility for Apache Kafka that provides functionality for producing and consuming messages, as well as various metadata operations. This feature installs kcat using the apt package manager on Debian/Ubuntu-based systems.
+
+## Version Support
+
+By default, this feature installs the latest version available in the distribution's repository. You can specify a particular version using the `version` option in your devcontainer.json:
+
+```jsonc
+{
+    "features": {
+        "ghcr.io/irfanputra/devcontainer-features/kcat-apt:1": {
+            "version": "1.7.0-1"  // Use specific version
+            // or
+            "version": "latest"   // Use latest version (default)
+        }
+    }
+}
+```
+
+To check available versions in your base image:
+```bash
+apt-cache policy kafkacat
+```
+
+## Usage Examples
+
+After installation, you can use either `kcat` or `kafkacat` command (they are symlinked):
+
+```bash
+# Consume messages
+kcat -b localhost:9092 -t my-topic
+
+# Produce messages
+echo "Hello Kafka" | kcat -b localhost:9092 -t my-topic -P
+
+# List topics
+kcat -b localhost:9092 -L
+```
+
+## Note
+
+This feature only supports Debian/Ubuntu-based containers as it uses the apt package manager.

src/kcat-apt/devcontainer-feature.json

@@ -0,0 +1,16 @@
+{
+    "name": "kcat",
+    "id": "kcat-apt",
+    "version": "1.0.0",
+    "description": "A Kafka command line utility using kcat (formerly kafkacat). Only supports Debian/Ubuntu.",
+    "options": {
+        "version": {
+            "type": "string",
+            "default": "latest",
+            "description": "Select version of kcat (kafkacat) to install. Use distribution version format (e.g., '1.7.0-1'). Defaults to latest version."
+        }
+    },
+    "installsAfter": [
+        "ghcr.io/devcontainers/features/common-utils"
+    ]
+}

src/kcat-apt/install.sh

@@ -0,0 +1,33 @@
+#!/bin/sh
+set -e
+
+# Check for apt-get
+if ! type apt-get >/dev/null 2>&1; then
+    echo "ERROR: apt-get not found. This feature is only supported on Debian/Ubuntu-based systems."
+    exit 1
+fi
+
+# Function to check and install packages
+check_package_and_install() {
+    if ! dpkg -s "$@" > /dev/null 2>&1; then
+        apt-get update -y
+        apt-get -y install --no-install-recommends "$@"
+    fi
+}
+
+# Install kafkacat and create kcat symlink
+if [ "${VERSION}" != "latest" ]; then
+    echo "Installing kafkacat version ${VERSION}..."
+    check_package_and_install kafkacat="${VERSION}"
+else
+    echo "Installing latest version of kafkacat..."
+    check_package_and_install kafkacat
+fi
+
+# Create symlink from kafkacat to kcat for consistency
+if [ ! -e "/usr/bin/kcat" ] && [ -e "/usr/bin/kafkacat" ]; then
+    ln -s /usr/bin/kafkacat /usr/bin/kcat
+fi
+
+# Clean up apt cache
+rm -rf /var/lib/apt/lists/*