While creating the KafkaAdminClient
client = KafkaAdminClient(bootstrap_servers=bootstrap_servers,
security_protocol=security_protocol,
sasl_mechanism=SASL_MECHANISM,
sasl_plain_username=username,
sasl_plain_password=password,
)
there are a lot of debug
and info
logs that are generated like:
kafka.client [DEBUG]- [client_async.py:279 - _conn_state_change()] - Node bootstrap-0 connected
kafka.protocol.parser [DEBUG]- [parser.py:59 - send_request()] - Sending request MetadataRequest_v0(topics=[])
Is there a config that would allow switching off DEBUG
and INFO
logs and only show WARN or ERROR
logs?
It uses the standard logging
library and the client side handler is named kafka
:
import logging
logger = logging.getLogger('kafka')
logger.setLevel(logging.WARN)
That should configure the kafka-python
library log level.