Kafka消费者为什么无法接收消息?

我在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,就开始接收消息),都没有反应。所以我到底哪里做错了呢?还是漏了什么?
感谢大家的帮助!!!我真的好着急……

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐