我在visual sdudio中使用c#。创建了两个项目，一个是生产者的，一个是消费者。我想在WinForm上通过窗体发送和接收消息。最开始，我实现了窗体发消息、cmd接收消息，也就是说producer到topic的过程是打通了的。
结果是这样的，我在窗体里输入什么，就在cmd输出什么（有用json做了解析）
在运行代码之前，我已经启动zookeeper和kafka:start zookeeper: zookeeper-server-start.bat ../../config/zookeeper.properties
然后是kafka：start kafka: kafka-server-start.bat ../../config/server.properties
然后是打开消费者：kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
producer的代码：string topic = "test";
consumerMsg = entry.Key + " is: " + entry.Value;
KafkaNet.Protocol.Message kafkaProducerMsg = new KafkaNet.Protocol.Message(consumerMsg);
var options = new KafkaOptions(uri);
var router = new BrokerRouter(options);
var client = new Producer(router);
client.SendMessageAsync(topic, new List<KafkaNet.Protocol.Message> {kafkaProducerMsg }).Wait();
接着我想把consumer也变成窗体，代码如下：
{class Program{static void Main(string[] args){
Uri uri = new Uri("http://localhost:9092");
string topicName = "test";
var options = new KafkaOptions(uri);
var brokerRouter = new BrokerRouter(options);
var consumer = new Consumer(new ConsumerOptions(topicName, brokerRouter));
Console.WriteLine("on foreach..."); // I use cw to find out how far I go
foreach (var msg in consumer.Consume())
{
Console.WriteLine("in foreach...");
Console.WriteLine(Encoding.UTF8.GetString(msg.Value));
}
Console.ReadLine();
}}}
但是什么都接收不到……consumer.Consumer()里面貌似是空的
output窗口有这样一堆东西：Awaiting message from: http://myacount.me.cn:9092/
Received message of size: 36 From: http://myacount.me.cn:9092/
Awaiting message from: http://myacount.me.cn:9092/
Received message of size: 36 From: http://myacount.me.cn:9092/
所以consumer其实是收到message的吧？但是为啥窗体啥都不显示呢？可能是我的事件用错了？我尝试了textchange，buttonclick（就是点击OK，就开始接收消息），都没有反应。所以我到底哪里做错了呢？还是漏了什么？
感谢大家的帮助！！！我真的好着急……
