Question

Aiokafka consumer process events in parallel

score 524 · Answer 1 · 2023-01-24 21:14:53

524

Views

Aiokafka consumer process events in parallel

Published on 24 January 2023 at 21:14

score 5.3k · Answer 2 · 2022-06-05 14:58:56

5.3k

Views

Connect Python to MSK with IAM role-based authentication

Published on 05 June 2022 at 14:58

score 358 · Answer 3 · 2021-12-06 12:03:24

358

Views

aiokafka producer running on one core in a python:buster Docker container achieves very low throughput 1 MiB per second

Published on 06 December 2021 at 12:03

score 501 · Answer 4 · 2023-03-03 17:33:29

501

Views

python aiokafka many consumers to many producers

Published on 03 March 2023 at 17:33

score 881 · Answer 5 · 2021-08-05 05:04:30

881

Views

Which Partition to use when Performing a Offset Seek using AIOKafkaConsumer?

Published on 05 August 2021 at 05:04

score 177 · Answer 6 · 2023-05-02 21:15:43

177

Views

aiokafka exits when running in a multiprocessing class

Published on 02 May 2023 at 21:15

score 174 · Answer 7 · 2023-05-09 11:55:06

174

Views

unable to consume asynchronous msg from producer & consumer

Published on 09 May 2023 at 11:55

score 62 · Answer 8 · 2023-05-27 05:59:16

62

Views

Python aiokafka - how to set max retry limit per message?

Published on 27 May 2023 at 05:59

score 63 · Answer 9 · 2024-01-12 23:37:14

63

Views

communication of microservices through kafka

Published on 12 January 2024 at 23:37

score 98 · Answer 10 · 2024-01-11 14:05:07

98

Views

Confluent Kafka Python Library blocking asyncio consumer poll

Published on 11 January 2024 at 14:05

score 56 · Answer 11 · 2024-01-27 00:25:25

56

Views

How to support snappy compression after aiokafka 0.9.0?

Published on 27 January 2024 at 00:25

score 24 · Answer 12 · 2024-03-12 08:56:39

24

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 623 · Answer 13 · 2022-10-11 08:09:32

623

Views

python fastapi, aiokafka starvation problem

Published on 11 October 2022 at 08:09

score 438 · Answer 14 · 2022-08-24 12:00:47

438

Views

Aiokafka connecting fails silently

Published on 24 August 2022 at 12:00

score 541 · Answer 15 · 2023-04-03 08:04:01

541

Views

Error "Auto offset commit failed: [Error 25] UnknownMemberIdError:" after days of use

Published on 03 April 2023 at 08:04

score 157 · Answer 16 · 2023-04-17 02:37:36

157

Views

Kafka consumer records - processing

Published on 17 April 2023 at 02:37

List Question

Aiokafka consumer process events in parallel

Connect Python to MSK with IAM role-based authentication

aiokafka producer running on one core in a python:buster Docker container achieves very low throughput 1 MiB per second

python aiokafka many consumers to many producers

Which Partition to use when Performing a Offset Seek using AIOKafkaConsumer?

aiokafka exits when running in a multiprocessing class

unable to consume asynchronous msg from producer & consumer

Python aiokafka - how to set max retry limit per message?

communication of microservices through kafka

Confluent Kafka Python Library blocking asyncio consumer poll

How to support snappy compression after aiokafka 0.9.0?

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

python fastapi, aiokafka starvation problem

Aiokafka connecting fails silently

Error "Auto offset commit failed: [Error 25] UnknownMemberIdError:" after days of use

Kafka consumer records - processing

Trending Questions

Popular # Hahtags

Popular Questions