Я очень заинтригован потоками Redis.(Похоже, что есть потенциал для создания небольших систем, основанных на логах дополнения, таких как Kafka, но без дополнительных затрат на Kafka.)
Это просто XADD для журнала / потока и для использования записииз журнала / потока.Но что делать, если вы хотите объединить два потока?
Kafka Streams, Flink, Spark и т. Д. Предоставляют средства для этого.Есть ли эквивалент во вселенной Redis?
Если нет, я думаю, мне просто нужно реализовать свою собственную вещь, которая использует два потока, выполняет собственную логику соединения из сообщений и публикует обратно вновый поток.Если у других есть опыт работы с Redis Streams, поделитесь своими указаниями или предупреждениями.