summaryrefslogtreecommitdiff
path: root/groot-stream/templates/proxy_event.yaml.j2
diff options
context:
space:
mode:
Diffstat (limited to 'groot-stream/templates/proxy_event.yaml.j2')
-rw-r--r--groot-stream/templates/proxy_event.yaml.j24
1 files changed, 1 insertions, 3 deletions
diff --git a/groot-stream/templates/proxy_event.yaml.j2 b/groot-stream/templates/proxy_event.yaml.j2
index e793d38..939a26f 100644
--- a/groot-stream/templates/proxy_event.yaml.j2
+++ b/groot-stream/templates/proxy_event.yaml.j2
@@ -3,15 +3,14 @@ sources:
type: kafka
properties:
topic: PROXY-EVENT
+ kafka.group.id: {{ kafka_source_group_id }}
kafka.bootstrap.servers: {{ kafka_source_servers }}
- kafka.client.id: PROXY-EVENT
kafka.session.timeout.ms: 60000
kafka.max.poll.records: 3000
kafka.max.partition.fetch.bytes: 31457280
kafka.security.protocol: SASL_PLAINTEXT
kafka.sasl.mechanism: PLAIN
kafka.sasl.jaas.config: 454f65ea6eef1256e3067104f82730e737b68959560966b811e7ff364116b03124917eb2b0f3596f14733aa29ebad9352644ce1a5c85991c6f01ba8a5e8f177a80bea937958aaa485c2acc2b475603495a23eb59f055e037c0b186acb22886bd0275ca91f1633441d9943e7962942252
- kafka.group.id: {{ kafka_source_group_id }}
kafka.auto.offset.reset: latest
format: json
json.ignore.parse.errors: false
@@ -79,7 +78,6 @@ processing_pipelines:
parameters:
path: [props.hos.path, props.hos.bucket.name.policy_capture_file, packet_capture_file]
-
- function: CURRENT_UNIX_TIMESTAMP
output_fields: [ processing_time ]
parameters: