feat: Implement Kafka AFS adapter with core functionality

NebulaStore.sln

@@ -49,6 +49,14 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "test", "test", "{1704E723-9
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "NebulaStore.Afs.Nio.Tests", "afs\nio\test\NebulaStore.Afs.Nio.Tests.csproj", "{DA9E1E64-1245-4E0D-9C15-80980DAF1623}"
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "kafka", "kafka", "{1BD88259-B7C9-540F-5B25-1E0ED5959ADD}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "NebulaStore.Afs.Kafka", "afs\kafka\NebulaStore.Afs.Kafka.csproj", "{4FA9334E-6BC5-4344-9198-3E35A59960CE}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tests", "tests", "{E513C5C4-19AC-DE96-9AA2-AD595D283603}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "NebulaStore.Afs.Kafka.Tests", "afs\kafka\tests\NebulaStore.Afs.Kafka.Tests.csproj", "{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -203,6 +211,30 @@ Global
 		{DA9E1E64-1245-4E0D-9C15-80980DAF1623}.Release|x64.Build.0 = Release|Any CPU
 		{DA9E1E64-1245-4E0D-9C15-80980DAF1623}.Release|x86.ActiveCfg = Release|Any CPU
 		{DA9E1E64-1245-4E0D-9C15-80980DAF1623}.Release|x86.Build.0 = Release|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Debug|x64.Build.0 = Debug|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Debug|x86.Build.0 = Debug|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Release|Any CPU.Build.0 = Release|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Release|x64.ActiveCfg = Release|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Release|x64.Build.0 = Release|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Release|x86.ActiveCfg = Release|Any CPU
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE}.Release|x86.Build.0 = Release|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Debug|x64.Build.0 = Debug|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Debug|x86.Build.0 = Debug|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Release|Any CPU.Build.0 = Release|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Release|x64.ActiveCfg = Release|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Release|x64.Build.0 = Release|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Release|x86.ActiveCfg = Release|Any CPU
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -214,5 +246,9 @@ Global
 		{1EDD44A6-7440-4D73-907E-5B89EF199012} = {01885DAA-D6B3-261D-26CC-40273AA28AE8}
 		{1704E723-975B-8E7A-0A72-66948CF308B6} = {01885DAA-D6B3-261D-26CC-40273AA28AE8}
 		{DA9E1E64-1245-4E0D-9C15-80980DAF1623} = {1704E723-975B-8E7A-0A72-66948CF308B6}
+		{1BD88259-B7C9-540F-5B25-1E0ED5959ADD} = {1213A069-D226-59B6-6383-4AD31C1DF055}
+		{4FA9334E-6BC5-4344-9198-3E35A59960CE} = {1BD88259-B7C9-540F-5B25-1E0ED5959ADD}
+		{E513C5C4-19AC-DE96-9AA2-AD595D283603} = {1BD88259-B7C9-540F-5B25-1E0ED5959ADD}
+		{7ADFE9C7-790E-4D55-BBD9-9D3B747C8ACA} = {E513C5C4-19AC-DE96-9AA2-AD595D283603}
 	EndGlobalSection
 EndGlobal

afs/kafka/NebulaStore.Afs.Kafka.csproj

@@ -0,0 +1,39 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net9.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <LangVersion>latest</LangVersion>
+    <RootNamespace>NebulaStore.Afs.Kafka</RootNamespace>
+
+    <!-- Exclude test and example files from compilation -->
+    <DefaultItemExcludes>$(DefaultItemExcludes);tests/**;examples/**</DefaultItemExcludes>
+
+    <!-- Package Information -->
+    <PackageId>NebulaStore.Afs.Kafka</PackageId>
+    <Version>1.0.0</Version>
+    <Authors>NebulaStore Contributors</Authors>
+    <Company>NebulaStore</Company>
+    <Product>NebulaStore AFS Kafka Adapter</Product>
+    <Description>Apache Kafka adapter for NebulaStore Abstract File System (AFS). Provides event-driven storage with audit trails and time-travel capabilities.</Description>
+    <PackageTags>nebulastore;kafka;afs;storage;event-sourcing;audit-trail</PackageTags>
+    <PackageLicenseExpression>EPL-2.0</PackageLicenseExpression>
+    <RepositoryUrl>https://github.com/hadv/NebulaStore</RepositoryUrl>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <!-- Confluent.Kafka - Apache Kafka .NET client -->
+    <PackageReference Include="Confluent.Kafka" Version="2.6.1" />
+
+    <!-- MessagePack for serialization (inherited from NebulaStore.Storage) -->
+    <!-- Version is managed by parent dependencies -->
+  </ItemGroup>
+
+  <ItemGroup>
+    <!-- Reference to AFS Blobstore base -->
+    <ProjectReference Include="../blobstore/NebulaStore.Afs.Blobstore.csproj" />
+  </ItemGroup>
+
+</Project>
+