StackOverflow Questions for Tag: pykafka

Surya S

Reputation: 1

How to handle fast Kafka offset consumption vs. slow join and sink in PyFlink with savepoints?

apache-flinkflink-streamingpyflinkcheckpointpykafka

Score: 0

Answers: 0

new

Reputation: 37

Can I have multiple consumer reading from same Kafka Topic in parallel?

apache-kafkapykafka

Score: 2

Answers: 3

GecKo

Reputation: 173

Unable to connect kafka in kubernetes cluster from python-producer

kubernetesapache-kafkapykafka

Score: 0

Answers: 1

fneron

Reputation: 1097

building MQTT and Kafka bridge getting pykafka exceptions

pythonapache-kafkamqttpykafka

Score: 0

Answers: 0

newUser

Reputation: 404

pykafka consumes same messages

pythonapache-kafkakafka-consumer-apipykafka

Score: -1

Answers: 1

Doraemon

Reputation: 339

Kafka producer always sends messages to the same partition (Kafka + Python)

pythonapache-kafkapykafka

Score: 1

Answers: 1

Doraemon

Reputation: 339

How to automatically generate partition keys for messages (Kafka + Python)?

pythonapache-kafkapykafka

Score: 0

Answers: 1

Enzy

Reputation: 185

Kafka Consumers on different partitions under same group are still consuming same messages intermittently

pythonapache-kafkakafka-consumer-apipykafka

Score: 0

Answers: 1

user3463832

Reputation: 15

Pytest a KAFKA consumer and producer (integration test)

python-3.xdocker-composeintegration-testingpytestpykafka

Score: 0

Answers: 1

Nick

Reputation: 189

I have an issue posting JSON message on Kafka using PyKafka

jsonpykafka

Score: 0

Answers: 1

Dan M

Reputation: 1272

confluent-kafka-python library: read offset per topic per consumer_group

pykafkaconfluent-kafka-python

Score: 1

Answers: 1

Naggappan Ramukannan

Reputation: 2822

Getting import _rd_kafka error in all docker images while trying to connect to kafka via pykafka

python-3.xpykafkastrimzi

Score: 0

Answers: 1

a.r. noureldin

Reputation: 63

Kafka reading txt file as single letters rather than words

pythonapache-kafkapykafka

Score: 0

Answers: 1

Max0u

Reputation: 720

High latency PyKafka

pythonapache-kafkapykafka

Score: 4

Answers: 0

e7lT2P

Reputation: 1931

Write a csv file to a kafka topic

pythonapache-kafkakafka-producer-apikafka-pythonpykafka

Score: 4

Answers: 1

bihire boris

Reputation: 1682

How to dynamically create kafka producers

python-3.xapache-kafkakafka-producer-apipykafka

Score: 2

Answers: 0

Hoa The Nguyen

Reputation: 103

pykafka deadlock on nosetests' integration tests

python-3.6deadlocknosepykafka

Score: 1

Answers: 0

Thomas Cigolla

Reputation: 1

Now Feedback if the connection works

pythonapache-kafkapykafka

Score: 0

Answers: 0

Coder

Reputation: 29

Cant send message by using pykafka

apache-kafkakafka-producer-apipykafka

Score: 1

Answers: 1

Yong

Reputation: 1

Producer can not connect to broker through DNS

apache-kafkakafka-producer-apikafka-pythonapache-kafka-connectpykafka

Score: 0

Answers: 0

PreviousPage 1Next

StackOverflow Questions for Tag: pykafka

How to handle fast Kafka offset consumption vs. slow join and sink in PyFlink with savepoints?

Can I have multiple consumer reading from same Kafka Topic in parallel?

Unable to connect kafka in kubernetes cluster from python-producer

building MQTT and Kafka bridge getting pykafka exceptions

pykafka consumes same messages

Kafka producer always sends messages to the same partition (Kafka + Python)

How to automatically generate partition keys for messages (Kafka + Python)?

Kafka Consumers on different partitions under same group are still consuming same messages intermittently

Pytest a KAFKA consumer and producer (integration test)

I have an issue posting JSON message on Kafka using PyKafka

confluent-kafka-python library: read offset per topic per consumer_group

Getting import _rd_kafka error in all docker images while trying to connect to kafka via pykafka

Kafka reading txt file as single letters rather than words

High latency PyKafka

Write a csv file to a kafka topic

How to dynamically create kafka producers

pykafka deadlock on nosetests&#39; integration tests

Now Feedback if the connection works

Cant send message by using pykafka

Producer can not connect to broker through DNS

pykafka deadlock on nosetests' integration tests