我正在使用NodeJs MS，到目前为止，它们通过Kafka Consumer / Producer进行通信。现在，我需要构建一个Loggger MS，该MS必须记录所有消息并进行一些处理（解析并保存到db），但是我不确定是否可以使用Kafka Stream改进当前方法，还是应该继续使用Consumers？ >
我正在使用NodeJs MS，到目前为止，它们通过Kafka Consumer / Producer进行通信。现在，我需要建立一个Loggger MS，该MS必须记录所有消息并进行一些处理（解析并保存到db），...
Streams API是位于Consumer / Producer API之上的更高层次的抽象。 Streams API允许您过滤和转换消息，并构建处理步骤的拓扑。
建立一个Loggger MS，该MS必须记录所有消息并进行一些处理（解析并保存到db）