生产者推送消息,为什么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);
}
}
}
java出身,不好意思,帮助不了你。
问题已解决。
分享下问题原因,留给其他遇到同样问题的人呀
你的答案