在空气中稳定的多价态金属氧化物# Chemistry - 化学
h*4
1 楼
有个问题:
在服务器端是有jar连接kafka做consumer,现在给客户端提供一个rest url,客户端可
以提供一个topic和groupId用get 来读数据。
现在的问题是怎样用一个get,然后服务器端就能不断的给客户端发信息,直到topic上
面的信息都发出去,然后维持5分钟,然后断掉。而且在此期间,如果又有新的消息,
那么服务器会发给客户并且重新注册时间。
看了kafka-rest,他们的实现方法是在zookeeper那注册一个consumer,然后每20秒左
右给客户端发一次回馈,不过这20秒过后get失效,要客户端重新发一个get request到
rest url来获取下一个20秒的信息。 不能实现一个连续不断的get...
大家有没有研究过这个方面?
看了websocket 和 twitterStream,好像有点意思
在服务器端是有jar连接kafka做consumer,现在给客户端提供一个rest url,客户端可
以提供一个topic和groupId用get 来读数据。
现在的问题是怎样用一个get,然后服务器端就能不断的给客户端发信息,直到topic上
面的信息都发出去,然后维持5分钟,然后断掉。而且在此期间,如果又有新的消息,
那么服务器会发给客户并且重新注册时间。
看了kafka-rest,他们的实现方法是在zookeeper那注册一个consumer,然后每20秒左
右给客户端发一次回馈,不过这20秒过后get失效,要客户端重新发一个get request到
rest url来获取下一个20秒的信息。 不能实现一个连续不断的get...
大家有没有研究过这个方面?
看了websocket 和 twitterStream,好像有点意思