使用Confluent.Kafka从.net核心服务写入Kafka

我有一个.net核心服务,从MEMSQL服务器获取数据并返回给客户端。 但是,在服务中生成的查询需要logging到Kafka集群。

我试着安装Confluent.Kafka软件包并进行日志logging,在本地运行时工作正常。 但在容器中,该服务无法logging并生成以下错误:

warning NU1701: Package 'librdkafka.redist 0.9.5' was restored using '.NETFramework,Version=v4.6.1' instead of the project target framework '.NETCoreApp,Version=v2.0'. This package may not be fully compatible with your project. The type initializer for 'Confluent.Kafka.Impl.LibRdKafka' threw an exception. 

容器在LINUX机器上运行。 基本上,我需要找出与.netcore 2.0兼容的Confluent.Kafka版本,而不依赖.NETFramework v4.6的版本。

这个警告是无害的 – 这是因为librdkafka.redist不包含任何托pipe代码,因此nuget无法确定目标框架是什么。 这个警告已经在即将发布的版本中得到解决,我们应该在一个星期之内发布。

更新到最新的Confluent软件包0.11.3修复了这个问题。 现在该服务可以从泊坞窗容器访问Kafka集群。