Skip to content

Commit

Permalink
Use only logger in signature
Browse files Browse the repository at this point in the history
  • Loading branch information
kumaranvpl committed May 24, 2024
1 parent 36c1469 commit 17d2303
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions faststream/confluent/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
from ssl import SSLContext
from time import time
from typing import (
TYPE_CHECKING,
Any,
Callable,
Dict,
Expand All @@ -22,9 +21,6 @@
from faststream.log import logger
from faststream.utils.functions import call_or_await

if TYPE_CHECKING:
from faststream.types import LoggerProto

_missing = object()


Expand Down Expand Up @@ -110,7 +106,7 @@ def __init__(
sasl_kerberos_service_name: str = "kafka",
sasl_kerberos_domain_name: Optional[str] = None,
sasl_oauth_token_provider: Optional[str] = None,
logger: Optional[Union["LoggerProto", logging.Logger]] = logger,
logger: Optional[logging.Logger] = logger,
) -> None:
self.logger = logger
if isinstance(bootstrap_servers, Iterable) and not isinstance(
Expand Down Expand Up @@ -302,7 +298,7 @@ def __init__(
sasl_kerberos_service_name: str = "kafka",
sasl_kerberos_domain_name: Optional[str] = None,
sasl_oauth_token_provider: Optional[str] = None,
logger: Optional[Union["LoggerProto", logging.Logger]] = logger,
logger: Optional[logging.Logger] = logger,
) -> None:
self.logger = logger
if group_id is None:
Expand Down

0 comments on commit 17d2303

Please sign in to comment.