closing consumer multiple times should not raise RunTimeError (@mkmoisen , #678)

Author: mkmoisen

confluent_kafka/src/Consumer.c

@@ -977,11 +977,8 @@ static PyObject *Consumer_consume (Handle *self, PyObject *args,
 static PyObject *Consumer_close (Handle *self, PyObject *ignore) {
         CallState cs;
 
-        if (!self->rk) {
-                PyErr_SetString(PyExc_RuntimeError,
-                                "Consumer already closed");
-                return NULL;
-        }
+        if (!self->rk)
+                Py_RETURN_NONE;
 
         CallState_begin(self, &cs);
 
@@ -1296,7 +1293,6 @@ static PyMethodDef Consumer_methods[] = {
 	  "see :py:func::`poll()` for more info.\n"
 	  "\n"
 	  "  :rtype: None\n"
-      "  :raises: RuntimeError if called on a closed consumer\n"
 	  "\n"
 	},
         { "list_topics", (PyCFunction)list_topics, METH_VARARGS|METH_KEYWORDS,

tests/test_Consumer.py

@@ -209,8 +209,8 @@ def test_offsets_for_times():
     c.close()
 
 
-def test_multiple_close_throw_exception():
-    """ Calling Consumer.close() multiple times should throw Runtime Exception
+def test_multiple_close_does_not_throw_exception():
+    """ Calling Consumer.close() multiple times should not throw Runtime Exception
     """
     c = Consumer({'group.id': 'test',
                   'enable.auto.commit': True,
@@ -222,10 +222,7 @@ def test_multiple_close_throw_exception():
 
     c.unsubscribe()
     c.close()
-
-    with pytest.raises(RuntimeError) as ex:
-        c.close()
-    assert ex.match('Consumer already closed')
+    c.close()
 
 
 def test_any_method_after_close_throws_exception():