diff --git a/build/common.props b/build/common.props
index 96c74eb..18e2186 100644
--- a/build/common.props
+++ b/build/common.props
@@ -39,7 +39,7 @@
-
+
diff --git a/docker-compose.yml b/docker-compose.yml
index 0361d07..57df1c0 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -1,11 +1,10 @@
# https://raw.githubusercontent.com/bitnami/bitnami-docker-kafka/master/docker-compose.yml
-version: "2"
services:
kafka:
hostname: kafka
container_name: kafka
- image: docker.io/bitnami/kafka:3.6.1
+ image: docker.io/bitnami/kafka:3.8.0
ports:
- "9092:9092"
- "29092:29092"
@@ -28,11 +27,13 @@ services:
- KAFKA_CFG_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=1
volumes:
- "kafkadata:/bitnami"
+
ready:
image: andrewlock/wait-for-dependencies
command: kafka:9092
depends_on:
- kafka
+
volumes:
kafkadata:
- driver: local
\ No newline at end of file
+ driver: local
diff --git a/src/Foundatio.Kafka/Foundatio.Kafka.csproj b/src/Foundatio.Kafka/Foundatio.Kafka.csproj
index 9e58521..792aed7 100644
--- a/src/Foundatio.Kafka/Foundatio.Kafka.csproj
+++ b/src/Foundatio.Kafka/Foundatio.Kafka.csproj
@@ -1,8 +1,8 @@
-
+
-
+
diff --git a/tests/Directory.Build.props b/tests/Directory.Build.props
index 407c652..99d6211 100644
--- a/tests/Directory.Build.props
+++ b/tests/Directory.Build.props
@@ -6,13 +6,13 @@
$(NoWarn);CS1591;NU1701
-
-
+
+
-
+
diff --git a/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusTestBase.cs b/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusTestBase.cs
index bb45885..1ad7477 100644
--- a/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusTestBase.cs
+++ b/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusTestBase.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
using System.Threading.Tasks;
using Foundatio.Messaging;
using Foundatio.Tests.Messaging;
diff --git a/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusTests.cs b/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusTests.cs
index 4f8f2b9..f770a0f 100644
--- a/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusTests.cs
+++ b/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusTests.cs
@@ -105,6 +105,12 @@ public override void CanDisposeWithNoSubscribersOrPublishers()
base.CanDisposeWithNoSubscribersOrPublishers();
}
+ [Fact]
+ public override Task CanSendMappedMessageAsync()
+ {
+ return base.CanSendMappedMessageAsync();
+ }
+
[Fact]
public async Task CanPersistAndNotLoseMessages()
{