fix

Author: luoluoyuyu

docker-compose.yml

@@ -26,7 +26,7 @@ services:
       - kafka
 
   kafka:
-    image: apache/kafka
+    image: apache/kafka:3.8.0
     hostname: kafka
     ports:
       - "9092:9092"

examples/go-processor/build.sh

@@ -10,7 +10,6 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-#!/bin/bash
 
 set -euo pipefail
 
@@ -41,6 +40,10 @@ if [ ! -d "$WIT_DEPS_DIR" ] || [ -z "$(ls -A "$WIT_DEPS_DIR" 2>/dev/null)" ]; th
 fi
 
 if ! command -v tinygo &> /dev/null; then
+    printf "Error: 'tinygo' command not found.\n" >&2
+    printf "TinyGo is required to build the WebAssembly component.\n" >&2
+    printf "Please install TinyGo and ensure it is on your PATH.\n" >&2
+    printf "See https://tinygo.org/getting-started/install/ for installation instructions.\n" >&2
     exit 1
 fi
 

examples/python-processor/processor_impl.py

@@ -71,8 +71,8 @@ def process(self, ctx: Context, source_id: int, data: bytes) -> None:
             # REQUIREMENT: Emit output for every single message processed
             self._emit_snapshot(ctx)
 
-        except Exception as e:
-            raise e
+        except Exception:
+            raise
 
     def _emit_snapshot(self, ctx: Context):
         """Helper: Serialize and emit current state."""