File tree Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -1425,13 +1425,14 @@ PyTypeObject ConsumerType = {
14251425 "\n"
14261426 ".. py:function:: Consumer(config)\n"
14271427 "\n"
1428- " :param dict config: Configuration properties. At a minimum ``group.id`` **must** be set,"
1429- " ``bootstrap.servers`` **should** be set"
1428+ " :param dict config: Configuration properties. "
1429+ "At a minimum ``group.id`` **must** be set,"
1430+ " ``bootstrap.servers`` **should** be set."
14301431 "\n"
14311432 "Create new Consumer instance using provided configuration dict.\n"
14321433 "\n"
14331434 " Special configuration properties:\n"
1434- " ``on_commit``: Optional callback will be called when a commit "
1435+ " ``on_commit``: Optional callback will be called when a commit "
14351436 "request has succeeded or failed.\n"
14361437 "\n"
14371438 "\n"
Original file line number Diff line number Diff line change @@ -114,7 +114,7 @@ https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
114114The Python bindings also provide some additional configuration properties:
115115
116116* ``default.topic.config ``: value is a dict of client topic-level configuration
117- properties that are applied to all used topics for the instance. **DEPRECATED: **
117+ properties that are applied to all used topics for the instance. **DEPRECATED: **
118118 topic configuration should now be specified in the global top-level configuration.
119119
120120* ``error_cb(kafka.KafkaError) ``: Callback for generic/global error events. This callback is served upon calling
You can’t perform that action at this time.
0 commit comments