生产者推送消息,为什么TASK状态一直是WaitingForActivation?

liu 发表于: 2019-01-08   最后更新时间: 2019-01-08 11:12:33   4,017 游览

生产者推送消息,为什么TASK状态一直是WaitingForActivation?

.NET

protected async Task PushSummaryData(string data, Item v)
        {
            var config = new Dictionary<string, object>
            {
                {"bootstrap.servers",v.kafka.BootstrapServers}
            };

            using (var p = new Producer<Null, string>(config, null, new StringSerializer(Encoding.UTF8)))
            {
                try
                {
                    WLog.WriteLog("UnitDataPush", "数据正在发送!");
                    var dr = await p.ProduceAsync(v.kafka.Topic, null, data);
                    WLog.WriteLog("UnitDataPush", dr.Error.Code.ToString());
                }
                catch (KafkaException e)
                {
                    WLog.WriteLog("UnitDataPush", e.Error.Reason);
                }
            }
     }
发表于 2019-01-08
liu
添加评论

java出身,不好意思,帮助不了你。

liu -> 半兽人 5年前

问题已解决。

半兽人 -> liu 5年前

分享下问题原因,留给其他遇到同样问题的人呀

你的答案

查看kafka相关的其他问题或提一个您自己的问题