diff --git a/input.c b/input.c index 1381e28a..452ebd24 100644 --- a/input.c +++ b/input.c @@ -309,7 +309,7 @@ static void inbuf_split (struct inbuf *inbuf, size_t dof, * * @returns 0 on eof/error, else 1 inbuf is valid. */ -int inbuf_read_to_delimeter (struct inbuf *inbuf, FILE *fp, +int inbuf_read_to_delimiter (struct inbuf *inbuf, FILE *fp, struct buf **outbuf) { int read_size = MIN(1024, inbuf->max_size); int fd = fileno(fp); diff --git a/input.h b/input.h index 470d9225..88763ffd 100644 --- a/input.h +++ b/input.h @@ -55,7 +55,7 @@ void buf_destroy (struct buf *buf); void inbuf_free_buf (void *buf, size_t size); void inbuf_init (struct inbuf *inbuf, size_t max_size, const char *delim, size_t delim_size); -int inbuf_read_to_delimeter (struct inbuf *inbuf, FILE *fp, +int inbuf_read_to_delimiter (struct inbuf *inbuf, FILE *fp, struct buf **outbuf); #endif diff --git a/kcat.1 b/kcat.1 index 694b7df8..4fc77a6c 100644 --- a/kcat.1 +++ b/kcat.1 @@ -50,7 +50,7 @@ In producer mode ( ), .Nm reads messages from stdin, delimited with a configurable -delimeter and produces them to the provided Kafka cluster, topic and +delimiter and produces them to the provided Kafka cluster, topic and partition. In consumer mode ( .Fl C ), diff --git a/kcat.c b/kcat.c index bfd6f8ff..e33014c9 100644 --- a/kcat.c +++ b/kcat.c @@ -422,7 +422,7 @@ static void producer_run (FILE *fp, char **paths, int pathcnt) { /* Read messages from input, delimited by conf.delim */ while (conf.run && - !(at_eof = !inbuf_read_to_delimeter(&inbuf, fp, &b))) { + !(at_eof = !inbuf_read_to_delimiter(&inbuf, fp, &b))) { int msgflags = 0; char *buf = b->buf; char *key = NULL; @@ -1392,7 +1392,7 @@ static void RD_NORETURN usage (const char *argv0, int exitcode, " -K Delimiter to split input key and message\n" " -k Use a fixed key for all messages.\n" " If combined with -K, per-message keys\n" - " takes precendence.\n" + " takes precedence.\n" " -H Add Message Headers " "(may be specified multiple times)\n" " -l Send messages from a file separated by\n" diff --git a/rpm/kcat.spec b/rpm/kcat.spec index 8e9ed065..a91558aa 100644 --- a/rpm/kcat.spec +++ b/rpm/kcat.spec @@ -16,7 +16,7 @@ kcat is a generic non-JVM producer and consumer for Apache Kafka >= 0.8, think of it as a netcat for Kafka. In producer mode kcat reads messages from stdin, delimited with a -configurable delimeter (-D, defaults to newline), and produces them to the +configurable delimiter (-D, defaults to newline), and produces them to the provided Kafka cluster (-b), topic (-t) and partition (-p). In consumer mode kcat reads messages from a topic and partition and prints