Question

how can we control polling messages from kafka queue using akka kafka connector

score 56 · Answer 1 · 2024-02-05T06:05:08.820000

56

Views

how can we control polling messages from kafka queue using akka kafka connector

Published on 05 February 2024 at 06:05

score 120 · Answer 2 · 2023-12-08T23:02:26.333000

120

Views

Resetting offset for partition after (Re-)joining group

Published on 08 December 2023 at 23:02

score 52 · Answer 3 · 2023-09-25T15:29:55.150000

52

Views

How to capture alpakka kafka source stream failure after max RestartSource

Published on 25 September 2023 at 15:29

score 61 · Answer 4 · 2023-08-03T20:56:10.450000

61

Views

How to group messages so that they go to the same partition every time?

Published on 03 August 2023 at 20:56

score 2.3k · Answer 5 · 2022-01-30T13:05:59.253000

2.3k

Views

Why does auto-commit enabled Kafka client commit latest produced message's offset during consumer close even if the message was not consumed yet?

Published on 30 January 2022 at 13:05

score 930 · Answer 6 · 2021-10-28T08:24:11.570000

930

Views

Akka Kafka Consumer processing rate decreases drastically when lag is there in our Kafka Partitions

Published on 28 October 2021 at 08:24

score 365 · Answer 7 · 2021-09-22T21:12:15.863000

365

Views

Fast Processing Topic and Slow Processing Topic - Akka Kafka

Published on 22 September 2021 at 21:12

score 494 · Answer 8 · 2020-12-03T15:26:55.340000

494

Views

Is this Akka Kafka Stream configuration benefits from Back Pressure mechanism of the Akka Streams?

Published on 03 December 2020 at 15:26

score 150 · Answer 9 · 2020-07-09T02:56:21.810000

150

Views

Lagom topic subscriber - how to retry in Future Exception?

Published on 09 July 2020 at 02:56

score 865 · Answer 10 · 2020-05-06T04:45:37.427000

865

Views

Akka streams Kafka consumer process parallel

Published on 06 May 2020 at 04:45

score 164 · Answer 11 · 2019-11-03T12:06:16.173000

164

Views

How Akka stream internal and explicit buffer interact with the underlying kafka client settings in alpakka Kafka?

Published on 03 November 2019 at 12:06

score 92 · Answer 12 · 2019-06-05T12:29:31.793000

92

Views

Is there functionality in the akka-Kafka (scala framework) to list all available topics

Published on 05 June 2019 at 12:29

score 543 · Answer 13 · 2018-08-01T15:03:55.683000

543

Views

avro4s can not deserialize AnyRef

Published on 01 August 2018 at 15:03

score 1k · Answer 14 · 2018-07-09T09:02:51.160000

1k

Views

Troubles with AVRO schema update

Published on 09 July 2018 at 09:02

score 693 · Answer 15 · 2018-06-10T09:33:30.613000

693

Views

Incompatible equality constraint while using Akka Kafka Streams

Published on 10 June 2018 at 09:33

score 511 · Answer 16 · 2018-04-12T10:28:02.403000

511

Views

Getting last message from kafka Topic using akka-stream-kafka when connecting with websocket

Published on 12 April 2018 at 10:28

score 1.1k · Answer 17 · 2018-03-13T18:05:17.503000

1.1k

Views

Akka streams kafka commit offset after filter

Published on 13 March 2018 at 18:05

score 217 · Answer 18 · 2018-03-12T10:28:43.470000

217

Views

How to sessionize / group the events in Akka Streams?

Published on 12 March 2018 at 10:28

score 560 · Answer 19 · 2018-02-15T22:16:09.350000

560

Views

Using reactive-kafka to conditionally process messages

Published on 15 February 2018 at 22:16

score 630 · Answer 20 · 2017-10-06T06:28:14.837000

630

Views

Akka Kafka stream supervison strategy not working

Published on 06 October 2017 at 06:28

List Question

how can we control polling messages from kafka queue using akka kafka connector

Resetting offset for partition after (Re-)joining group

How to capture alpakka kafka source stream failure after max RestartSource

How to group messages so that they go to the same partition every time?

Why does auto-commit enabled Kafka client commit latest produced message's offset during consumer close even if the message was not consumed yet?

Akka Kafka Consumer processing rate decreases drastically when lag is there in our Kafka Partitions

Fast Processing Topic and Slow Processing Topic - Akka Kafka

Is this Akka Kafka Stream configuration benefits from Back Pressure mechanism of the Akka Streams?

Lagom topic subscriber - how to retry in Future Exception?

Akka streams Kafka consumer process parallel

How Akka stream internal and explicit buffer interact with the underlying kafka client settings in alpakka Kafka?

Is there functionality in the akka-Kafka (scala framework) to list all available topics

avro4s can not deserialize AnyRef

Troubles with AVRO schema update

Incompatible equality constraint while using Akka Kafka Streams

Getting last message from kafka Topic using akka-stream-kafka when connecting with websocket

Akka streams kafka commit offset after filter

How to sessionize / group the events in Akka Streams?

Using reactive-kafka to conditionally process messages

Akka Kafka stream supervison strategy not working

Trending Questions

Popular # Hahtags

Popular Questions