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

生产者推送消息,为什么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);
                }
            }
     }





发表于: 4月前   最后更新时间: 4月前   游览量:419
上一条: 到头了!
下一条: 已经是最后了!

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