Dcp.Net.MQ.KafkaMQ 1.0.1.7

Install-Package Dcp.Net.MQ.KafkaMQ -Version 1.0.1.7
dotnet add package Dcp.Net.MQ.KafkaMQ --version 1.0.1.7
<PackageReference Include="Dcp.Net.MQ.KafkaMQ" Version="1.0.1.7" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add Dcp.Net.MQ.KafkaMQ --version 1.0.1.7
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: Dcp.Net.MQ.KafkaMQ, 1.0.1.7"
#r directive can be used in F# Interactive, C# scripting and .NET Interactive. Copy this into the interactive tool or source code of the script to reference the package.
// Install Dcp.Net.MQ.KafkaMQ as a Cake Addin
#addin nuget:?package=Dcp.Net.MQ.KafkaMQ&version=1.0.1.7

// Install Dcp.Net.MQ.KafkaMQ as a Cake Tool
#tool nuget:?package=Dcp.Net.MQ.KafkaMQ&version=1.0.1.7
The NuGet Team does not provide support for this client. Please contact its maintainers for support.

支持泛型发送与原始数组发送,支持string类型接收

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.7 1,156 6/10/2021
1.0.1.6 212 6/10/2021
1.0.1.5 208 6/3/2021
1.0.1.4 170 5/27/2021
1.0.1.3 169 4/22/2021
1.0.1.2 153 4/22/2021
1.0.0.9 161 3/15/2021
1.0.0.8 166 3/12/2021
1.0.0.7 184 3/12/2021
1.0.0.6 198 3/12/2021
1.0.0.5 170 3/12/2021
1.0.0.4 167 3/5/2021
1.0.0.3 91 3/2/2021
1.0.0.2 1,836 5/18/2020
1.0.0.1 218 5/13/2020

增加阿里云的认证访问模式
修改kafka默认消费起点,从最开始消费
AutoOffsetReset.Earliest