diff --git a/src/help.h b/src/help.h index 005afd94..c89f1f44 100644 --- a/src/help.h +++ b/src/help.h @@ -975,7 +975,7 @@ struct commandHelp { "5.0.0" }, { "XPENDING", "key group [start end count] [consumer]", - "Return information and entries from a stream conusmer group pending entries list, that are messages fetched but never acknowledged.", + "Return information and entries from a stream consumer group pending entries list, that are messages fetched but never acknowledged.", 14, "5.0.0" }, { "XRANGE", diff --git a/src/t_stream.c b/src/t_stream.c index 6d8fd92c..16913f37 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -945,7 +945,7 @@ size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end /* This is an helper function for streamReplyWithRange() when called with * group and consumer arguments, but with a range that is referring to already * delivered messages. In this case we just emit messages that are already - * in the history of the conusmer, fetching the IDs from its PEL. + * in the history of the consumer, fetching the IDs from its PEL. * * Note that this function does not have a 'rev' argument because it's not * possible to iterate in reverse using a group. Basically this function @@ -1571,7 +1571,7 @@ void xgroupCommand(client *c) { "CREATE -- Create a new consumer group.", "SETID -- Set the current group ID.", "DESTROY -- Remove the specified group.", -"DELCONSUMER -- Remove the specified conusmer.", +"DELCONSUMER -- Remove the specified consumer.", "HELP -- Prints this help.", NULL };