TechQA.

Question

Kafka topic partitions are paused for downstream consumer due to backpressure. Only one of the partitions got drained eventually

score 55 · Answer 1 · 2024-03-05T22:06:30.670000

0

Answer

55

Views

Kafka topic partitions are paused for downstream consumer due to backpressure. Only one of the partitions got drained eventually

55 views Asked by candicetdh At 05 March 2024 at 22:06

score 92 · Answer 2 · 2024-02-03T12:19:23.323000

Reactor Kafka Application Stops Unexpectedly Without Errors During High-Volume Consumption

92 views Asked by user7551211 At 03 February 2024 at 12:19

score 68 · Answer 3 · 2024-01-24T04:25:24.227000

issue with functionCatalog.lookup("sendFluxToWeb|sendFluxToKafka")

68 views Asked by PatPanda At 24 January 2024 at 04:25

score 85 · Answer 4 · 2023-12-19T23:01:51.103000

Pattern to change Kafka producer type per configuration

85 views Asked by PatPanda At 19 December 2023 at 23:01

score 106 · Answer 5 · 2023-12-11T14:26:00.590000

Kafka consumer is getting automatically resumed after a manual pause is invoked

106 views Asked by Manisha At 11 December 2023 at 14:26

score 145 · Answer 6 · 2023-11-28T15:23:48.700000

Intermittent "Node X disconnected" issue for Kafka despite batch.size , linger.ms change

145 views Asked by PatPanda At 28 November 2023 at 15:23

score 95 · Answer 7 · 2023-11-09T17:51:08.717000

Reactor Kafka is causing the interruption of consumer messages from random partitions

95 views Asked by Surajit Chongder At 09 November 2023 at 17:51

score 74 · Answer 8 · 2023-10-31T15:51:25.097000

Reactive Kafka Consumer Back Pressure - Configure the value at which back pressure is applied

74 views Asked by Michael McFadyen At 31 October 2023 at 15:51

score 73 · Answer 9 · 2023-10-28T17:46:44.380000

Reactor Kafka with spring-boot 3 not closing a inner flux on flatMap

73 views Asked by Tim At 28 October 2023 at 17:46

score 127 · Answer 10 · 2023-10-26T14:53:08.857000

How to move to the next offset when RecordDeserializationException occurs reactor-kafka receiver?

127 views Asked by Mikhail Geyer At 26 October 2023 at 14:53

score 84 · Answer 11 · 2023-10-24T14:07:18.890000

Limit number of concurrently processed messages with the Spring Cloud Stream Kafka Reactive binder

84 views Asked by kschlesselmann At 24 October 2023 at 14:07

score 217 · Answer 12 · 2023-09-23T10:22:37.477000

How to get a list of messages with reactor-kafka receiver?

217 views Asked by Mikhail Geyer At 23 September 2023 at 10:22

score 58 · Answer 13 · 2023-09-21T08:28:44.403000

Start Reactive Receiver after Spring Boot main method or after some event

58 views Asked by Viktor Loskutov At 21 September 2023 at 08:28

score 39 · Answer 14 · 2023-09-07T08:31:00.233000

Reactor Kafka "Can't signal value due to lack of requests" when using sample() - "Concurrent Processing with Partition-Based Ordering"

39 views Asked by gira1 At 07 September 2023 at 08:31

score 68 · Answer 15 · 2023-08-25T06:42:42.140000

Are there any underlying effects of not using reactive kafka consumer in spring webflux?

68 views Asked by Nakash Kumar At 25 August 2023 at 06:42

score 64 · Answer 16 · 2023-08-14T10:29:34.560000

How to cancel Webflux Kafka subscription (and skip acknowledge) when client disconnect?

64 views Asked by doragon At 14 August 2023 at 10:29

score 165 · Answer 17 · 2023-08-08T17:06:17.413000

Unable to use schemaRegistry in reactor kafka

165 views Asked by Gajukorse At 08 August 2023 at 17:06

score 82 · Answer 18 · 2023-07-25T17:15:47.100000

How to do nothing when consuming invalid json using reactor kafka?

82 views Asked by PatPanda At 25 July 2023 at 17:15

score 319 · Answer 19 · 2023-06-22T08:33:03.447000

Reactor Kafka is receiving the message but printing value as "null"

319 views Asked by user1354825 At 22 June 2023 at 08:33

score 62 · Answer 20 · 2023-06-02T11:03:07.310000

onErrorContinue not handling onErrorDropped error in Reactive Streams

62 views Asked by Techie97 At 02 June 2023 at 11:03

TechQA.

List Question

Kafka topic partitions are paused for downstream consumer due to backpressure. Only one of the partitions got drained eventually

Reactor Kafka Application Stops Unexpectedly Without Errors During High-Volume Consumption

issue with functionCatalog.lookup("sendFluxToWeb|sendFluxToKafka")

Pattern to change Kafka producer type per configuration

Kafka consumer is getting automatically resumed after a manual pause is invoked

Intermittent "Node X disconnected" issue for Kafka despite batch.size , linger.ms change

Reactor Kafka is causing the interruption of consumer messages from random partitions

Reactive Kafka Consumer Back Pressure - Configure the value at which back pressure is applied

Reactor Kafka with spring-boot 3 not closing a inner flux on flatMap

How to move to the next offset when RecordDeserializationException occurs reactor-kafka receiver?

Limit number of concurrently processed messages with the Spring Cloud Stream Kafka Reactive binder

How to get a list of messages with reactor-kafka receiver?

Start Reactive Receiver after Spring Boot main method or after some event

Reactor Kafka "Can't signal value due to lack of requests" when using sample() - "Concurrent Processing with Partition-Based Ordering"

Are there any underlying effects of not using reactive kafka consumer in spring webflux?

How to cancel Webflux Kafka subscription (and skip acknowledge) when client disconnect?

Unable to use schemaRegistry in reactor kafka

How to do nothing when consuming invalid json using reactor kafka?

Reactor Kafka is receiving the message but printing value as "null"

onErrorContinue not handling onErrorDropped error in Reactive Streams

Popular Questions

Trending Questions