TechQA.

Question

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

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

0

Answer

56

Views

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

56 views Asked by user3871913 At 05 February 2024 at 06:05

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

Resetting offset for partition after (Re-)joining group

120 views Asked by Zixel At 08 December 2023 at 23:02

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

How to capture alpakka kafka source stream failure after max RestartSource

52 views Asked by Byron At 25 September 2023 at 15:29

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

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

61 views Asked by Venky At 03 August 2023 at 20:56

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

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

2.3k views Asked by kadir At 30 January 2022 at 13:05

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

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

930 views Asked by Abhinandan Sanduja At 28 October 2021 at 08:24

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

Fast Processing Topic and Slow Processing Topic - Akka Kafka

365 views Asked by rollercoaster At 22 September 2021 at 21:12

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

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

494 views Asked by posthumecaver At 03 December 2020 at 15:26

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

Lagom topic subscriber - how to retry in Future Exception?

150 views Asked by Mark At 09 July 2020 at 02:56

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

Akka streams Kafka consumer process parallel

865 views Asked by vkt At 06 May 2020 at 04:45

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

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

164 views Asked by MaatDeamon At 03 November 2019 at 12:06

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

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

92 views Asked by person personson At 05 June 2019 at 12:29

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

avro4s can not deserialize AnyRef

543 views Asked by HoTicE At 01 August 2018 at 15:03

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

Troubles with AVRO schema update

1k views Asked by HoTicE At 09 July 2018 at 09:02

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

Incompatible equality constraint while using Akka Kafka Streams

693 views Asked by Prasanth At 10 June 2018 at 09:33

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

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

511 views Asked by Martin At 12 April 2018 at 10:28

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

Akka streams kafka commit offset after filter

1.1k views Asked by Kanekotic At 13 March 2018 at 18:05

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

How to sessionize / group the events in Akka Streams?

217 views Asked by dks551 At 12 March 2018 at 10:28

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

Using reactive-kafka to conditionally process messages

560 views Asked by Thundzz At 15 February 2018 at 22:16

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

Akka Kafka stream supervison strategy not working

630 views Asked by dks551 At 06 October 2017 at 06:28

TechQA.

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

Popular Questions

Trending Questions