1 files changed, 16 insertions, 0 deletions
diff --git a/fluent-bit/conf/parsers_kafka.conf b/fluent-bit/conf/parsers_kafka.conf
new file mode 100644
index 000000000..db4384a61
--- /dev/null
+++ b/fluent-bit/conf/parsers_kafka.conf
@@ -0,0 +1,16 @@
+[PARSER]
+    # Confluent Schema Registry 7.1.1 default format
+    Name confluent-schema-registry
+    Format regex
+    Time_Key time
+    Time_Format %Y-%m-%d %H:%M:%S,%L
+    Regex ^\[(?<time>\d{4}-\d{1,2}-\d{1,2} \d{2}:\d{2}:\d{2},\d{1,4})] (?<level>[A-Z]{1,8}) (?<src>[\d.]+) - - \[(?<date>.*)] \"(?<method>[A-Z]+) (?<path>\/[\S]+|\/) (?<http_version>HTTP\/[\d]\.[\d])\" (?<code>[\d]{1,3}) (?<size>[\d]+) \"-\" \"(?<agent>.*)\" (?<extra_info>.*)
+
+
+[PARSER]
+    # Confluent Schema Registry 7.1.1 default format - with _sr_ prefix to allow `nest`
+    Name confluent-schema-registry-prefixed
+    Format regex
+    Time_Key _sr_time
+    Time_Format %Y-%m-%d %H:%M:%S,%L
+    Regex ^\[(?<_sr_time>\d{4}-\d{1,2}-\d{1,2} \d{2}:\d{2}:\d{2},\d{1,4})] (?<_sr_level>[A-Z]{1,8}) (?<_sr_src>[\d.]+) - - \[(?<_sr_date>.*)] \"(?<_sr_method>[A-Z]+) (?<_sr_path>\/[\S]+|\/) (?<_sr_http_version>HTTP\/[\d]\.[\d])\" (?<_sr_code>[\d]{1,3}) (?<_sr_size>[\d]+) \"-\" \"(?<_sr_agent>.*)\" (?<_sr_extra_info>.*)