公开(公告)号：US10484326B2

公开(公告)日：2019-11-19

申请号：US16242940

申请日：2019-01-08

申请人： Confluent, Inc.

发明人： Dan Norwood ,  Neha Narkhede ,  Anna Povzner ,  Joseph Adler ,  Yasuhiro Matsuda ,  Jay Kreps

IPC分类号： G06F15/16 ,  H04L12/58 ,  H04L12/26 ,  H04L12/66 ,  G06F9/54 ,  H04L12/18 ,  H04L29/06 ,  H04L12/24

摘要： A stream verification system for a distributed message queue system with metric collectors on each producer and consumer. A producer time stamp allows correlation of sent and received messages. Verification reports are organized by a message topic. A cumulative checksum allows detection of missing or corrupted messages. Verification messages are used to determine if a zero message report means no messages were sent, or rather that the messages weren't received.

公开(公告)号：US10212120B2

公开(公告)日：2019-02-19

申请号：US15494275

申请日：2017-04-21

申请人： Confluent, Inc.

发明人： Dan Norwood ,  Neha Narkhede ,  Anna Povzner ,  Joseph Adler ,  Yasuhiro Matsuda ,  Jay Kreps

IPC分类号： G06F15/16 ,  H04L12/58 ,  H04L12/26 ,  H04L12/66 ,  G06F9/54 ,  H04L12/18 ,  H04L29/06 ,  H04L12/24

摘要： A stream verification system for a distributed message queue system with metric collectors on each producer and consumer. A producer time stamp allows correlation of sent and received messages. Verification reports are organized by a message topic. A cumulative checksum allows detection of missing or corrupted messages. Verification messages are used to determine if a zero message report means no messages were sent, or rather that the messages weren't received.