issues Search Results · repo:Parsely/pykafka language:Python
Filter by
553 results
(63 ms)553 results
inParsely/pykafka (press backspace or delete to remove)we have a kafka cluster with 5 nodes, and producer gen through method get_producer , when we restart one node, the
producer got error message bellow:
- pykafka.OwnedBroker.queue_reader for broker 4] ...
zuiwanting
- Opened on Mar 23, 2021
- #1035
I am trying to connect to kafka 2.3.1 servers from a test pod with container python:3
My code {code} from pykafka import KafkaClient, SslConfig import pytest import datetime import time import unittest ...
mailtoshrb
- 1
- Opened on Mar 3, 2021
- #1034
I m use the get_balanced_consumer, and start 50 threading,the lag is too high image image
auqf
- Opened on Feb 26, 2021
- #1033
HI i tried with multiple docker images like Ubuntu and python:3.8-alpine etc.. and everywhere I am getting an error as
below while trying to connect to my kafka cluster (2.7) via pykafka library.
kafka ...
naggappan
- Opened on Feb 9, 2021
- #1032
when i boot my django project,the console will print as follow errors:
Exception AttributeError: NoneType object has no attribute info in bound method Producer.__del__ of pykafka.producer.Producer ...
ittqqzz
- Opened on Dec 16, 2020
- #1024
here is my code
def process_buff(buff, direction): completed_buff = parser.parse(buff) if completed_buff: if G.dumper:
G.dumper.dump(completed_buff, direction) else: logger.debug( buff is not an completed ...
littleningmeng
- Opened on Dec 11, 2020
- #1022
Saw this issue that really helped me address the same error I had with Producer.produce not taking strings:
https://github.com/Parsely/pykafka/issues/759
Please fix the READMME to reflect this. Thanks. ...
gravityshouldbenaut
- Opened on Dec 11, 2020
- #1021
Dependabot couldn t authenticate with https://pypi.org/simple/.
Dependabot tried to authenticate with the details you previously provided, but authentication failed. If they are no
longer valid you will ...
dependabot-preview[bot]
- Opened on Sep 25, 2020
- #1015
/kind question
sorry, i can t be copied log with text. An error occurs when starting occasionally image consumer stopped, so
self.consumer is None image I ve added hosts for kafka broker, error still ...
liown
- Opened on Sep 23, 2020
- #1014
PyKafka version: 2.8.0
I m not sure I m doing this correctly, but based on what I have read in docs and source code, to produce messages into a
specific partition while having many consumers (so only ...
Shadowsong27
- Opened on Jul 3, 2020
- #1009
Learn how you can use GitHub Issues to plan and track your work.
Save views for sprints, backlogs, teams, or releases. Rank, sort, and filter issues to suit the occasion. The possibilities are endless.Learn more about GitHub IssuesProTip!
Restrict your search to the title by using the in:title qualifier.Learn how you can use GitHub Issues to plan and track your work.
Save views for sprints, backlogs, teams, or releases. Rank, sort, and filter issues to suit the occasion. The possibilities are endless.Learn more about GitHub IssuesProTip!
Press the /
key to activate the search input again and adjust your query.