fix windows event log parsing

nv-morpheus · Aug 21, 2024 · 422b797 · 422b797
1 parent 03ee92a
commit 422b797
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/ci/scripts/download_kafka.py b/ci/scripts/download_kafka.py
@@ -20,8 +20,8 @@
 import pytest_kafka
 from pytest_kafka.install import set_up_kafka
 
-DEFAULT_KAFKA_URL = 'https://downloads.apache.org/kafka/3.5.2/kafka_2.13-3.5.2.tgz'
-DEFAULT_KAFKA_TAR_ROOTDIR = 'kafka_2.13-3.5.2/'
+DEFAULT_KAFKA_URL = 'https://downloads.apache.org/kafka/3.8.0/kafka_2.13-3.8.0.tgz'
+DEFAULT_KAFKA_TAR_ROOTDIR = 'kafka_2.13-3.8.0/'
 
 
 def main():

diff --git a/python/morpheus/morpheus/parsers/event_parser.py b/python/morpheus/morpheus/parsers/event_parser.py
@@ -98,7 +98,7 @@ def parse_raw_event(self, text: cudf.Series, event_regex: typing.Dict[str, any])
         # Applies regex pattern for each expected output column to raw data
         for col in event_specific_columns:
             regex_pattern = event_regex.get(col)
-            extracted_gdf = text.str.extract(regex_pattern)
+            extracted_gdf = text.str.extract(regex_pattern).reset_index()
             if not extracted_gdf.empty:
                 parsed_gdf[col] = extracted_gdf[0]