var messageData = new KafkaMessage { MessageId = i.ToString(), Content = $"我是内容_{i}", CreateTime = DateTime.Now };
  await _messageBus.PublishAsync(messageData);

   await _messageBus.SubscribeAsync<KafkaMessage>(async (message) =>
   {
       var current = Interlocked.Increment(ref Count);
       Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss fff")}消费数据：MessageId={message.MessageId},Content=                         {message.Content},count={current}");
       await Task.CompletedTask;
   });