Skip to content

Commit

Permalink
Fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
yzhan289 committed Feb 24, 2023
1 parent 4af8da1 commit ae37183
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,9 @@ class GenericKafkaClient(KafkaClient):
def __init__(self, config, tls_context, log) -> None:
super().__init__(config, tls_context, log)
self.use_legacy_client = config.use_legacy_client
self.confluent_kafka_client = ConfluentKafkaClient(config, tls_context, log) if not self.use_legacy_client else None
self.confluent_kafka_client = (
ConfluentKafkaClient(config, tls_context, log) if not self.use_legacy_client else None
)
self.python_kafka_client = KafkaPythonClient(config, tls_context, log)

def get_consumer_offsets(self):
Expand Down

0 comments on commit ae37183

Please sign in to comment.