diff options
| -rw-r--r-- | logs-streaming/test/logs-aggregated.yml | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/logs-streaming/test/logs-aggregated.yml b/logs-streaming/test/logs-aggregated.yml index 6356b68..6807d22 100644 --- a/logs-streaming/test/logs-aggregated.yml +++ b/logs-streaming/test/logs-aggregated.yml @@ -16,7 +16,7 @@ data: exec 2>&1 echo "{\"#---\":\"$(date -u --iso-8601='ns')\"}" - kafkacat -b $BOOTSTRAP -C -t $TOPIC -f '{"#topic":"%t","#partition":%p,"#offset":%o,"#key":"%k","=":%s}\n' -o -10 -e + kafkacat -b $BOOTSTRAP -C -t $TOPIC -f '%t@%p [%o] %k: %s\n' -o -10 -e exit 0 |