kafka-python

0열

1답변

Confluent Kafka : 소비자가 주제의 모든 파티션을 처음부터 읽지 않습니다.

40 개의 파티션이있는 주제가 있습니다. 설정은 다음과 같습니다. def on_assign (c,ps): for p in ps: p.offset=0 print ps c.assign(ps) conf = {'bootstrap.servers': 'localhost:9092' 'enable.auto.commit' : False,

apache-kafka kafka-consumer-api confluent-kafka kafka-python 2017-12-06

---

0열

2답변

Python에서 동일한 그룹 ID를 가진 여러 소비자

파이썬에서 동일한 그룹 ID를 사용하여 여러 소비자를 실행하는 방법을 아는 사람이 있습니까? 내가 a = Consumer({'bootstrap.servers': 'localhost:9092', 'group.id': 'dd1', 'default.topic.config': {'auto.offset.reset': 'smallest'}}) b =

python apache-kafka kafka-python 2017-10-21

---

0열

1답변

수입 카프카 오류, 카프카 - 파이썬

ENV : CentOS는, python2.7.9 카프카 - 파이썬 == 0.9.3 여섯 == 1.9.0 나는 카프카에 새가, 난 그냥 예제 프로그램을 시도하고 오전 오류가 발생했습니다. 어떤 도움을 주시면 감사하겠습니다. 코드는 "카프카의 수입 KafkaClient, KeyedProducer에서 RoundRobinPartitioner을"에 Traceback

python apache-kafka kafka-python 2017-10-25

---

2열

1답변

파이썬 다중 처리를 사용하여 데이터가 Kafka 대기열에 푸시되지 않음

파이썬 (2.7) 다중 처리를 사용하여 kafka-python (1.3.5) KafkaProducer를 사용하여 데이터를 Kafka 대기열로 푸시합니다. from kafka import KafkaProducer import multiprocessing # other imports class TestClass(object): def __in

python multithreading apache-kafka multiprocessing kafka-python 2017-11-08

---

1열

1답변

자동 커밋을 할 수있는 동안 수동으로 파티션을 할당하는 방법은 무엇입니까?

소비자 그룹 내의 각 소비자에게 파티션을 수동으로 할당하려고합니다. 그룹에 소비자를 추가하는 것처럼 보이지만 Kafka (또는 적어도 kafka-python)는 그룹 코디네이터가 모든 과제를 수행하기를 원한다고 가정합니다. 파티션 할당을 수동으로 관리 할 수있는 동안 소비자 그룹 (특히 자동 커밋) 사용의 모든 이점을 계속 유지할 수있는 방법이 있습니까?

apache-kafka kafka-consumer-api kafka-python 2017-09-20

---

0열

1답변

단순한 카프카 프로듀싱 문제 해결

저는 개발을 시작하기 위해 Mac Pro (Sierra; 10.12.6)에서 카프카를 로컬로 실행하고 있습니다. 사육사와 카프카 서버 (0.11.0.1) 내가 시작했습니다 : bin/zookeeper-server-start.sh config/zookeeper.properties bin/kafka-server-start.sh config/server.pro

python apache-kafka kafka-python 2017-09-22

---

1열

1답변

kafka-python kafka.KafkaProducer # send()에 대한 실패 콜백을 추가하는 방법?

생성 된 레코드가 실패 할 경우 콜백을 설정하고 싶습니다. 처음에는 실패한 레코드를 기록하고 싶습니다. 합류 카프카 파이썬 라이브러리는 콜백 추가하기위한 메커니즘을 제공 : produce(topic[, value][, key][, partition][, on_delivery][, timestamp]) ... on_delivery(err,msg)

kafka-python 2017-09-24

---

0열

2답변

파이썬 KafkaConsumer가 타임 스탬프에서 메시지를 소비하기 시작합니다.

주제의 시작을 건너 뛰고 특정 타임 스탬프의 메시지 만 끝까지 읽으려고합니다. 이것을 달성하는 방법에 대한 힌트가 있습니까?

python-3.x apache-kafka kafka-consumer-api kafka-python 2017-09-25

---

0열

1답변

카프카 파티션 지연 증가

카프카 1.0을 대기열로 사용하는 응용 프로그램이 있습니다. Kafka 주제에는 80 개의 파티션과 80 개의 소비자가 실행 중입니다. (카프카 - 파이썬 소비자). 명령을 실행하여 : 제가 파티션 중 하나가 오프셋에서 중단하고, 새로운 레코드가 추가 될 때 지연을 연속적으로 증가되는 것을 볼 ./bin/kafka-consumer-groups.sh --bo

python apache-kafka kafka-consumer-api kafka-python 2017-11-15

---

0열

1답변

Python-Kafka : 스크립트 모드가 아닌 대화 형 모드로 실행되는 프로그램

Machine_1의 python 스크립트를 통해 Machine_2의 카프카 주제에 일부 메시지를 보내려고합니다. Machine_2과 Machine_1은 모두 동일한 네트워크에 있으며 둘 다 Azure의 VM입니다. 코드 : 나는 파이썬 sampl.py 로 위의 코드를 실행하면 sampl.py from kafka import KafkaProducer Pro

python apache-kafka kafka-python 2017-10-13

---