Dcp.Net.MQ.KafkaMQ
1.0.1.8
dotnet add package Dcp.Net.MQ.KafkaMQ --version 1.0.1.8
NuGet\Install-Package Dcp.Net.MQ.KafkaMQ -Version 1.0.1.8
<PackageReference Include="Dcp.Net.MQ.KafkaMQ" Version="1.0.1.8" />
paket add Dcp.Net.MQ.KafkaMQ --version 1.0.1.8
#r "nuget: Dcp.Net.MQ.KafkaMQ, 1.0.1.8"
// Install Dcp.Net.MQ.KafkaMQ as a Cake Addin #addin nuget:?package=Dcp.Net.MQ.KafkaMQ&version=1.0.1.8 // Install Dcp.Net.MQ.KafkaMQ as a Cake Tool #tool nuget:?package=Dcp.Net.MQ.KafkaMQ&version=1.0.1.8
支持泛型发送与原始数组发送,支持string类型接收
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
.NET Core | netcoreapp2.0 was computed. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
.NET Standard | netstandard2.0 is compatible. netstandard2.1 was computed. |
.NET Framework | net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
MonoAndroid | monoandroid was computed. |
MonoMac | monomac was computed. |
MonoTouch | monotouch was computed. |
Tizen | tizen40 was computed. tizen60 was computed. |
Xamarin.iOS | xamarinios was computed. |
Xamarin.Mac | xamarinmac was computed. |
Xamarin.TVOS | xamarintvos was computed. |
Xamarin.WatchOS | xamarinwatchos was computed. |
-
.NETStandard 2.0
- Confluent.Kafka (>= 1.4.0)
- Geek.Net.MQ (>= 1.0.2.8)
NuGet packages (2)
Showing the top 2 NuGet packages that depend on Dcp.Net.MQ.KafkaMQ:
Package | Downloads |
---|---|
Dcp.Net.MQ.Rpc
RpcManager rpcManager = new RpcManager(_mqAddress, "demo测试131243"); rpcManager.RegisterAssembly(typeof(Program).Assembly); rpcManager.StartServer(); rpcManager.CreateClient(); var rpcTestApi = DcpApiClientProxy.Create<IRpcTestApi>(); while (Console.ReadLine()!="exit") { var result=rpcTestApi.WriteLine("测试WriteLine方法=》" + DateTime.Now).Result; Console.WriteLine("client"+result.data); } |
|
Dcp.Net.MQ.Lib
增加kafka支持泛型与原始数组发送 |
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
1.0.1.8 | 2,952 | 3/11/2022 |
1.0.1.7 | 2,550 | 6/10/2021 |
1.0.1.6 | 682 | 6/10/2021 |
1.0.1.5 | 542 | 6/3/2021 |
1.0.1.4 | 512 | 5/27/2021 |
1.0.1.3 | 510 | 4/22/2021 |
1.0.1.2 | 499 | 4/22/2021 |
1.0.0.9 | 518 | 3/15/2021 |
1.0.0.8 | 521 | 3/12/2021 |
1.0.0.7 | 519 | 3/12/2021 |
1.0.0.6 | 532 | 3/12/2021 |
1.0.0.5 | 404 | 3/12/2021 |
1.0.0.4 | 509 | 3/5/2021 |
1.0.0.3 | 325 | 3/2/2021 |
1.0.0.2 | 3,738 | 5/18/2020 |
1.0.0.1 | 450 | 5/13/2020 |
增加阿里云的认证访问模式
修改kafka默认消费起点,从最开始消费
AutoOffsetReset.Earliest