Style fix

Author: k-raina

src/confluent_kafka/__init__.py

@@ -37,9 +37,9 @@
     TIMESTAMP_LOG_APPEND_TIME,
     TIMESTAMP_NOT_AVAILABLE,
     Consumer,
-    ShareConsumer,
     Message,
     Producer,
+    ShareConsumer,
     TopicPartition,
     Uuid,
     consistent,
@@ -57,7 +57,6 @@
     "Consumer",
     "ShareConsumer",
     "aio",
-
     "KafkaError",
     "KafkaException",
     "kafkatest",

src/confluent_kafka/src/ShareConsumer.c

@@ -165,7 +165,7 @@ static PyObject *ShareConsumer_unsubscribe(ShareConsumerHandle *self,
  * @brief Get current topic subscription.
  */
 static PyObject *ShareConsumer_subscription(ShareConsumerHandle *self,
-                                             PyObject *ignore) {
+                                            PyObject *ignore) {
         rd_kafka_topic_partition_list_t *c_topics;
         rd_kafka_resp_err_t err;
         PyObject *topics;
@@ -486,8 +486,9 @@ ShareConsumer_init(PyObject *selfobj, PyObject *args, PyObject *kwargs) {
          * rd_kafka_share_set_log_queue() wrapper — needs rd_kafka_t *, which
          * is opaque inside rd_kafka_share_t in the public API. */
 
-        /* TODO KIP-932: call rd_kafka_sasl_background_callbacks_enable() for OAuth once
-         * librdkafka adds a share-level wrapper for the same reason. */
+        /* TODO KIP-932: call rd_kafka_sasl_background_callbacks_enable() for
+         * OAuth once librdkafka adds a share-level wrapper for the same reason.
+         */
 
 
         return 0;