diff options
| author | Staffan Olsson <staffan@repos.se> | 2017-11-04 11:17:29 +0100 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2017-11-04 11:17:29 +0100 |
| commit | 224cfbe1af2abdc896d0ed598e16065eb42ba30d (patch) | |
| tree | 81cfad37a5dc89396a9f80de830b68751dd2c4cc | |
| parent | 55e0e20addfd4f203eb15f3852f8b8572b499f8d (diff) | |
| download | kubernetes-kafka-224cfbe1af2abdc896d0ed598e16065eb42ba30d.tar.gz kubernetes-kafka-224cfbe1af2abdc896d0ed598e16065eb42ba30d.tar.bz2 kubernetes-kafka-224cfbe1af2abdc896d0ed598e16065eb42ba30d.zip | |
Can't output as JSON unless aggregation produces JSON
| -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 |