Question

cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to create consumer: sasl.username and sasl.password must be set"}

score 23 · Answer 1 · 2024-03-22T22:12:02.580000

23

Views

cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to create consumer: sasl.username and sasl.password must be set"}

Published on 22 March 2024 at 22:12

score 48 · Answer 2 · 2024-03-12T08:56:39.130000

48

Views

org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 369295617 larger than 524288) when consumer is started

Published on 12 March 2024 at 08:56

score 36 · Answer 3 · 2024-03-11T10:32:47.827000

36

Views

Unable to connect to broker using TLS librdkafka

Published on 11 March 2024 at 10:32

score 47 · Answer 4 · 2024-02-28T18:04:52.250000

47

Views

OverflowError: Python int too large to convert to C int when using confluent_kafka Avro deserializer

Published on 28 February 2024 at 18:04

score 168 · Answer 5 · 2024-02-22T14:55:25.203000

168

Views

Kafka producer localhost:9092/1: Connect to ipv4#127.0.0.1:9092 failed: Connection refused

Published on 22 February 2024 at 14:55

score 82 · Answer 6 · 2024-02-14T21:20:40.983000

82

Views

Kafka consumer status says "no active members" although I see my consumers ingesting logs

Published on 14 February 2024 at 21:20

score 36 · Answer 7 · 2024-02-13T09:47:30.283000

36

Views

Does ordering matter when committing offsets using a message?

Published on 13 February 2024 at 09:47

score 54 · Answer 8 · 2024-02-11T20:44:31.343000

54

Views

confluent_kafka Python code to alter topic config

Published on 11 February 2024 at 20:44

score 40 · Answer 9 · 2024-02-06T15:48:06.777000

40

Views

Confluent Kafka Python Client and modifying replication factor and partitions for a topic that already exists?

Published on 06 February 2024 at 15:48

score 30 · Answer 10 · 2024-02-04T13:13:08.183000

30

Views

Why confuent-kafka consumer is preventing my Python script to intercept KeyboardInterrupt

Published on 04 February 2024 at 13:13

score 49 · Answer 11 · 2024-01-18T05:16:19.517000

49

Views

Exception handling and Retry failure messages with same offset from Kafka using Python

Published on 18 January 2024 at 05:16

score 40 · Answer 12 · 2024-01-12T10:13:45.527000

40

Views

Confluent Python Kafka - TSL configuration not working

Published on 12 January 2024 at 10:13

score 141 · Answer 13 · 2024-01-11T14:05:07.663000

141

Views

Confluent Kafka Python Library blocking asyncio consumer poll

Published on 11 January 2024 at 14:05

score 49 · Answer 14 · 2024-01-10T07:58:00.547000

49

Views

Confluent Kafka connection from Databricks

Published on 10 January 2024 at 07:58

score 176 · Answer 15 · 2023-12-23T01:43:22.743000

176

Views

confluent-kafka in AWS Python Lambda. Unable to import module 'main': No module named 'confluent_kafka.cimpl

Published on 23 December 2023 at 01:43

score 49 · Answer 16 · 2023-12-20T14:06:44.783000

49

Views

Confluent Kafka AdminClient create_topics method returns KafkaException error but still creates topics

Published on 20 December 2023 at 14:06

score 82 · Answer 17 · 2023-12-19T23:43:34.097000

82

Views

Why does rebalancing stop the world?

Published on 19 December 2023 at 23:43

score 78 · Answer 18 · 2023-12-12T20:03:22.397000

78

Views

Deserializtion/Parsing error KafkaProtobuf Python

Published on 12 December 2023 at 20:03

score 93 · Answer 19 · 2023-12-06T16:37:34.960000

93

Views

twisted integrating blocking confluent-kafka pythong library issues

Published on 06 December 2023 at 16:37

score 140 · Answer 20 · 2023-12-04T03:35:21.993000

140

Views

InvalidInputException - Unable to resolve valid connection Service:AWSGlueJobExecutor)

Published on 04 December 2023 at 03:35

List Question

cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to create consumer: sasl.username and sasl.password must be set"}

org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 369295617 larger than 524288) when consumer is started

Unable to connect to broker using TLS librdkafka

OverflowError: Python int too large to convert to C int when using confluent_kafka Avro deserializer

Kafka producer localhost:9092/1: Connect to ipv4#127.0.0.1:9092 failed: Connection refused

Kafka consumer status says "no active members" although I see my consumers ingesting logs

Does ordering matter when committing offsets using a message?

confluent_kafka Python code to alter topic config

Confluent Kafka Python Client and modifying replication factor and partitions for a topic that already exists?

Why confuent-kafka consumer is preventing my Python script to intercept KeyboardInterrupt

Exception handling and Retry failure messages with same offset from Kafka using Python

Confluent Python Kafka - TSL configuration not working

Confluent Kafka Python Library blocking asyncio consumer poll

Confluent Kafka connection from Databricks

confluent-kafka in AWS Python Lambda. Unable to import module 'main': No module named 'confluent_kafka.cimpl

Confluent Kafka AdminClient create_topics method returns KafkaException error but still creates topics

Why does rebalancing stop the world?

Deserializtion/Parsing error KafkaProtobuf Python

twisted integrating blocking confluent-kafka pythong library issues

InvalidInputException - Unable to resolve valid connection Service:AWSGlueJobExecutor)

Trending Questions

Popular # Hahtags

Popular Questions