我的意思是，我知道经纪人、制片人、消费者和Kafka的主题。如果我创建了一个用户，并存储在Kafka中的Producer中，用户名：Person 12，密码：Person 12，我如何从消费者那里检索它并将其与用户输入进行匹配？我对Node JS并不陌生，但在过去的10天里我都搞不清楚。
lc8prwob1#
首先，在没有加密的情况下，您不应该在Kafka主题上存储明文密码。(您还应该限制可以使用授权访问这些主题的人员。)
但是，您通常不会将密码与用户名分开，因此使用JSON、Avro或Protobuf等结构化格式来创建包含密码的User对象。
有一个nodefluent/kafka-streams库存在，我还没有用过，但Kafka Streams允许使用KTable查找键值，因此使用用户名/ID作为键，您可以根据记录的值查找密码或整个用户对象
nodefluent/kafka-streams
1条答案
按热度按时间lc8prwob1#
首先，在没有加密的情况下，您不应该在Kafka主题上存储明文密码。(您还应该限制可以使用授权访问这些主题的人员。)
但是，您通常不会将密码与用户名分开，因此使用JSON、Avro或Protobuf等结构化格式来创建包含密码的User对象。
有一个
nodefluent/kafka-streams库存在，我还没有用过，但Kafka Streams允许使用KTable查找键值，因此使用用户名/ID作为键，您可以根据记录的值查找密码或整个用户对象