TechQA.

Question

Resetting offset for partition after (Re-)joining group

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

0

Answer

120

Views

Resetting offset for partition after (Re-)joining group

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

score 494 · Answer 2 · 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 543 · Answer 3 · 2018-08-01T15:03:55.683000

avro4s can not deserialize AnyRef

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

score 164 · Answer 4 · 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 630 · Answer 5 · 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

score 365 · Answer 6 · 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 1568 · Answer 7 · 2017-01-24T09:53:24.527000

Reactive-Kafka Stream Consumer: Dead letters occured

1.5k views Asked by anshul_cached At 24 January 2017 at 09:53

score 61 · Answer 8 · 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 865 · Answer 9 · 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 693 · Answer 10 · 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 1891 · Answer 11 · 2017-03-06T20:14:30.857000

What is a good pattern for committing Kafka consumer offset after processing message?

1.8k views Asked by jacob At 06 March 2017 at 20:14

score 562 · Answer 12 · 2017-03-06T23:33:52.443000

How do you return a future containing a list of messages after all available messages have been consumed from a Kafka topic?

562 views Asked by SML At 06 March 2017 at 23:33

score 511 · Answer 13 · 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 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 695 · Answer 15 · 2015-12-22T08:32:36.880000

Kafka producer with adjustable amount of messages per second

695 views Asked by benny.la At 22 December 2015 at 08:32

score 2351 · Answer 16 · 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 798 · Answer 17 · 2016-12-14T05:56:58.477000

Akka Stream TCP + Akka Stream Kafka producer not stopping not publishing messages and not error-ing out

798 views Asked by Darien At 14 December 2016 at 05:56

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

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 217 · Answer 19 · 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 1102 · Answer 20 · 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

TechQA.

List Question

Resetting offset for partition after (Re-)joining group

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

avro4s can not deserialize AnyRef

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

Akka Kafka stream supervison strategy not working

Fast Processing Topic and Slow Processing Topic - Akka Kafka

Reactive-Kafka Stream Consumer: Dead letters occured

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

Akka streams Kafka consumer process parallel

Incompatible equality constraint while using Akka Kafka Streams

What is a good pattern for committing Kafka consumer offset after processing message?

How do you return a future containing a list of messages after all available messages have been consumed from a Kafka topic?

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

Troubles with AVRO schema update

Kafka producer with adjustable amount of messages per second

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 Stream TCP + Akka Stream Kafka producer not stopping not publishing messages and not error-ing out

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

How to sessionize / group the events in Akka Streams?

Akka streams kafka commit offset after filter

Popular Questions

Popular Tags

Trending Questions