diff --git a/faust/transport/drivers/confluent.py b/faust/transport/drivers/confluent.py index 2573a1545..19b4dd708 100644 --- a/faust/transport/drivers/confluent.py +++ b/faust/transport/drivers/confluent.py @@ -208,8 +208,6 @@ class ConfluentConsumerThread(ConsumerThread): _consumer: Optional[AsyncConsumer] = None _assigned: bool = False - # _pending_rebalancing_spans: Deque[opentracing.Span] - tp_last_committed_at: MutableMapping[TP, float] time_started: float