fix: resolve test failures from dependency upgrades

- Upgrade elastic test image from 7.13.2 to 8.17.0 for go-elasticsearch/v8 compatibility
- Fix esapi import to use v8 package path
- Remove stale go-elasticsearch v0.0.0 dependency
- Fix mysql test image tag from 8.0.25 to 8.0 for ARM64 support
- Fix kafka test HostIP from "localhost" to "0.0.0.0" for valid port binding

Author: ravisuhag

go.mod

@@ -19,7 +19,6 @@ require (
 	github.com/d5/tengo/v2 v2.17.0
 	github.com/denisenkom/go-mssqldb v0.12.3
 	github.com/dnaeon/go-vcr/v2 v2.0.1
-	github.com/elastic/go-elasticsearch v0.0.0
 	github.com/elastic/go-elasticsearch/v8 v8.19.3
 	github.com/go-kivik/couchdb v2.0.0+incompatible
 	github.com/go-kivik/kivik v2.0.0+incompatible

go.sum

@@ -278,8 +278,6 @@ github.com/ebitengine/purego v0.10.0 h1:QIw4xfpWT6GWTzaW5XEKy3HXoqrJGx1ijYHzTF0/
 github.com/ebitengine/purego v0.10.0/go.mod h1:iIjxzd6CiRiOG0UyXP+V1+jWqUXVjPKLAI0mRfJZTmQ=
 github.com/elastic/elastic-transport-go/v8 v8.9.0 h1:KeT/2P54F0xS0S8Y3Pf+tFDg4HmBgReQMB+BMz8dDAs=
 github.com/elastic/elastic-transport-go/v8 v8.9.0/go.mod h1:ssMTvNS2hwf7CaiGsRRsx4gQHFZ/jS/DkLcISxekWzc=
-github.com/elastic/go-elasticsearch v0.0.0 h1:Pd5fqOuBxKxv83b0+xOAJDAkziWYwFinWnBO0y+TZaA=
-github.com/elastic/go-elasticsearch v0.0.0/go.mod h1:TkBSJBuTyFdBnrNqoPc54FN0vKf5c04IdM4zuStJ7xg=
 github.com/elastic/go-elasticsearch/v8 v8.19.3 h1:5LDg0hfGJXBa9Y+2QlUgRTsNJ/7rm7oNidydtFAq0LI=
 github.com/elastic/go-elasticsearch/v8 v8.19.3/go.mod h1:tHJQdInFa6abmDbDCEH2LJja07l/SIpaGpJcm13nt7s=
 github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=

plugins/extractors/elastic/elastic_test.go

@@ -17,8 +17,8 @@ import (
 	"google.golang.org/protobuf/types/known/anypb"
 	"google.golang.org/protobuf/types/known/structpb"
 
-	"github.com/elastic/go-elasticsearch/esapi"
 	"github.com/elastic/go-elasticsearch/v8"
+	"github.com/elastic/go-elasticsearch/v8/esapi"
 	"github.com/ory/dockertest/v3"
 	"github.com/ory/dockertest/v3/docker"
 	v1beta2 "github.com/raystack/meteor/models/raystack/assets/v1beta2"
@@ -57,7 +57,7 @@ func TestMain(m *testing.M) {
 	// setup test
 	opts := dockertest.RunOptions{
 		Repository: "elasticsearch",
-		Tag:        "7.13.2",
+		Tag:        "8.17.0",
 		Env: []string{
 			"discovery.type=single-node",
 			"ES_JAVA_OPTS=-Xms512m -Xmx512m",

plugins/extractors/kafka/kafka_test.go

@@ -43,7 +43,7 @@ func TestMain(m *testing.M) {
 		ExposedPorts: []string{"9093"},
 		PortBindings: map[docker.Port][]docker.PortBinding{
 			"9093": {
-				{HostIP: "localhost", HostPort: "9093"},
+				{HostIP: "0.0.0.0", HostPort: "9093"},
 			},
 		},
 	}

plugins/extractors/mysql/mysql_test.go

@@ -41,7 +41,7 @@ func TestMain(m *testing.M) {
 	// setup test
 	opts := dockertest.RunOptions{
 		Repository: "mysql",
-		Tag:        "8.0.25",
+		Tag:        "8.0",
 		Env: []string{
 			"MYSQL_ALLOW_EMPTY_PASSWORD=true",
 		},