Skip to content

Commit b956654

Browse files
JohnPrestonedsiper
authored andcommitted
Adding parser for confluent schema registry
Signed-off-by: John Preston <[email protected]>
1 parent 39acdf9 commit b956654

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

conf/parsers_kafka.conf

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
[PARSER]
2+
# Confluent Schema Registry 7.1.1 default format
3+
Name confluent-schema-registry
4+
Format regex
5+
Time_Key time
6+
Time_Format %Y-%m-%d %H:%M:%S,%L
7+
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>.*)
8+
9+
10+
[PARSER]
11+
# Confluent Schema Registry 7.1.1 default format - with _sr_ prefix to allow `nest`
12+
Name confluent-schema-registry-prefixed
13+
Format regex
14+
Time_Key _sr_time
15+
Time_Format %Y-%m-%d %H:%M:%S,%L
16+
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>.*)

0 commit comments

Comments
 (0)