-
Notifications
You must be signed in to change notification settings - Fork 922
Open
Labels
bugReporting an unexpected or problematic behavior of the codebaseReporting an unexpected or problematic behavior of the codebasecode:pythonIssues that are specific to Python or versions of Python independent of library logicIssues that are specific to Python or versions of Python independent of library logicsize:smallMaintainer triage tag for indicating change required is particularly smallMaintainer triage tag for indicating change required is particularly smallstatus:help-wantedIssues that would especially appreciate external development or attentionIssues that would especially appreciate external development or attention
Description
c = Consumer({ 'bootstrap.servers': servers, 'group.id': groupid, 'auto.offset.reset': offsettype, # 'auto.offset.reset': 'latest', }) c.subscribe([topic])
When I created the consumer, I thought it would be obvious if there was no data because KAFKA was not connected
Checklist
Please provide the following information:
- confluent-kafka-python and librdkafka version (
confluent_kafka.version()
andconfluent_kafka.libversion()
): - Apache Kafka broker version:
- Client configuration:
{...}
- Operating system:
- Provide client logs (with
'debug': '..'
as necessary) - Provide broker log excerpts
- Critical issue
Metadata
Metadata
Assignees
Labels
bugReporting an unexpected or problematic behavior of the codebaseReporting an unexpected or problematic behavior of the codebasecode:pythonIssues that are specific to Python or versions of Python independent of library logicIssues that are specific to Python or versions of Python independent of library logicsize:smallMaintainer triage tag for indicating change required is particularly smallMaintainer triage tag for indicating change required is particularly smallstatus:help-wantedIssues that would especially appreciate external development or attentionIssues that would especially appreciate external development or attention