2017-04-26 176 views
0

我创建了一个java class用于记录消耗,我连接到相应的服务器和一切完成,而从我的本地机器运行此class它的工作,并能够消费消息,但在maven构建获取jar文件,我从那里把这个jar文件放在我的服务器上我正在运行我的java class,它正在订阅这个主题,之后没有收到消息,但是在本地它正在订阅和接收消息。kafka消费者不消耗服务器中的记录

+0

当消费者在服务器上运行时,您是否尝试过向服务器生成附加消息? – user2122031

回答

0

在服务器中,kafka服务器IP是不同的,这就是它无法使用消息的原因。更改kafka服务器IP后,其工作。

相关问题