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: