pulsar: various test fixes (#4309)

* pulsar: use native ARM image to fix container startup timeouts

Switch from apachepulsar/pulsar-standalone:2.8.3 (amd64-only) to
apachepulsar/pulsar:3.3.4 (multi-arch) so the container runs natively
on ARM instead of under x86 emulation. This eliminates the slow
startup that caused context deadline exceeded errors.

Fixes CON-387

* pulsar: disable StreamTestAtLeastOnceDelivery due to upstream data race

The benthos StreamTestAtLeastOnceDelivery test helper has an unsynchronized
concurrent map read/write at stream_test_definitions.go:571-584. A goroutine
iterates a shared map while another writes to it. Since this is in upstream
benthos code, disabling the test until the race is fixed upstream.

Fixes CON-415

Author: mmatczuk

internal/impl/pulsar/integration_test.go

@@ -30,8 +30,8 @@ import (
 func TestIntegrationPulsar(t *testing.T) {
 	integration.CheckSkip(t)
 
-	ctr, err := testcontainers.Run(t.Context(), "apachepulsar/pulsar-standalone:2.8.3",
-		testcontainers.WithImagePlatform("linux/amd64"),
+	ctr, err := testcontainers.Run(t.Context(), "apachepulsar/pulsar:3.3.4",
+		testcontainers.WithCmd("bin/pulsar", "standalone"),
 		testcontainers.WithExposedPorts("6650/tcp", "8080/tcp"),
 		testcontainers.WithWaitStrategyAndDeadline(3*time.Minute,
 			wait.ForHTTP("/admin/v2/brokers/ready").WithPort("8080/tcp").WithStartupTimeout(3*time.Minute),
@@ -95,7 +95,8 @@ input:
 		integration.StreamTestStreamParallel(1000),
 		integration.StreamTestStreamParallelLossy(1000),
 		integration.StreamTestStreamParallelLossyThroughReconnect(1000),
-		integration.StreamTestAtLeastOnceDelivery(),
+		// StreamTestAtLeastOnceDelivery disabled due to upstream data race in
+		// benthos stream_test_definitions.go:571-584 (concurrent map read/write).
 	)
 
 	suite.Run(