refactor: fuzz-test.sh with action subcommands + single-topic Kafka

- Restructure fuzz-test.sh into up/run/status/validate/logs/down actions
- No auto-cleanup: containers stay up for investigation
- Single Kafka topic per adapter via RegexRouter (preserves event order)
- Simplify validator: global frontier instead of per-node
- Consumer subscribes to fixed topic names (lm-events, olr-events)

Author: rophy

tests/dbz-twin/rac/config/application-logminer-kafka.properties

@@ -1,4 +1,5 @@
 # Debezium Server — LogMiner adapter → Kafka sink (RAC fuzz test)
+# All events routed to single topic (preserves commit order, no partition gaps)
 quarkus.http.port=8081
 debezium.sink.type=kafka
 debezium.sink.kafka.producer.bootstrap.servers=localhost:9092
@@ -24,6 +25,12 @@ debezium.source.snapshot.mode=no_data
 debezium.source.log.mining.strategy=online_catalog
 debezium.source.lob.enabled=true
 
+# Route all tables to a single topic for ordered delivery
+debezium.transforms=route
+debezium.transforms.route.type=org.apache.kafka.connect.transforms.RegexRouter
+debezium.transforms.route.regex=.*
+debezium.transforms.route.replacement=lm-events
+
 debezium.source.offset.storage=org.apache.kafka.connect.storage.FileOffsetBackingStore
 debezium.source.offset.storage.file.filename=/debezium/data/offsets.dat
 debezium.source.offset.flush.interval.ms=0

tests/dbz-twin/rac/config/application-olr-kafka.properties

@@ -1,4 +1,5 @@
 # Debezium Server — OLR adapter → Kafka sink (RAC fuzz test)
+# All events routed to single topic (preserves commit order, no partition gaps)
 quarkus.http.port=8082
 debezium.sink.type=kafka
 debezium.sink.kafka.producer.bootstrap.servers=localhost:9092
@@ -25,6 +26,12 @@ debezium.source.topic.prefix=olr
 debezium.source.schema.include.list=OLR_TEST
 debezium.source.snapshot.mode=no_data
 
+# Route all tables to a single topic for ordered delivery
+debezium.transforms=route
+debezium.transforms.route.type=org.apache.kafka.connect.transforms.RegexRouter
+debezium.transforms.route.regex=.*
+debezium.transforms.route.replacement=olr-events
+
 debezium.source.offset.storage=org.apache.kafka.connect.storage.FileOffsetBackingStore
 debezium.source.offset.storage.file.filename=/debezium/data/offsets.dat
 debezium.source.offset.flush.interval.ms=0