我尝试使用 confluent-kafka-dotnet
在docker容器中,它可以很好地与生产者和消费者一起工作。但要在合流控制中心获得流处理器,需要设置合流监视拦截器。需要将插件添加到配置:
var config = new Dictionary<string, object>
{
{ "bootstrap.servers", "kafka:9092" },
{ "plugin.library.paths", "monitoring-interceptor" }
};
我从手册中下载了适用于macos的libs,它运行得很好,但当我尝试在docker容器中运行此程序时,出现错误:
System.ArgumentException: dlopen() failed: monitoring-interceptor.so: cannot open shared object file: No such file or directory (plugin monitoring-interceptor)
at Confluent.Kafka.Impl.SafeConfigHandle.Set(String name, String value)
at Confluent.Kafka.Producer.<>c__DisplayClass23_0.<.ctor>b__3(KeyValuePair`2 kvp)
at System.Collections.Generic.List`1.ForEach(Action`1 action)
我尝试安装 confluent-librdkafka-plugins
从linux安装手册,但得到相同的问题。
暂无答案!
目前还没有任何答案,快来回答吧!