-
Notifications
You must be signed in to change notification settings - Fork 934
Closed
Description
Description
The returned Kafka messages value method expects an argument payload
that makes the ide mark the calling of the method as problematic. It's not a real issue but
I wonder where it stems from.
for instance
msg = consumer.poll()
process_msg_value(msg.value())
will give a warning in pycharm as if I am missing an input on the value method.
The method I find is the following
def value(self, payload): # real signature unknown; restored from __doc__
"""
:returns: message value (payload) or None if not available.
:rtype: str|bytes or None
"""
pass
How to reproduce
On pycharm (my version 2017.1) call msg.value()
Checklist
Please provide the following information:
- confluent-kafka-python and librdkafka version (
confluent_kafka.version()
andconfluent_kafka.libversion()
): 0.9.2 - Apache Kafka broker version:
- Client configuration:
{...}
- Operating system: MacOS
- Provide client logs (with
'debug': '..'
as necessary) - Provide broker log excerpts
- Critical issue
Metadata
Metadata
Assignees
Labels
No labels