TestKafkaDistributed.init fails on Apple Silicon

[elonazoulay]

The TestKafkaDistributed.init method fails with the following message on apple silicon. I tried increasing the following kafka producer properties with no luck:

• linger_ms
• delivery timeout
• request timeout Also tried using newer images: 7.4.1 and 7.4.1-1-ubi8 and setting the kafka heap size to 2g. All of the above failed including running the test in isolation with 3g (and 6g) heap and setting TESTCONTAINERS_SKIP_ARCHITECTURE_CHECK to true.

I then tried this same branch on a linux ec2 instance (default amazon ami) and the test passes repeatedly when run in isolation with the above arguments: 3g heap, skip test container architecture check. The test also passes in ci.

[ERROR] Failures: 
[ERROR]   TestKafkaDistributed>AbstractTestQueryFramework.init:104->createQueryRunner:30 » QueryFailed Actual written bytes: '374374' not equal to expected written bytes: '375837'

One hypothesis is that the advertised listeners are not set correctly but I am still investigating. Using apple m1 with docker desktop v24.0.2 and virtualization framework + experimental feature to use rosetta enabled.

[elonazoulay]

For context, I was testing #18485 and #16828.

[elonazoulay]

The init method fails when trying to insert from the tpch.tiny.customers table.