We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3090791 commit e758fb2Copy full SHA for e758fb2
filebeat/module/kafka/log/ingest/pipeline.json
@@ -68,11 +68,12 @@
68
{
69
"date": {
70
"if": "ctx.event.timezone != null",
71
- "field": "@timestamp",
72
- "formats": ["ISO8601"],
+ "field": "kafka.log.timestamp",
+ "target_field": "@timestamp",
73
+ "formats": ["yyyy-MM-dd HH:mm:ss,SSS"],
74
"timezone": "{{ event.timezone }}",
- "on_failure": [{"append": {"field": "error.message", "value": "{{ _ingest.on_failure_message }}"}}]
75
- }
+ "on_failure": [{"append": {"field": "error.message", "value": "{{ _ingest.on_failure_message }}"}}]
76
+ }
77
},
78
{"remove": {"field": "kafka.log.timestamp" }}
79
],
0 commit comments