WebApplicationFactory Setup for Kafka Messaging

[Tieantono]

Hi @jeremydmiller, I'm trying to setup the integration test for my web app project that have dependency to Kafka / Redpanda using custom WebApplicationFactory setup. However, the test sometimes got aborted and an exception occurred even with minimal setups. The project specifications:

• ASP.NET Core 8.0
• WolverineFx.Kafka version 3.12.2
• WolverineFx.Postgresql version 3.12.2
• xUnit version 2.9.3
• Redpanda version 24.2.8

Exception:

Fatal error. System.AccessViolationException: Attempted to read or write protected memory. This is often an indication that other memory is corrupt.
Repeat 2 times:
--------------------------------
   at Confluent.Kafka.Impl.NativeMethods.NativeMethods.rd_kafka_consumer_poll(IntPtr, IntPtr)
--------------------------------
   at Confluent.Kafka.Impl.Librdkafka.consumer_poll(IntPtr, IntPtr)
   at Confluent.Kafka.Impl.SafeKafkaHandle.ConsumerPoll(IntPtr)
   at Confluent.Kafka.Consumer`2[[System.__Canon, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e],[System.__Canon, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e]].Consume(Int32)
   at Confluent.Kafka.Consumer`2[[System.__Canon, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e],[System.__Canon, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e]].Consume(System.Threading.CancellationToken)
   at Wolverine.Kafka.Internals.KafkaListener+<>c__DisplayClass7_0+<<-ctor>b__0>d.MoveNext()
   at System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[[Wolverine.Kafka.Internals.KafkaListener+<>c__DisplayClass7_0+<<-ctor>b__0>d, Wolverine.Kafka, Version=0.0.0.0, Culture=neutral, PublicKeyToken=null]](<<-ctor>b__0>d ByRef)
   at System.Runtime.CompilerServices.AsyncTaskMethodBuilder.Start[[Wolverine.Kafka.Internals.KafkaListener+<>c__DisplayClass7_0+<<-ctor>b__0>d, Wolverine.Kafka, Version=0.0.0.0, Culture=neutral, PublicKeyToken=null]](<<-ctor>b__0>d ByRef)
   at Wolverine.Kafka.Internals.KafkaListener+<>c__DisplayClass7_0.<.ctor>b__0()
   at System.Threading.Tasks.Task`1[[System.__Canon, System.Private.CoreLib, Version=8.0.0.0, Culture=neutral, PublicKeyToken=7cec85d7bea7798e]].InnerInvoke()
   at System.Threading.ExecutionContext.RunFromThreadPoolDispatchLoop(System.Threading.Thread, System.Threading.ExecutionContext, System.Threading.ContextCallback, System.Object)
   at System.Threading.Tasks.Task.ExecuteWithThreadLocal(System.Threading.Tasks.Task ByRef, System.Threading.Thread)
   at System.Threading.ThreadPoolWorkQueue.Dispatch()
   at System.Threading.PortableThreadPool+WorkerThread.WorkerThreadStart()

This is the minimal repo that I've mentioned is here: https://github.com/Tieantono/WolverineTest
You can use this attached Docker Compose file to run the Redpanda service: docker-compose.txt

I just want to make sure whether the test setup is correct or how to properly setup the Kafka listener for integration test.