Unstable operation of Kafka consumer with ConcurrentConsumerLimit option set when the broker stops

Contact Details
No response
Version
8.x (develop, pre-release), 8.x
On which operating system(s) are you experiencing the issue?
Linux
Using which broker(s) did you encounter the issue?
Kafka
What are the steps required to reproduce the issue?

1. Start kafka broker and create topic "pings-new" with 20 partitions
2. Stop kafka broker
3. Start one instance of application with kafka consumer with ConcurrentConsumerLimit = 20
4. Start kafka broker

What is the expected behavior?
Application consumes messages
What actually happened?
Application don't consumes messages.  Kafka consumer group is empty.
The issue also occurs when the broker stops during normal operation of application(interruption happens in approximately 50 percent of cases)
Related log output, including any exceptions
No response
Link to repository that demonstrates/reproduces the issue
https://github.com/cpplance/MassTransitKafkaTester

how many partitions do you have on the topic?

I tried 1 and 20 partitions, result is the same.

I tried 1 and 20 partitions, result is the same.

https://masstransit.io/documentation/configuration/transports/kafka

Updated steps to reproduce the issue:

Start kafka broker and create topic "pings-new" with 20 partitions
Stop kafka broker
Start one instance of application with kafka consumer with ConcurrentConsumerLimit = 20
Start kafka broker

What is the expected behavior? Application consumes messages.
What actually happened? Application don't consumes messages. Kafka consumer group is empty.

Updated steps to reproduce the issue:

Start kafka broker and create topic "pings-new" with 20 partitions

Stop kafka broker

Start one instance of application with kafka consumer with ConcurrentConsumerLimit = 20

Start kafka broker

What is the expected behavior? Application consumes messages.
What actually happened? Application don't consumes messages. Kafka consumer group is empty.

how long do you wait for it to start consuming? I think kafka has pretty big rebalance timeout by default (at least with zookeeper). can you try waiting for at least 5mins?

how long do you wait for it to start consuming? I think kafka has pretty big rebalance timeout by default (at least with zookeeper). can you try waiting for at least 5mins?
waited for 20 minutes, same result. Kafka consumer group remains empty

can you give us MT your logs?

If it works with ConcurrentConsumerLimit = 1 I'd suggest using that value or some other lower value. As stated above, it's likely an issue with consumer rebalancing on the Kafka side, but the logs should offer some indication.

Author

Your logs are full of produce logs, I suggest you do separate app for producer (to make debugging more easy)
You need to have Debug log, so we can see what Consumer is doing

Replaced https://github.com/cpplance/MassTransitKafkaTester with separate consumer/producer projects
These are new logs with a Trace log level
issue_trace_logs.log
its no issue with consumer rebalancing on the Kafka side. Rebalancing occurs after the consumer group joins, but in this case, the consumers don't even connect. I checked kafka broker logs and there is no consumers connected.

Replaced https://github.com/cpplance/MassTransitKafkaTester with separate consumer/producer projects These are new logs with a Trace log level issue_trace_logs.log
its no issue with consumer rebalancing on the Kafka side. Rebalancing occurs after the consumer group joins, but in this case, the consumers don't even connect. I checked kafka broker logs and there is no consumers connected.

forgot to ask, which exact version? there was some version when we fixed similar behavior, btw, can you also look into broker logs?

Replaced https://github.com/cpplance/MassTransitKafkaTester with separate consumer/producer projects These are new logs with a Trace log level issue_trace_logs.log
its no issue with consumer rebalancing on the Kafka side. Rebalancing occurs after the consumer group joins, but in this case, the consumers don't even connect. I checked kafka broker logs and there is no consumers connected.

forgot to ask, which exact version? there was some version when we fixed similar behavior, btw, can you also look into broker logs?

Yes, I remember that issue with earlier version. It was with ConcurrentConsumerLimit = 1. This is a new problem only with ConcurrentConsumerLimit. I've also checked the broker logs. the consumers aren't connecting.

that's clearly the issue with MT then. I'll try to take a look, but can't promise when

It's 8.2.2, per the linked repository.
Also, this package is deprecated and should NOT be included: https://github.com/cpplance/MassTransitKafkaTester/blob/master/MtKafkaIssueConsumer/MtKafkaIssueConsumer.csproj#L16

Tested it without deprecated package, the problem remains.

that is what I get:
20:52:48.562-I Configured endpoint ConcurrentConsumersReceive_Specs, Consumer: MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer
20:52:48.595-D Starting bus instances: IBus
20:52:48.596-D Starting bus: loopback://localhost/
20:52:48.596-D Endpoint Ready: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_migoyyg6ww5pdyfrbdqe6baoro
20:52:51.373-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:52:51.373-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:52:51.373-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:52:51.373-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:52:51.373-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:52:51.670-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:52:51.670-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:52:51.670-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:52:51.670-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:52:51.670-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:52:51.832-D Endpoint Faulted: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs

MassTransit.KafkaConnectionException: ReceiveTransport faulted: multiple-consumers-test
 ---> Confluent.Kafka.KafkaException: localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT)
   at MassTransit.KafkaIntegration.Middleware.KafkaConsumerFilter`2.Send(ConsumerContext context, IPipe`1 next) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/Transports/MassTransit.KafkaIntegration/KafkaIntegration/Middleware/KafkaConsumerFilter.cs:line 31
   at MassTransit.Middleware.ReceiveEndpointDependencyFilter`1.Send(TContext context, IPipe`1 next) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Middleware/ReceiveEndpointDependencyFilter.cs:line 23
   at MassTransit.Agents.PipeContextSupervisor`1.Send(IPipe`1 pipe, CancellationToken cancellationToken) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Agents/PipeContextSupervisor.cs:line 55
   at MassTransit.Agents.PipeContextSupervisor`1.Send(IPipe`1 pipe, CancellationToken cancellationToken) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Agents/PipeContextSupervisor.cs:line 61
   at MassTransit.Agents.PipeContextSupervisor`1.Send(IPipe`1 pipe, CancellationToken cancellationToken) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Agents/PipeContextSupervisor.cs:line 67
   at MassTransit.Transports.ReceiveTransport`1.ReceiveTransportAgent.RunTransport() in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Transports/ReceiveTransport.cs:line 195
   --- End of inner exception stack trace ---
20:53:07.325-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:07.325-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:07.325-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:07.325-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:07.325-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:07.511-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:07.511-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:07.511-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:07.511-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:07.511-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:07.587-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
20:53:07.587-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
20:53:20.271-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 2ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:20.270-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 4ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:20.271-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 2ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:20.278-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 2ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:20.378-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test. IsFatal(False)
20:53:20.378-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:20.491-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:20.491-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:20.491-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
20:53:20.491-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
20:53:20.834-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
20:53:20.879-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
20:53:20.919-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
20:53:38.592-D Endpoint Ready: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs
20:53:38.598-I Bus started: loopback://localhost/
20:53:38.601-D Partition: multiple-consumers-test [[4]] with -1001 was assigned to: rdkafka-be571148-f256-4bef-bb31-d1fc635ce330
20:53:38.603-D Partition: multiple-consumers-test [[0]] with -1001 was assigned to: rdkafka-4fa4394a-374d-4f5a-8071-c524a7e4e12f
20:53:38.603-D Partition: multiple-consumers-test [[2]] with -1001 was assigned to: rdkafka-58d8bd51-47e3-47e6-924d-65bd43612771
20:53:38.604-D Partition: multiple-consumers-test [[8]] with -1001 was assigned to: rdkafka-fc280e9f-8ed9-40f5-8000-7addc93ffcca
20:53:38.604-D Partition: multiple-consumers-test [[6]] with -1001 was assigned to: rdkafka-d093a6cf-b50b-4555-a990-6e8b25b816c6
20:53:38.604-D Partition: multiple-consumers-test [[5]] with -1001 was assigned to: rdkafka-be571148-f256-4bef-bb31-d1fc635ce330
20:53:38.605-D Partition: multiple-consumers-test [[1]] with -1001 was assigned to: rdkafka-4fa4394a-374d-4f5a-8071-c524a7e4e12f
20:53:38.605-D Partition: multiple-consumers-test [[3]] with -1001 was assigned to: rdkafka-58d8bd51-47e3-47e6-924d-65bd43612771
20:53:38.605-D Partition: multiple-consumers-test [[9]] with -1001 was assigned to: rdkafka-fc280e9f-8ed9-40f5-8000-7addc93ffcca
20:53:38.605-D Partition: multiple-consumers-test [[7]] with -1001 was assigned to: rdkafka-d093a6cf-b50b-4555-a990-6e8b25b816c6
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-6422-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-49ce-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-ed98-08dc8f072e7f MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-d074-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-250c-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-e7d0-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-8312-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-03aa-08dc8f072e8a MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-98ca-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.853-D SEND loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-b652-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
20:53:39.919-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-ed98-08dc8f072e7f MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0083695)
20:53:39.919-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-49ce-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0083745)
20:53:39.919-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-8312-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0083812)
20:53:39.919-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-b652-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0083837)
20:53:39.919-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-e7d0-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0083513)
20:53:39.925-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-98ca-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0007017)
20:53:39.925-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-03aa-08dc8f072e8a MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0006908)
20:53:39.925-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-6422-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0006888)
20:53:39.925-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-d074-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0007065)
20:53:39.925-D RECEIVE loopback://localhost/kafka/multiple-consumers-test 5d4d0000-dea5-36d1-250c-08dc8f072e89 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0007022)
20:53:39.926-D Stopping bus instances: IBus
20:53:39.929-D Stopping bus: loopback://localhost/
20:53:39.933-D Endpoint Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs
20:53:39.934-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
20:53:39.935-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
20:53:39.935-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
20:53:39.936-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
20:53:39.936-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
20:53:40.100-D Partition: multiple-consumers-test [[6]] was closed on rdkafka-d093a6cf-b50b-4555-a990-6e8b25b816c6
20:53:40.100-D Partition: multiple-consumers-test [[2]] was closed on rdkafka-58d8bd51-47e3-47e6-924d-65bd43612771
20:53:40.100-D Partition: multiple-consumers-test [[4]] was closed on rdkafka-be571148-f256-4bef-bb31-d1fc635ce330
20:53:40.100-D Partition: multiple-consumers-test [[8]] was closed on rdkafka-fc280e9f-8ed9-40f5-8000-7addc93ffcca
20:53:40.100-D Partition: multiple-consumers-test [[0]] was closed on rdkafka-4fa4394a-374d-4f5a-8071-c524a7e4e12f
20:53:40.345-D Partition: multiple-consumers-test [[2]] updating checkpoint with offset: 6 on rdkafka-58d8bd51-47e3-47e6-924d-65bd43612771
20:53:40.345-D Partition: multiple-consumers-test [[6]] updating checkpoint with offset: 6 on rdkafka-d093a6cf-b50b-4555-a990-6e8b25b816c6
20:53:40.345-D Partition: multiple-consumers-test [[0]] updating checkpoint with offset: 6 on rdkafka-4fa4394a-374d-4f5a-8071-c524a7e4e12f
20:53:40.345-D Partition: multiple-consumers-test [[8]] updating checkpoint with offset: 6 on rdkafka-fc280e9f-8ed9-40f5-8000-7addc93ffcca
20:53:40.346-D Partition: multiple-consumers-test [[1]] was closed on rdkafka-4fa4394a-374d-4f5a-8071-c524a7e4e12f
20:53:40.346-D Partition: multiple-consumers-test [[9]] was closed on rdkafka-fc280e9f-8ed9-40f5-8000-7addc93ffcca
20:53:40.346-D Partition: multiple-consumers-test [[5]] was closed on rdkafka-be571148-f256-4bef-bb31-d1fc635ce330
20:53:40.346-D Partition: multiple-consumers-test [[3]] was closed on rdkafka-58d8bd51-47e3-47e6-924d-65bd43612771
20:53:40.346-D Partition: multiple-consumers-test [[7]] was closed on rdkafka-d093a6cf-b50b-4555-a990-6e8b25b816c6
20:53:40.364-D Partition: multiple-consumers-test [[4]] updating checkpoint with offset: 6 on rdkafka-be571148-f256-4bef-bb31-d1fc635ce330
20:53:40.364-D Partition: multiple-consumers-test [[5]] updating checkpoint with offset: 6 on rdkafka-be571148-f256-4bef-bb31-d1fc635ce330
20:53:40.364-D Partition: multiple-consumers-test [[1]] updating checkpoint with offset: 6 on rdkafka-4fa4394a-374d-4f5a-8071-c524a7e4e12f
20:53:40.364-D Partition: multiple-consumers-test [[9]] updating checkpoint with offset: 6 on rdkafka-fc280e9f-8ed9-40f5-8000-7addc93ffcca
20:53:40.366-D Partition: multiple-consumers-test [[3]] updating checkpoint with offset: 6 on rdkafka-58d8bd51-47e3-47e6-924d-65bd43612771
20:53:40.367-D Partition: multiple-consumers-test [[7]] updating checkpoint with offset: 6 on rdkafka-d093a6cf-b50b-4555-a990-6e8b25b816c6
20:53:40.382-D Endpoint Completed: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs
20:53:40.384-D Consumer Completed: loopback://localhost/kafka/multiple-consumers-test/ConcurrentConsumersReceive_Specs: 10 received, 5 concurrent
20:53:40.485-D Endpoint Stopping: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_migoyyg6ww5pdyfrbdqe6baoro
20:53:40.486-D Consumer Stopping: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_migoyyg6ww5pdyfrbdqe6baoro (Stop Receive Transport)
20:53:40.491-D Endpoint Completed: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_migoyyg6ww5pdyfrbdqe6baoro
20:53:40.491-D Consumer Completed: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_migoyyg6ww5pdyfrbdqe6baoro: 0 received, 0 concurrent
20:53:40.496-I Bus stopped: loopback://localhost/

ConcurrentConsumersReceive_Specs

Even if I change the line
c.ConcurrentConsumerLimit = concurrentConsumers / 2;
to
c.ConcurrentConsumerLimit = concurrentConsumers
tests still works for me.
But the test application doesn't work. I found that if I change ConcurrentConsumerLimit in the application to the number of partitions / 2, the issue disappears.

The issue in the test application disappears if I add topic creation using c.CreateIfMissing(y => y.NumPartitions = 20);
(as it happens in a unit test)

MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs.Should_receive_with_multiple_consumers

10:30:44.912-I Configured endpoint ConcurrentConsumersReceive_Specs, Consumer: MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer
10:30:44.940-D Starting bus instances: IBus
10:30:44.941-D Starting bus: loopback://localhost/
10:30:44.941-D Endpoint Ready: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_ht8oyyg6ww5pdirybdqe66kwn3
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.678-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.678-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.678-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.679-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.679-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.679-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.679-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.679-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.679-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.721-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:48.923-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.967-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.967-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.967-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:49.004-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:49.004-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:49.024-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:49.024-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:49.080-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:49.178-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:49.243-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:49.278-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:49.313-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:49.369-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:49.418-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:49.483-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:49.619-D Endpoint Faulted: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs

MassTransit.KafkaConnectionException: ReceiveTransport faulted: multiple-consumers-test-2
 ---> Confluent.Kafka.KafkaException: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT)
   at MassTransit.KafkaIntegration.Middleware.KafkaConsumerFilter`2.Send(ConsumerContext context, IPipe`1 next) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/Transports/MassTransit.KafkaIntegration/KafkaIntegration/Middleware/KafkaConsumerFilter.cs:line 31
   at MassTransit.Middleware.ReceiveEndpointDependencyFilter`1.Send(TContext context, IPipe`1 next) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Middleware/ReceiveEndpointDependencyFilter.cs:line 23
   at MassTransit.Agents.PipeContextSupervisor`1.Send(IPipe`1 pipe, CancellationToken cancellationToken) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Agents/PipeContextSupervisor.cs:line 55
   at MassTransit.Agents.PipeContextSupervisor`1.Send(IPipe`1 pipe, CancellationToken cancellationToken) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Agents/PipeContextSupervisor.cs:line 61
   at MassTransit.Agents.PipeContextSupervisor`1.Send(IPipe`1 pipe, CancellationToken cancellationToken) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Agents/PipeContextSupervisor.cs:line 67
   at MassTransit.Transports.ReceiveTransport`1.ReceiveTransportAgent.RunTransport() in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Transports/ReceiveTransport.cs:line 195
   --- End of inner exception stack trace ---
10:30:58.681-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 2ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.681-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 2ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.681-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.682-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.681-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.682-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 2ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.682-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.682-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 2ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.682-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:58.803-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.883-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.883-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.964-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.964-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.989-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.964-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.989-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.992-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:58.996-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:58.996-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.036-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.039-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:59.320-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.219-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:59.261-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.362-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:59.261-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.264-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.292-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.320-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.320-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.440-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.362-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.374-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:59.510-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.489-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:59.583-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.583-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.583-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.777-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.777-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:30:59.777-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.777-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.777-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:59.795-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2.  IsFatal(False)
10:31:09.853-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:09.854-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:09.853-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:09.853-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:09.854-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:09.854-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:09.854-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:09.861-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:09.869-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2.  IsFatal(False)
10:31:10.322-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:10.565-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:10.565-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:10.565-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:10.354-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:10.565-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:10.431-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:10.489-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:10.541-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:10.541-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:10.545-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2.  IsFatal(False)
10:31:26.072-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.105-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.105-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.105-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.104-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.105-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.105-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.324-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.324-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.324-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.324-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.393-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.393-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.393-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.393-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.393-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.393-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.459-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:26.459-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:26.501-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.501-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.522-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.568-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.568-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.598-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:26.627-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:26.628-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.907-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:26.795-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.800-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.962-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.962-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:26.827-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:26.800-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.907-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.907-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.907-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:26.907-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:27.108-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:26.929-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:27.140-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:27.009-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:31:27.055-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2.  IsFatal(False)
10:31:59.325-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:59.325-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:59.326-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:59.444-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:59.485-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:59.645-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:59.615-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:59.645-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:59.774-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:59.774-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:59.803-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:59.803-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:59.985-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:59.879-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:31:59.879-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:31:59.985-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.018-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.012-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.012-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 2ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.202-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:00.164-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.164-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.295-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.077-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.307-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.289-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.289-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.312-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.307-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:00.337-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.466-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.397-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.611-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.611-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.611-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:00.611-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.699-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.750-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.827-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:00.827-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.904-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:00.904-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:00.994-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:01.119-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:01.211-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:01.312-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:01.448-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:01.549-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:01.643-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:00.994-W Stop Faulted

System.ObjectDisposedException: The CancellationTokenSource has been disposed.
   at System.Threading.CancellationTokenSource.Cancel()
   at MassTransit.KafkaIntegration.KafkaMessageConsumer`2.ActiveAndActualAgentsCompleted(StopContext context) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/Transports/MassTransit.KafkaIntegration/KafkaIntegration/KafkaMessageConsumer.cs:line 143
   at MassTransit.Middleware.Agent.Stop(StopContext context) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit.Abstractions/Middleware/Middleware/Agent.cs:line 88
   at MassTransit.Transports.ConsumerAgent`1.<SetConsumeTask>g__TryStop|23_0() in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit/Transports/ConsumerAgent.cs:line 97
10:32:01.749-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:01.796-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:01.960-W Stop Faulted

System.ObjectDisposedException: The CancellationTokenSource has been disposed.
   at System.Threading.CancellationTokenSource.Cancel()
   at MassTransit.KafkaIntegration.KafkaMessageConsumer`2.ActiveAndActualAgentsCompleted(StopContext context) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/Transports/MassTransit.KafkaIntegration/KafkaIntegration/KafkaMessageConsumer.cs:line 143
   at MassTransit.Middleware.Agent.Stop(StopContext context) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit.Abstractions/Middleware/Middleware/Agent.cs:line 88
   at MassTransit.Middleware.Supervisor.StopSupervisor(StopSupervisorContext context) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit.Abstractions/Middleware/Middleware/Supervisor.cs:line 116
   at MassTransit.Middleware.Agent.Stop(StopContext context) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/MassTransit.Abstractions/Middleware/Middleware/Agent.cs:line 88
   at MassTransit.KafkaIntegration.Middleware.KafkaConsumerFilter`2.ConsumerSupervisor.<.ctor>b__0_0(Task _) in /Users/denys.kozhevnikov/src/GitHub/MassTransit/src/Transports/MassTransit.KafkaIntegration/KafkaIntegration/Middleware/KafkaConsumerFilter.cs:line 79
10:32:38.534-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:38.535-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:38.584-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:38.628-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:38.773-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:38.773-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:38.843-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:38.843-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:38.881-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:38.982-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:38.989-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.058-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.020-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.027-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:39.100-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.058-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.100-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.071-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.125-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.157-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.259-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.259-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.297-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:39.297-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.297-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.343-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.462-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.498-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:39.498-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.498-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.498-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.601-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.674-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.674-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:39.675-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.770-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.862-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:32:39.900-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:32:39.862-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.862-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:32:39.868-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2.  IsFatal(False)
10:33:20.101-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.117-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.263-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.263-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.350-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.407-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.407-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.465-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.504-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.536-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.606-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:20.633-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.790-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.790-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:20.633-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.664-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.857-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:20.790-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.917-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.917-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.844-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.917-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.823-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:20.844-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:20.982-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:21.224-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:21.224-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:21.224-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:21.272-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:21.303-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:21.303-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:21.272-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:21.408-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:21.316-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:21.354-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:21.408-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:21.377-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:21.377-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:21.385-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2.  IsFatal(False)
10:33:56.640-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:56.684-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:56.760-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:56.841-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:56.841-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:56.917-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:57.029-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.029-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:57.007-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.097-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:57.184-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.243-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.243-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:57.243-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.243-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.243-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.484-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:57.365-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:57.365-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:57.407-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:57.407-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:57.508-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.484-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.508-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:33:57.508-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.518-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:57.546-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.549-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.681-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.681-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:33:57.681-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:33:57.854-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2.   IsFatal(False)
10:34:35.392-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:35.434-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:35.510-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:35.565-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:35.565-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:35.723-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:35.750-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:35.750-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:35.750-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:35.817-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:35.971-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:35.971-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.001-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.001-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:35.971-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.005-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.104-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.156-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:36.156-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.160-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.209-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.245-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:36.419-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.330-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.330-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.350-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.419-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.419-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:36.459-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.684-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.538-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.652-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.684-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.684-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.684-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.684-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.684-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.684-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:36.740-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:34:36.785-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:36.941-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.941-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.941-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.941-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:34:36.976-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.068-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.174-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.272-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.357-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.460-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.516-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.598-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.702-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.748-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:34:37.796-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consumer stopped, stopping supervisor)
10:35:13.043-D Partition: multiple-consumers-test-2 [[0]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.043-D Partition: multiple-consumers-test-2 [[10]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.043-D Partition: multiple-consumers-test-2 [[1]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.043-D Partition: multiple-consumers-test-2 [[11]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.065-D Partition: multiple-consumers-test-2 [[2]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.065-D Partition: multiple-consumers-test-2 [[12]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.065-D Partition: multiple-consumers-test-2 [[3]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.065-D Partition: multiple-consumers-test-2 [[4]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.065-D Partition: multiple-consumers-test-2 [[5]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.065-D Partition: multiple-consumers-test-2 [[13]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.066-D Partition: multiple-consumers-test-2 [[14]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.066-D Partition: multiple-consumers-test-2 [[6]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.066-D Partition: multiple-consumers-test-2 [[15]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.066-D Partition: multiple-consumers-test-2 [[7]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.066-D Partition: multiple-consumers-test-2 [[16]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.066-D Partition: multiple-consumers-test-2 [[8]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.066-D Partition: multiple-consumers-test-2 [[17]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.066-D Partition: multiple-consumers-test-2 [[18]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:13.066-D Partition: multiple-consumers-test-2 [[9]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:13.066-D Partition: multiple-consumers-test-2 [[19]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.143-D Partition: multiple-consumers-test-2 [[0]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.143-D Partition: multiple-consumers-test-2 [[10]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.317-D Partition: multiple-consumers-test-2 [[11]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.317-D Partition: multiple-consumers-test-2 [[1]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.317-D Partition: multiple-consumers-test-2 [[2]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.343-D Partition: multiple-consumers-test-2 [[12]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.343-D Partition: multiple-consumers-test-2 [[3]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.368-D Partition: multiple-consumers-test-2 [[13]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.368-D Partition: multiple-consumers-test-2 [[4]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.405-D Partition: multiple-consumers-test-2 [[5]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.405-D Partition: multiple-consumers-test-2 [[14]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.406-D Partition: multiple-consumers-test-2 [[6]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.417-D Partition: multiple-consumers-test-2 [[7]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.417-D Partition: multiple-consumers-test-2 [[15]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.417-D Partition: multiple-consumers-test-2 [[8]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.418-D Partition: multiple-consumers-test-2 [[16]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.418-D Partition: multiple-consumers-test-2 [[9]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.418-D Partition: multiple-consumers-test-2 [[17]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.419-D Partition: multiple-consumers-test-2 [[18]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.419-D Partition: multiple-consumers-test-2 [[19]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.432-D Partition: multiple-consumers-test-2 [[7]] with -1001 was assigned to: rdkafka-44d0c1ad-eee0-44ed-8adc-587bc3666ad5
10:35:16.433-D Partition: multiple-consumers-test-2 [[1]] with -1001 was assigned to: rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:16.433-D Partition: multiple-consumers-test-2 [[2]] with -1001 was assigned to: rdkafka-14e50262-231a-4b1c-84d9-212bc0565c2b
10:35:16.434-D Partition: multiple-consumers-test-2 [[4]] with -1001 was assigned to: rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:16.434-D Partition: multiple-consumers-test-2 [[14]] with -1001 was assigned to: rdkafka-acd34053-8865-4572-86e4-41118b20285d
10:35:16.434-D Partition: multiple-consumers-test-2 [[0]] with -1001 was assigned to: rdkafka-052fd9c0-c101-47de-821e-39f3fac461b4
10:35:16.434-D Partition: multiple-consumers-test-2 [[18]] with -1001 was assigned to: rdkafka-f5185bbf-9a64-44ed-bbfb-66b8efed6b26
10:35:16.434-D Partition: multiple-consumers-test-2 [[12]] with -1001 was assigned to: rdkafka-8e689303-f486-4457-a942-a8c6362aded7
10:35:16.434-D Partition: multiple-consumers-test-2 [[9]] with -1001 was assigned to: rdkafka-5225f793-153c-47ff-8547-b6e689e36dfa
10:35:16.434-D Partition: multiple-consumers-test-2 [[10]] with -1001 was assigned to: rdkafka-6114f1e7-1d29-4bcb-be83-171d437d8e4d
10:35:16.434-D Partition: multiple-consumers-test-2 [[13]] with -1001 was assigned to: rdkafka-973cfdb3-337b-4fc6-8744-c37db5fd17e4
10:35:16.434-D Partition: multiple-consumers-test-2 [[5]] with -1001 was assigned to: rdkafka-321e3956-673e-4e09-8d61-e4296885eadc
10:35:16.434-D Partition: multiple-consumers-test-2 [[3]] with -1001 was assigned to: rdkafka-1e1d30a2-64f1-4f39-941d-d0f010ae7fdf
10:35:16.434-D Partition: multiple-consumers-test-2 [[19]] with -1001 was assigned to: rdkafka-fb4be67e-ecb0-46c9-9e33-ad429067ee7a
10:35:16.434-D Partition: multiple-consumers-test-2 [[15]] with -1001 was assigned to: rdkafka-b6981f8a-e39c-4dd5-aa99-4828bb102a35
10:35:16.434-D Partition: multiple-consumers-test-2 [[8]] with -1001 was assigned to: rdkafka-472802e8-c713-4cec-9d6a-ec9834b174b4
10:35:16.434-D Partition: multiple-consumers-test-2 [[11]] with -1001 was assigned to: rdkafka-689c4836-a9af-40e0-99a8-d457e1e7b5fc
10:35:16.434-D Partition: multiple-consumers-test-2 [[17]] with -1001 was assigned to: rdkafka-f3e4acb3-af53-45b9-a6fb-46048785b32e
10:35:16.436-D Partition: multiple-consumers-test-2 [[16]] with -1001 was assigned to: rdkafka-ea7692df-ea3a-4b3c-989b-0403a1914d6d
10:35:16.436-D Partition: multiple-consumers-test-2 [[6]] with -1001 was assigned to: rdkafka-3d0bf4c0-3afa-40ea-a039-34a29937c671
10:35:16.562-D Endpoint Ready: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs
10:35:16.565-I Bus started: loopback://localhost/
10:35:17.655-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-07c0-08dc8f79f658 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.658-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-0adc-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.658-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-31b0-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.658-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-5a32-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.658-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-7760-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.658-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-93f8-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.658-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-b086-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.665-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-d12e-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.665-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-ed8a-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.666-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-0a4a-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.666-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-3330-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.666-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-520c-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.666-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-6fa8-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.667-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-8d08-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.667-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-aa22-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.667-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-c6ce-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.667-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-e226-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.668-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-ff04-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.668-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-1b92-08dc8f79f663 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.668-D SEND loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-37b2-08dc8f79f663 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage
10:35:17.708-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-0adc-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0083479)
10:35:17.717-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-6fa8-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0006014)
10:35:17.717-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-07c0-08dc8f79f658 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0002536)
10:35:17.718-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-1b92-08dc8f79f663 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000147)
10:35:17.718-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-ed8a-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000113)
10:35:17.718-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-e226-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000137)
10:35:17.718-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-aa22-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000104)
10:35:17.718-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-520c-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000085)
10:35:17.718-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-0a4a-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000113)
10:35:17.719-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-3330-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000095)
10:35:17.719-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-8d08-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000121)
10:35:17.719-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-7760-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000077)
10:35:17.719-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-ff04-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000134)
10:35:17.719-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-d12e-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000075)
10:35:17.719-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-93f8-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000120)
10:35:17.720-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-37b2-08dc8f79f663 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000089)
10:35:17.720-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-5a32-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000133)
10:35:17.720-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-31b0-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000073)
10:35:17.720-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-b086-08dc8f79f661 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000090)
10:35:17.720-D RECEIVE loopback://localhost/kafka/multiple-consumers-test-2 e44f0000-dea5-36d1-c6ce-08dc8f79f662 MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessage MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer(00:00:00.0000079)
10:35:17.721-D Stopping bus instances: IBus
10:35:17.723-D Stopping bus: loopback://localhost/
10:35:17.728-D Endpoint Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs
10:35:17.729-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.730-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.730-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.730-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.731-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.731-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.731-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.732-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.732-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.733-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.733-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.733-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.734-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.734-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.734-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.735-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.735-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.735-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.736-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:17.736-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Stop Receive Transport)
10:35:18.306-D Partition: multiple-consumers-test-2 [[3]] was closed on rdkafka-1e1d30a2-64f1-4f39-941d-d0f010ae7fdf
10:35:18.306-D Partition: multiple-consumers-test-2 [[6]] was closed on rdkafka-3d0bf4c0-3afa-40ea-a039-34a29937c671
10:35:18.306-D Partition: multiple-consumers-test-2 [[14]] was closed on rdkafka-acd34053-8865-4572-86e4-41118b20285d
10:35:18.306-D Partition: multiple-consumers-test-2 [[2]] was closed on rdkafka-14e50262-231a-4b1c-84d9-212bc0565c2b
10:35:18.306-D Partition: multiple-consumers-test-2 [[8]] was closed on rdkafka-472802e8-c713-4cec-9d6a-ec9834b174b4
10:35:18.391-D Partition: multiple-consumers-test-2 [[1]] was closed on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:18.391-D Partition: multiple-consumers-test-2 [[12]] was closed on rdkafka-8e689303-f486-4457-a942-a8c6362aded7
10:35:18.391-D Partition: multiple-consumers-test-2 [[4]] was closed on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:18.391-D Partition: multiple-consumers-test-2 [[7]] was closed on rdkafka-44d0c1ad-eee0-44ed-8adc-587bc3666ad5
10:35:18.391-D Partition: multiple-consumers-test-2 [[5]] was closed on rdkafka-321e3956-673e-4e09-8d61-e4296885eadc
10:35:18.417-D Partition: multiple-consumers-test-2 [[18]] was closed on rdkafka-f5185bbf-9a64-44ed-bbfb-66b8efed6b26
10:35:18.417-D Partition: multiple-consumers-test-2 [[11]] was closed on rdkafka-689c4836-a9af-40e0-99a8-d457e1e7b5fc
10:35:18.417-D Partition: multiple-consumers-test-2 [[13]] was closed on rdkafka-973cfdb3-337b-4fc6-8744-c37db5fd17e4
10:35:18.417-D Partition: multiple-consumers-test-2 [[10]] was closed on rdkafka-6114f1e7-1d29-4bcb-be83-171d437d8e4d
10:35:18.417-D Partition: multiple-consumers-test-2 [[19]] was closed on rdkafka-fb4be67e-ecb0-46c9-9e33-ad429067ee7a
10:35:18.417-D Partition: multiple-consumers-test-2 [[0]] was closed on rdkafka-052fd9c0-c101-47de-821e-39f3fac461b4
10:35:18.451-D Partition: multiple-consumers-test-2 [[9]] was closed on rdkafka-5225f793-153c-47ff-8547-b6e689e36dfa
10:35:18.451-D Partition: multiple-consumers-test-2 [[17]] was closed on rdkafka-f3e4acb3-af53-45b9-a6fb-46048785b32e
10:35:18.482-D Partition: multiple-consumers-test-2 [[15]] was closed on rdkafka-b6981f8a-e39c-4dd5-aa99-4828bb102a35
10:35:18.482-D Partition: multiple-consumers-test-2 [[16]] was closed on rdkafka-ea7692df-ea3a-4b3c-989b-0403a1914d6d
10:35:18.508-D Partition: multiple-consumers-test-2 [[6]] updating checkpoint with offset: 3 on rdkafka-3d0bf4c0-3afa-40ea-a039-34a29937c671
10:35:18.508-D Partition: multiple-consumers-test-2 [[2]] updating checkpoint with offset: 3 on rdkafka-14e50262-231a-4b1c-84d9-212bc0565c2b
10:35:18.508-D Partition: multiple-consumers-test-2 [[3]] updating checkpoint with offset: 3 on rdkafka-1e1d30a2-64f1-4f39-941d-d0f010ae7fdf
10:35:18.508-D Partition: multiple-consumers-test-2 [[14]] updating checkpoint with offset: 3 on rdkafka-acd34053-8865-4572-86e4-41118b20285d
10:35:18.508-D Partition: multiple-consumers-test-2 [[12]] updating checkpoint with offset: 3 on rdkafka-8e689303-f486-4457-a942-a8c6362aded7
10:35:18.508-D Partition: multiple-consumers-test-2 [[8]] updating checkpoint with offset: 3 on rdkafka-472802e8-c713-4cec-9d6a-ec9834b174b4
10:35:18.508-D Partition: multiple-consumers-test-2 [[1]] updating checkpoint with offset: 3 on rdkafka-0703e8ff-b957-4a81-801b-e87bbba938c2
10:35:18.515-D Partition: multiple-consumers-test-2 [[4]] updating checkpoint with offset: 3 on rdkafka-2e8da70b-b6e9-4eae-b233-741bcbdc0a32
10:35:18.520-D Partition: multiple-consumers-test-2 [[7]] updating checkpoint with offset: 3 on rdkafka-44d0c1ad-eee0-44ed-8adc-587bc3666ad5
10:35:18.531-D Partition: multiple-consumers-test-2 [[5]] updating checkpoint with offset: 3 on rdkafka-321e3956-673e-4e09-8d61-e4296885eadc
10:35:18.544-D Partition: multiple-consumers-test-2 [[18]] updating checkpoint with offset: 3 on rdkafka-f5185bbf-9a64-44ed-bbfb-66b8efed6b26
10:35:18.558-D Partition: multiple-consumers-test-2 [[11]] updating checkpoint with offset: 3 on rdkafka-689c4836-a9af-40e0-99a8-d457e1e7b5fc
10:35:18.570-D Partition: multiple-consumers-test-2 [[13]] updating checkpoint with offset: 3 on rdkafka-973cfdb3-337b-4fc6-8744-c37db5fd17e4
10:35:18.581-D Partition: multiple-consumers-test-2 [[0]] updating checkpoint with offset: 3 on rdkafka-052fd9c0-c101-47de-821e-39f3fac461b4
10:35:18.581-D Partition: multiple-consumers-test-2 [[15]] updating checkpoint with offset: 3 on rdkafka-b6981f8a-e39c-4dd5-aa99-4828bb102a35
10:35:18.581-D Partition: multiple-consumers-test-2 [[9]] updating checkpoint with offset: 3 on rdkafka-5225f793-153c-47ff-8547-b6e689e36dfa
10:35:18.581-D Partition: multiple-consumers-test-2 [[19]] updating checkpoint with offset: 3 on rdkafka-fb4be67e-ecb0-46c9-9e33-ad429067ee7a
10:35:18.581-D Partition: multiple-consumers-test-2 [[17]] updating checkpoint with offset: 3 on rdkafka-f3e4acb3-af53-45b9-a6fb-46048785b32e
10:35:18.581-D Partition: multiple-consumers-test-2 [[16]] updating checkpoint with offset: 3 on rdkafka-ea7692df-ea3a-4b3c-989b-0403a1914d6d
10:35:18.607-D Partition: multiple-consumers-test-2 [[10]] updating checkpoint with offset: 3 on rdkafka-6114f1e7-1d29-4bcb-be83-171d437d8e4d
10:35:18.674-D Endpoint Completed: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs
10:35:18.676-D Consumer Completed: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs: 20 received, 20 concurrent
10:35:18.753-D Endpoint Stopping: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_ht8oyyg6ww5pdirybdqe66kwn3
10:35:18.754-D Consumer Stopping: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_ht8oyyg6ww5pdirybdqe66kwn3 (Stop Receive Transport)
10:35:18.759-D Endpoint Completed: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_ht8oyyg6ww5pdirybdqe66kwn3
10:35:18.759-D Consumer Completed: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_ht8oyyg6ww5pdirybdqe66kwn3: 0 received, 0 concurrent
10:35:18.764-I Bus stopped: loopback://localhost/

    public class ConcurrentConsumersReceive_Specs :
        InMemoryTestFixture
    {
        const string Topic = "multiple-consumers-test-2";

        [Test]
        public async Task Should_receive_with_multiple_consumers()
        {
            const int concurrentConsumers = 20;
            await using var provider = new ServiceCollection()
                .ConfigureKafkaTestOptions(options =>
                {
                    //options.CreateTopicsIfNotExists = true;
                    options.TopicNames = new[] { Topic };
                    options.Partitions = concurrentConsumers;
                })
                .AddMassTransitTestHarness(x =>
                {
                    for (var i = 0; i < concurrentConsumers; i++)
                        x.AddTaskCompletionSource<ConsumeContext<KafkaMessage>>();
                    x.AddRider(rider =>
                    {
                        rider.AddProducer<KafkaMessage>(Topic);
                        rider.AddConsumer<KafkaMessageConsumer>();

                        rider.UsingKafka((context, k) =>
                        {
                            k.TopicEndpoint<KafkaMessage>(Topic, nameof(ConcurrentConsumersReceive_Specs), c =>
                            {
                                c.AutoOffsetReset = AutoOffsetReset.Earliest;
                                c.ConcurrentConsumerLimit = concurrentConsumers;

                                c.ConfigureConsumer<KafkaMessageConsumer>(context);
                            });
                        });
                    });
                }).BuildServiceProvider();

            var harness = provider.GetTestHarness();
            await harness.Start();

            ITopicProducer<KafkaMessage> producer = harness.GetProducer<KafkaMessage>();

            await Task.WhenAll(Enumerable.Range(0, concurrentConsumers).Select(i =>
                producer.Produce(new { }, Pipe.Execute<KafkaSendContext>(x => x.Partition = i), harness.CancellationToken)));

            await Task.WhenAll(provider.GetTasks<ConsumeContext<KafkaMessage>>()).OrCanceled(harness.CancellationToken);
        }

        class KafkaMessageConsumer :
            IConsumer<KafkaMessage>
        {
            readonly TaskCompletionSource<ConsumeContext<KafkaMessage>>[] _taskCompletionSource;

            public KafkaMessageConsumer(IEnumerable<TaskCompletionSource<ConsumeContext<KafkaMessage>>> taskCompletionSource)
            {
                _taskCompletionSource = taskCompletionSource.ToArray();
            }

            public async Task Consume(ConsumeContext<KafkaMessage> context)
            {
                var index = (context.Partition() ?? 0) % _taskCompletionSource.Length;
                _taskCompletionSource[index].TrySetResult(context);
            }
        }

        public interface KafkaMessage
        {
        }
    }

MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs.Should_receive_with_multiple_consumers

10:30:44.912-I Configured endpoint ConcurrentConsumersReceive_Specs, Consumer: MassTransit.KafkaIntegration.Tests.ConcurrentConsumersReceive_Specs+KafkaMessageConsumer
10:30:44.940-D Starting bus instances: IBus
10:30:44.941-D Starting bus: loopback://localhost/
10:30:44.941-D Endpoint Ready: loopback://localhost/DenyssLaptop_ReSharperTestRunner_bus_ht8oyyg6ww5pdirybdqe66kwn3
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv4#<IP_ADDRESS>:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.213-W Consumer [] error (Local_Transport): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) on multiple-consumers-test-2. IsFatal(False)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)
10:30:48.571-D Consumer Stopping: loopback://localhost/kafka/multiple-consumers-test-2/ConcurrentConsumersReceive_Specs (Consume Loop Exited)