IBM · zeeIBM · Feb 25, 2026 · Feb 25, 2026 · Feb 25, 2026 · Feb 25, 2026
@@ -5,5 +5,4 @@
 # the repo. Unless a later match takes precedence,
 # @global-owner1 and @global-owner2 will be requested for
 # review when someone opens a pull request.
-*       @devanshah2 @Tal-Daniel @ofer-haim @natalygmkibm @apurva-birajdar @itai-g-weather-com @RefaelAdi @PratikshaSonawane @mwnovak-ibm @hadarkorny @doryo @chirag-ibm @rasikashete3 @pankajkumaribm @taees-eimouri @pankajkumar @piyush-desai-ibm @ShalakaKulkarni15 @JingqiuDu
-
+*       @devanshah2 @pankajkumaribm @taees-eimouri @JingqiuDu @Rose-Kaur @nida-bandukwala @laurel-hu @AndychenIBM @jsminem @GlennLee-IBM
@@ -28,6 +28,9 @@ jobs:
       actions: read
       contents: read
       security-events: write
+
+    env:
+      ARTIFACTORY_URL: https://repo.maven.apache.org/maven2/
 
     strategy:
       fail-fast: false

@@ -0,0 +1,3 @@
+{
+  "settingsInheritedFrom": "ibm-mend-config/mend-config@main"
+}
@@ -10,9 +10,11 @@ filter-plugin/logstash-filter-mysql-percona-guardium/logstash-filter-mysql_perco
 filter-plugin/logstash-filter-generic-guardium/logstash-filter-generic_guardium_filter
 filter-plugin/logstash-filter-saphana-guardium/logstash-filter-saphana_guardium_plugin_filter
 filter-plugin/logstash-filter-cassandra-guardium/logstash-filter-cassandra_guardium_plugin_filter
+filter-plugin/logstash-filter-mysql-aws-guardium/logstash-filter-mysql_guardium_plugin_filter
 filter-plugin/logstash-filter-aurora-mysql-guardium/logstash-filter-auroramysqlguardiumpluginfilter
 filter-plugin/logstash-filter-dynamodb-guardium/logstash-filter-dynamodb_guardium_plugin_filter
 filter-plugin/logstash-filter-neptune-aws-guardium/logstash-filter-neptune_guardium_filter
+filter-plugin/logstash-filter-cockroachdb-guardium/logstash-filter-cockroachdb_guardium_filter
 filter-plugin/logstash-filter-couchbasedb-guardium/logstash-filter-couchbasedb_guardium_plugin_filter
 filter-plugin/logstash-filter-couchdb-guardium/logstash-filter-couchdb_guardium_filter
 filter-plugin/logstash-filter-mariadb-guardium/logstash-filter-mariadb_guardium_filter
@@ -25,6 +27,7 @@ filter-plugin/logstash-filter-neo4j-guardium/logstash-filter-neodb_guardium_filt
 filter-plugin/logstash-filter-snowflake-guardium/logstash-filter-guardium_snowflake_filter
 filter-plugin/logstash-filter-yugabyte-guardium/logstash-filter-yugabytedb_guardium_filter
 filter-plugin/logstash-filter-teradatadb-guardium/logstash-filter-teradatadb_guardium_plugin_filter
+filter-plugin/logstash-filter-postgres-guardium/logstash-filter-s3sqs_postgresql_guardium_plugin_filter
 filter-plugin/logstash-filter-pubsub-apachesolr-guardium/logstash-filter-apache_solr_gcp_connector
 filter-plugin/logstash-filter-pubsub-bigquery-guardium/logstash-filter-big_query_guardium_filter
 filter-plugin/logstash-filter-pubsub-bigtable-guardium/logstash-filter-big_table_guardium_filter
@@ -36,9 +39,15 @@ filter-plugin/logstash-filter-intersystems-iris-guardium/logstash-filter-intersy
 filter-plugin/logstash-filter-postgres-ibmcloud-guardium/logstash-filter-icd_postgresql_guardium_filter
 filter-plugin/logstash-filter-mysql-azure-guardium/logstash-filter-azure_mysql_guardium_filter
 filter-plugin/logstash-filter-scylldb-guardium/logstash-filter-scylladb_guardium_filter
+filter-plugin/logstash-filter-databricks-guardium/logstash-filter-databricks_guardium_filter
+filter-plugin/logstash-filter-trino-guardium/logstash-filter-trino_guardium_filter
+filter-plugin/logstash-filter-capella-guardium/logstash-filter-capella_guardium_filter
+filter-plugin/logstash-filter-opensearch-guardium/logstash-filter-opensearch_guardium_filter
+filter-plugin/logstash-filter-milvus-guardium/logstash-filter-milvus_guardium_filter
+filter-plugin/logstash-filter-singlestore-guardium/logstash-filter-singlestoredb_guardium_filter
+filter-plugin/logstash-filter-alloydb-guardium/logstash-filter-alloydb_guardium_filter
+input-plugin/logstash-input-couchbase-capella/logstash-input-couchbase_capella_input
 input-plugin/logstash-input-mongo-atlas/logstash-input-mongo_atlas_input
-input-plugin/logstash-input-couchbase-capella/logstash-input-couchbase-capella_input
-input-plugin/logstash-input-http/logstash-input-http_input
-filter-plugin/logstash-filter-capella-guardium/logstash-filter-capella-guardium_filter
-filter-plugin/logstash-filter-databricks-guardium/logstash-filter-databricks-guardium_filter
-filter-plugin/logstash-filter-trino-guardium/logstash-filter-trino-guardium_filter
+input-plugin/logstash-input-s3sqs/logstash-input-s3_sqs
+input-plugin/logstash-input-sqs-custom/logstash-input-custom_sqs
+
@@ -11,9 +11,11 @@ filter-plugin/logstash-filter-mysql-percona-guardium
 filter-plugin/logstash-filter-generic-guardium
 filter-plugin/logstash-filter-saphana-guardium
 filter-plugin/logstash-filter-cassandra-guardium
+filter-plugin/logstash-filter-mysql-aws-guardium
 filter-plugin/logstash-filter-aurora-mysql-guardium
 filter-plugin/logstash-filter-dynamodb-guardium
 filter-plugin/logstash-filter-neptune-aws-guardium
+filter-plugin/logstash-filter-cockroachdb-guardium
 filter-plugin/logstash-filter-couchbasedb-guardium
 filter-plugin/logstash-filter-couchdb-guardium
 filter-plugin/logstash-filter-mariadb-guardium
@@ -33,12 +35,18 @@ filter-plugin/logstash-filter-pubsub-firebase-realtime-guardium
 filter-plugin/logstash-filter-pubsub-firestore-guardium
 filter-plugin/logstash-filter-pubsub-spanner-guardium
 filter-plugin/logstash-filter-intersystems-iris-guardium
+filter-plugin/logstash-filter-postgres-guardium
 filter-plugin/logstash-filter-postgres-ibmcloud-guardium
 filter-plugin/logstash-filter-mysql-azure-guardium
 filter-plugin/logstash-filter-scylldb-guardium
+filter-plugin/logstash-filter-databricks-guardium
+filter-plugin/logstash-filter-trino-guardium
+filter-plugin/logstash-filter-capella-guardium
+filter-plugin/logstash-filter-opensearch-guardium
+filter-plugin/logstash-filter-milvus-guardium
+filter-plugin/logstash-filter-singlestore-guardium
+filter-plugin/logstash-filter-alloydb-guardium
 input-plugin/logstash-input-mongo-atlas
+input-plugin/logstash-input-s3sqs
 input-plugin/logstash-input-couchbase-capella
-input-plugin/logstash-input-http
-filter-plugin/logstash-filter-capella-guardium
-filter-plugin/logstash-filter-databricks-guardium
-filter-plugin/logstash-filter-trino-guardium
+input-plugin/logstash-input-sqs-custom
@@ -3,9 +3,11 @@ filter-plugin/logstash-filter-documentdb-aws-guardium/DocumentDBOverCloudwatchPa
 filter-plugin/logstash-filter-aurora-mysql-guardium/AuroraMysqlOverCloudwatchPackage
 filter-plugin/logstash-filter-dynamodb-guardium/DynamodbOverCloudwatch/DynamodbOverCloudwatchPackage
 #filter-plugin/logstash-filter-mariadb-aws-guardium/MariaDBOverCloudWatchPackage
+filter-plugin/logstash-filter-mysql-aws-guardium/MySQLOverS3SQS
 filter-plugin/logstash-filter-mysql-aws-guardium/MysqlOverCloudwatchLogsPackage
 filter-plugin/logstash-filter-neptune-aws-guardium/NeptuneOverCloudWatchPackage
 filter-plugin/logstash-filter-postgres-guardium/PostgresOverCloudWatchPackageß
+filter-plugin/logstash-filter-postgres-guardium/PostgresOverS3SQSPackage
 filter-plugin/logstash-filter-s3-guardium/S3OverCloudwatchLogsPackage
 filter-plugin/logstash-filter-s3-guardium/S3OverSQSPackage
 #Filebeat plug-ins
@@ -16,12 +18,14 @@ filter-plugin/logstash-filter-couchdb-guardium/CouchdbOverFilebeatPackage
 filter-plugin/logstash-filter-hdfs-guardium/HdfsOverFilebeatPackage
 filter-plugin/logstash-filter-mariadb-guardium/MariaDBOverFilebeatPackage
 filter-plugin/logstash-filter-mongodb-guardium/MongodbOverFilebeatPackage
+filter-plugin/logstash-filter-milvus-guardium/MilvusOverFilebeatPackage
 filter-plugin/logstash-filter-mysql-guardium/MysqlOverFilebeatPackage
 filter-plugin/logstash-filter-mysql-percona-guardium/MysqlPerconaOverFilebeatPackage
 filter-plugin/logstash-filter-neo4j-guardium/NeodbOverFilebeatPackage
 filter-plugin/logstash-filter-onPremGreenplumdb-guardium/GreenplumdbOverFilebeatPackage
 filter-plugin/logstash-filter-onPremPostgres-guardium/PostgresOverFilebeatPackage
 filter-plugin/logstash-filter-saphana-guardium/SaphanaOverFilebeatPackage
+filter-plugin/logstash-filter-singlestore-guardium/SingleStoreOverFilebeatPackage
 filter-plugin/logstash-filter-yugabyte-guardium/YugabytedbOverFilebeatPackage
 #JDBC plug-ins
 filter-plugin/logstash-filter-snowflake-guardium/SnowflakeOverJbdcPackage
@@ -37,18 +41,27 @@ filter-plugin/logstash-filter-pubsub-firestore-guardium/PubSubFireStorePackage
 filter-plugin/logstash-filter-pubsub-mysql-guardium/PubSubMySQLPackage
 filter-plugin/logstash-filter-pubsub-postgresql-guardium/PubSubPostgreSQLPackage
 filter-plugin/logstash-filter-pubsub-bigtable-guardium/gdp-pubsub-bigtable-package
+filter-plugin/logstash-filter-alloydb-guardium/AlloyDBoverPubSubPackage
 #Syslog plug-ins
+filter-plugin/logstash-filter-cockroachdb-guardium/CockroachDBOverSyslogPackage
 filter-plugin/logstash-filter-mongodb-guardium/MongoDBOverSyslogPackage
 filter-plugin/logstash-filter-mysql-guardium/MySQLOverSyslogPackage
 #Other
 filter-plugin/logstash-filter-mongodb-guardium/MongodbOverMongoAtlasPackage
 filter-plugin/logstash-filter-azure-postgresql-guardium/AzurePostgresqlOverAzureEventHub
+filter-plugin/logstash-filter-databricks-guardium/AzureDatabricksOverAzureEventHub
+filter-plugin/logstash-filter-trino-guardium/TrinoOverSyslogPackage
+filter-plugin/logstash-filter-capella-guardium/CapellaCouchbaseOverCapellaPackage
+filter-plugin/logstash-filter-opensearch-guardium/OpenSearchOverCloudwatchPackage
 #Input plug-ins
 input-plugin/logstash-input-azure-event-hubs/AzureEventHubsInputPackage
 input-plugin/logstash-input-beats/FilebeatInputPackage
+input-plugin/logstash-input-couchbase-capella/InputCouchbaseCapellaPackage
 input-plugin/logstash-input-cloudwatch-logs/CloudwatchLogsInputPackage
 input-plugin/logstash-input-jdbc/JdbcInputPackage
 input-plugin/logstash-input-mongo-atlas/InputMongoAtlasPackage
 input-plugin/logstash-input-sqs/SQSInputPackage
+input-plugin/logstash-input-sqs-custom/AWSSQSInputPackage
+input-plugin/logstash-input-s3sqs/InputS3SQSPackage;
 input-plugin/logstash-input-tcp-syslog/SyslogInputPackage
-input-plugin/logstash-input-google-pubsub/GooglePubSubPackage
+input-plugin/logstash-input-google-pubsub/GooglePubSubPackage
@@ -4,9 +4,11 @@ filter-plugin/logstash-filter-documentdb-aws-guardium/DocumentDBOverCloudwatchPa
 filter-plugin/logstash-filter-aurora-mysql-guardium/AuroraMysqlOverCloudwatchPackage;logstash-filter-auroramysqlguardiumpluginfilter.zip
 filter-plugin/logstash-filter-dynamodb-guardium/DynamodbOverCloudwatch/DynamodbOverCloudwatchPackage;logstash-filter-dynamodb_guardium_plugin_filter.zip
 filter-plugin/logstash-filter-mariadb-aws-guardium/MariaDBOverCloudWatchPackage;logstash-filter-mariadb_guardium_filter.zip
+filter-plugin/logstash-filter-mysql-aws-guardium/MySQLOverS3SQS;logstash-filter-mysql_guardium_plugin_filter.zip
 filter-plugin/logstash-filter-mysql-aws-guardium/MysqlOverCloudwatchLogsPackage;
 filter-plugin/logstash-filter-neptune-aws-guardium/NeptuneOverCloudWatchPackage;logstash-filter-neptune_guardium_filter.zip
 filter-plugin/logstash-filter-postgres-guardium/PostgresOverCloudWatchPackage;
+filter-plugin/logstash-filter-postgres-guardium/PostgresOverS3SQSPackage;logstash-filter-s3sqs_postgresql_guardium_plugin_filter.zip
 filter-plugin/logstash-filter-s3-guardium/S3OverCloudwatchLogsPackage;logstash-filter-logstash_filter_s3_guardium.zip
 filter-plugin/logstash-filter-s3-guardium/S3OverSQSPackage;logstash-filter-logstash_filter_s3_guardium.zip
 #Filebeat plug-ins
@@ -17,12 +19,14 @@ filter-plugin/logstash-filter-couchdb-guardium/CouchdbOverFilebeatPackage;logsta
 filter-plugin/logstash-filter-hdfs-guardium/HdfsOverFilebeatPackage;logstash-filter-hdfs_guardium_filter.zip
 filter-plugin/logstash-filter-mariadb-guardium/MariaDBOverFilebeatPackage;logstash-filter-mariadb_guardium_filter.zip
 filter-plugin/logstash-filter-mongodb-guardium/MongodbOverFilebeatPackage;logstash-filter-mongodb_guardium_filter.zip
+filter-plugin/logstash-filter-milvus-guardium/MilvusOverFilebeatPackage;logstash-filter-milvus_guardium_filter.zip
 filter-plugin/logstash-filter-mysql-guardium/MysqlOverFilebeatPackage;logstash-filter-mysql_filter_guardium.zip
 filter-plugin/logstash-filter-mysql-percona-guardium/MysqlPerconaOverFilebeatPackage;logstash-filter-mysql_percona_filter.zip
 filter-plugin/logstash-filter-neo4j-guardium/NeodbOverFilebeatPackage;logstash-filter-neodb_guardium_filter.zip
 filter-plugin/logstash-filter-onPremGreenplumdb-guardium/GreenplumdbOverFilebeatPackage;logstash-filter-greenplumdb_guardium_filter.zip
 filter-plugin/logstash-filter-onPremPostgres-guardium/PostgresOverFilebeatPackage;
 filter-plugin/logstash-filter-saphana-guardium/SaphanaOverFilebeatPackage;logstash-filter-saphana_guardium_plugin_filter.zip
+filter-plugin/logstash-filter-singlestore-guardium/SingleStoreOverFilebeatPackage;logstash-filter-singlestoredb_guardium_filter.zip
 filter-plugin/logstash-filter-yugabyte-guardium/YugabytedbOverFilebeatPackage;logstash-filter-yugabytedb_guardium_filter.zip
 #JDBC plug-ins
 filter-plugin/logstash-filter-snowflake-guardium/SnowflakeOverJbdcPackage;
@@ -32,6 +36,7 @@ filter-plugin/logstash-filter-mssql-guardium/MssqlOnPremOverJdbcPackage;
 filter-plugin/logstash-filter-saphana-guardium/SaphanaOverJdbcPackage;logstash-filter-saphana_guardium_plugin_filter.zip
 filter-plugin/logstash-filter-intersystems-iris-guardium/gi-filter-intersystems-iris-package;gi-filter-intersystems-iris-package.zip
 #GCP plug-ins
+filter-plugin/logstash-filter-alloydb-guardium/AlloyDBoverPubSubPackage;logstash-filter-alloydb_guardium_filter.zip
 filter-plugin/logstash-filter-pubsub-apachesolr-guardium/PubSubApacheSolrPackage;logstash-filter-apache_solr_gcp_connector.zip
 filter-plugin/logstash-filter-pubsub-bigquery-guardium/BigQueryOverPubSubPackage;logstash-filter-big_query_guardium_filter.zip
 filter-plugin/logstash-filter-pubsub-firebase-realtime-guardium/PubSubFirebasePackage;logstash-filter-fire_base_guardium_filter.zip
@@ -47,6 +52,7 @@ filter-plugin/logstash-filter-pubsub-bigquery-guardium/gi-pubsub-bigquery-packag
 filter-plugin/logstash-filter-pubsub-apachesolr-guardium/gi-pubsub-apachsolr-package;logstash-filter-apache_solr_gcp_connector.zip
 filter-plugin/logstash-filter-pubsub-bigtable-guardium/gi-pubsub-bigtable-package;logstash-filter-big_table_guardium_filter.zip
 #Syslog plug-ins
+filter-plugin/logstash-filter-cockroachdb-guardium/CockroachDBOverSyslogPackage;logstash-filter-cockroachdb_guardium_filter.zip
 filter-plugin/logstash-filter-onPremPostgres-guardium/PostgresOverSyslogPackage;
 filter-plugin/logstash-filter-yugabyte-guardium/YugabyteOverSyslogPackage;
 #Other
@@ -59,6 +65,8 @@ input-plugin/logstash-input-cloudwatch-logs/CloudwatchLogsInputPackage
 input-plugin/logstash-input-jdbc/JdbcInputPackage;
 input-plugin/logstash-input-mongo-atlas/InputMongoAtlasPackage;logstash-input-mongo_atlas_input.zip
 input-plugin/logstash-input-sqs/SQSInputPackage;
+input-plugin/logstash-input-sqs-custom/AWSSQSInputPackage;logstash-input-custom_sqs.zip
+input-plugin/logstash-input-s3sqs/InputS3SQSPackage;
 input-plugin/logstash-input-tcp-syslog/TCPInputPackage;
 input-plugin/logstash-input-google-pubsub/GooglePubSubPackage;
-input-plugin/logstash-input-google-pubsub/gi-pubsub-package;
+input-plugin/logstash-input-google-pubsub/gi-pubsub-package;
@@ -12,24 +12,38 @@ version "${file("VERSION").text.trim()}"
 // ===========================================================================
 
 
-sourceCompatibility = 1.8
-targetCompatibility = 1.8
+sourceCompatibility = JavaVersion.VERSION_17
+targetCompatibility = JavaVersion.VERSION_17
 
 buildscript {
     repositories {
-        mavenCentral()
-        jcenter()
-    }    
+        mavenLocal()
+        maven {
+            url System.getenv("ARTIFACTORY_URL") ?: "https://repo.maven.apache.org/maven2/"
+            credentials {
+                username System.getenv("ARTIFACTORY_USERNAME") ?: ""
+                password System.getenv("ARTIFACTORY_AUTH_TOKEN") ?: ""
+            }
+        }
+    }
 }
 
 repositories {
-    mavenCentral()
+    mavenLocal()
+    maven {
+        url System.getenv("ARTIFACTORY_URL") ?: "https://repo.maven.apache.org/maven2/"
+        credentials {
+            username System.getenv("ARTIFACTORY_USERNAME") ?: ""
+            password System.getenv("ARTIFACTORY_AUTH_TOKEN") ?: ""
+        }
+    }
 }
 
 
 
 dependencies {
     implementation group: 'commons-validator', name: 'commons-validator', version: '1.7'
+    implementation group: 'commons-beanutils', name: 'commons-beanutils', version: '1.11.0'
     implementation group: 'org.apache.logging.log4j', name: 'log4j-core', version: '2.23.1'
     implementation group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.17.2'
     implementation group: 'com.google.guava', name: 'guava', version: '33.3.1-jre'
@@ -52,15 +66,23 @@ tasks.withType(JavaCompile) {
 
 task javadocJar(type: Jar) {
     from javadoc
-    classifier = 'javadoc'
+    archiveClassifier = 'javadoc'
 }
 
 task sourcesJar(type: Jar) {
     from sourceSets.main.allJava
-    classifier = 'sources'
+    archiveClassifier = 'sources'
 }
 
 artifacts {
      archives sourcesJar
      archives javadocJar
 }
+
+task copyDependencies(type: Copy) {
+    description 'Copies all runtime dependencies into build/libs directory'
+    from configurations.runtimeClasspath
+    into "${buildDir}/libs"
+}
+
+jar.finalizedBy(copyDependencies)
@@ -1,5 +1,7 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-7.4.2-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.11.1-bin.zip
+networkTimeout=10000
+validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
@@ -5,7 +5,15 @@
 import com.ibm.guardium.universalconnector.commons.custom_parsing.excepton.InvalidConfigurationException;
 import com.ibm.guardium.universalconnector.commons.custom_parsing.parsers.IParser;
 import com.ibm.guardium.universalconnector.commons.structures.Record;
-import com.ibm.guardium.universalconnector.commons.structures.*;
+import com.ibm.guardium.universalconnector.commons.structures.Accessor;
+import com.ibm.guardium.universalconnector.commons.structures.Construct;
+import com.ibm.guardium.universalconnector.commons.structures.Data;
+import com.ibm.guardium.universalconnector.commons.structures.ExceptionRecord;
+import com.ibm.guardium.universalconnector.commons.structures.Record;
+import com.ibm.guardium.universalconnector.commons.structures.Sentence;
+import com.ibm.guardium.universalconnector.commons.structures.SentenceObject;
+import com.ibm.guardium.universalconnector.commons.structures.SessionLocator;
+import com.ibm.guardium.universalconnector.commons.structures.Time;
 import org.apache.commons.validator.routines.InetAddressValidator;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -216,7 +224,7 @@ protected SessionLocator getSessionLocator(String payload) {
 
         String clientIp = getClientIp(payload);
         String clientIpv6 = getClientIpv6(payload);
-        if (clientIpv6 != null && inetAddressValidator.isValidInet6Address(clientIpv6)) {
+        if (clientIpv6 != null && !clientIpv6.equals(DEFAULT_IPV6) && inetAddressValidator.isValidInet6Address(clientIpv6)) {
             // If client IP is IPv6, set both client and server to IPv6
             sessionLocator.setIpv6(true);
             sessionLocator.setClientIpv6(clientIpv6);