diff --git a/confluent_kafka/src/Consumer.c b/confluent_kafka/src/Consumer.c index 9d08a4152..e71c674b7 100644 --- a/confluent_kafka/src/Consumer.c +++ b/confluent_kafka/src/Consumer.c @@ -193,7 +193,7 @@ static PyObject *Consumer_assign (Handle *self, PyObject *tlist) { if (err) { cfl_PyErr_Format(err, - "Failed to set assignemnt: %s", + "Failed to set assignment: %s", rd_kafka_err2str(err)); return NULL; } diff --git a/confluent_kafka/src/Producer.c b/confluent_kafka/src/Producer.c index ec61197e8..e05a6af87 100644 --- a/confluent_kafka/src/Producer.c +++ b/confluent_kafka/src/Producer.c @@ -371,7 +371,7 @@ static PyMethodDef Producer_methods[] = { " This is an asynchronous operation, an application may use the " "``callback`` (alias ``on_delivery``) argument to pass a function " "(or lambda) that will be called from :py:func:`poll()` when the " - "message has been succesfully delivered or permanently fails delivery.\n" + "message has been successfully delivered or permanently fails delivery.\n" "\n" " :param str topic: Topic to produce message to\n" " :param str|bytes value: Message payload\n" @@ -379,7 +379,7 @@ static PyMethodDef Producer_methods[] = { " :param int partition: Partition to produce to, elses uses the " "configured partitioner.\n" " :param func on_delivery(err,msg): Delivery report callback to call " - "(from :py:func:`poll()` or :py:func:`flush()`) on succesful or " + "(from :py:func:`poll()` or :py:func:`flush()`) on successful or " "failed delivery\n" "\n" " :rtype: None\n"