0
我创建了一个java class
用于记录消耗,我连接到相应的服务器和一切完成,而从我的本地机器运行此class
它的工作,并能够消费消息,但在maven构建获取jar文件,我从那里把这个jar文件放在我的服务器上我正在运行我的java class
,它正在订阅这个主题,之后没有收到消息,但是在本地它正在订阅和接收消息。kafka消费者不消耗服务器中的记录
我创建了一个java class
用于记录消耗,我连接到相应的服务器和一切完成,而从我的本地机器运行此class
它的工作,并能够消费消息,但在maven构建获取jar文件,我从那里把这个jar文件放在我的服务器上我正在运行我的java class
,它正在订阅这个主题,之后没有收到消息,但是在本地它正在订阅和接收消息。kafka消费者不消耗服务器中的记录
在服务器中,kafka服务器IP是不同的,这就是它无法使用消息的原因。更改kafka服务器IP后,其工作。
当消费者在服务器上运行时,您是否尝试过向服务器生成附加消息? – user2122031