我正在尝试设计即时消息,或者更确切地说,我正在做基于回合制的游戏,其机制如下:

玩家“A”做某事并将有关他的步骤的信息发送给玩家“B” . 玩家“B”接收此信息也做某事并回复玩家“A” .

我正在考虑kafka sink连接器,如果它可以作为客户端托管在kafka之外?因为它是一种避免编写大量代码并通过分区为客户端提供良好的消息接收机制的好方法,因此可以使用schemas e.t.c.我想做以下事情,例如:

两个客户端可以订阅一个主题,并可以使用某些信息在彼此之间交换消息 .

有可能是这样的吗?

或者,如果不可能,我只是在思考..如果要在源连接器中执行2个侦听器,在接收器中执行另一个侦听器,以便以kafka管理的任何方式发送和接收消息 . 它有意义吗,你怎么看?

我只是收集想法如何以最佳和最快的速度实现它,具有良好的性能,可扩展性和更少的工作量 . :)