Merge branch 'main' of github.com:FoundatioFx/Foundatio.Kafka

FoundatioFx · Oct 14, 2024 · 6e3c266 · 6e3c266
2 parents 74616f4 + 535038d
commit 6e3c266
Show file tree

Hide file tree

Showing 6 changed files with 17 additions and 10 deletions.
diff --git a/build/common.props b/build/common.props
@@ -39,7 +39,7 @@
   <ItemGroup>
     <PackageReference Include="Microsoft.SourceLink.GitHub" Version="8.0.0" PrivateAssets="All"/>
     <PackageReference Include="AsyncFixer" Version="1.6.0" PrivateAssets="All" />
-    <PackageReference Include="MinVer" Version="5.0.0" PrivateAssets="All" />
+    <PackageReference Include="MinVer" Version="6.0.0" PrivateAssets="All" />
   </ItemGroup>
 
   <ItemGroup>

diff --git 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
+    driver: local
diff --git a/src/Foundatio.Kafka/Foundatio.Kafka.csproj b/src/Foundatio.Kafka/Foundatio.Kafka.csproj
@@ -1,8 +1,8 @@
 <Project Sdk="Microsoft.NET.Sdk">
   <ItemGroup>
-    <PackageReference Include="Confluent.Kafka" Version="2.5.2" />
+    <PackageReference Include="Confluent.Kafka" Version="2.5.3" />
 
-    <PackageReference Include="Foundatio" Version="11.0.2" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
+    <PackageReference Include="Foundatio" Version="11.0.5" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
     <ProjectReference Include="..\..\..\Foundatio\src\Foundatio\Foundatio.csproj" Condition="'$(ReferenceFoundatioSource)' == 'true'" />
   </ItemGroup>
 </Project>
diff --git a/tests/Directory.Build.props b/tests/Directory.Build.props
@@ -6,13 +6,13 @@
     <NoWarn>$(NoWarn);CS1591;NU1701</NoWarn>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.11.0" />
-    <PackageReference Include="xunit" Version="2.9.0" />
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.11.1" />
+    <PackageReference Include="xunit" Version="2.9.2" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.8.2" />
 
     <PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" PrivateAssets="All" />
 
-    <PackageReference Include="Foundatio.TestHarness" Version="11.0.2" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
+    <PackageReference Include="Foundatio.TestHarness" Version="11.0.5" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
     <ProjectReference Include="..\..\..\Foundatio\src\Foundatio.TestHarness\Foundatio.TestHarness.csproj" Condition="'$(ReferenceFoundatioSource)' == 'true'" />
   </ItemGroup>
 </Project>
diff --git 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
@@ -105,6 +105,12 @@ public override void CanDisposeWithNoSubscribersOrPublishers()
         base.CanDisposeWithNoSubscribersOrPublishers();
     }
 
+    [Fact]
+    public override Task CanSendMappedMessageAsync()
+    {
+        return base.CanSendMappedMessageAsync();
+    }
+
     [Fact]
     public async Task CanPersistAndNotLoseMessages()
     {