summaryrefslogtreecommitdiff
path: root/config/template/grootstream_job_template.yaml
diff options
context:
space:
mode:
authordoufenghu <[email protected]>2024-04-02 17:36:46 +0800
committerdoufenghu <[email protected]>2024-04-02 17:36:46 +0800
commit95bcb7db323b12d7e7f864dff615d73622d7e688 (patch)
tree919b582cbcefb9304004444fda1d350a3041a2f5 /config/template/grootstream_job_template.yaml
parent80e93523eb12f986acac73a81f2614516c718a5e (diff)
[Feature][Tests] add Kafka Container for unit test.
Diffstat (limited to 'config/template/grootstream_job_template.yaml')
-rw-r--r--config/template/grootstream_job_template.yaml1
1 files changed, 1 insertions, 0 deletions
diff --git a/config/template/grootstream_job_template.yaml b/config/template/grootstream_job_template.yaml
index d700777..af73704 100644
--- a/config/template/grootstream_job_template.yaml
+++ b/config/template/grootstream_job_template.yaml
@@ -20,6 +20,7 @@ sources: # [object] Define connector source
kafka.max.partition.fetch.bytes: 31457280
kafka.group.id: SESSION-RECORD-GROUP-GROOT-STREAM-001 # [string] Kafka Group ID for Consumer
kafka.auto.offset.reset: latest # [string] Kafka Auto Offset Reset, default is latest
+ kafka.compression.type: snappy # [string] Kafka Compression Type, default is none
format: json # [string] Data Format for Source. eg. json, protobuf, etc.
json.ignore.parse.errors: false # [boolean] Flag to ignore parse errors, default will record the parse errors. If set true, it will ignore the parse errors.