Question

Resetting offset for partition after (Re-)joining group

score 103 · Answer 1 · 2023-12-08 23:02:26

103

Views

Resetting offset for partition after (Re-)joining group

Published on 08 December 2023 at 23:02

score 475 · Answer 2 · 2020-12-03 15:26:55

475

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 525 · Answer 3 · 2018-08-01 15:03:55

525

Views

avro4s can not deserialize AnyRef

Published on 01 August 2018 at 15:03

score 151 · Answer 4 · 2019-11-03 12:06:16

151

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 610 · Answer 5 · 2017-10-06 06:28:14

610

Views

Akka Kafka stream supervison strategy not working

Published on 06 October 2017 at 06:28

score 349 · Answer 6 · 2021-09-22 21:12:15

349

Views

Fast Processing Topic and Slow Processing Topic - Akka Kafka

Published on 22 September 2021 at 21:12

score 1.5k · Answer 7 · 2017-01-24 09:53:24

1.5k

Views

Reactive-Kafka Stream Consumer: Dead letters occured

Published on 24 January 2017 at 09:53

score 44 · Answer 8 · 2023-08-03 20:56:10

44

Views

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

Published on 03 August 2023 at 20:56

score 844 · Answer 9 · 2020-05-06 04:45:37

844

Views

Akka streams Kafka consumer process parallel

Published on 06 May 2020 at 04:45

score 649 · Answer 10 · 2018-06-10 09:33:30

649

Views

Incompatible equality constraint while using Akka Kafka Streams

Published on 10 June 2018 at 09:33

score 1.8k · Answer 11 · 2017-03-06 20:14:30

1.8k

Views

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

Published on 06 March 2017 at 20:14

score 543 · Answer 12 · 2017-03-06 23:33:52

543

Views

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

Published on 06 March 2017 at 23:33

score 494 · Answer 13 · 2018-04-12 10:28:02

494

Views

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

Published on 12 April 2018 at 10:28

score 999 · Answer 14 · 2018-07-09 09:02:51

999

Views

Troubles with AVRO schema update

Published on 09 July 2018 at 09:02

score 681 · Answer 15 · 2015-12-22 08:32:36

681

Views

Kafka producer with adjustable amount of messages per second

Published on 22 December 2015 at 08:32

score 2.3k · Answer 16 · 2022-01-30 13:05:59

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 781 · Answer 17 · 2016-12-14 05:56:58

781

Views

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

Published on 14 December 2016 at 05:56

score 42 · Answer 18 · 2024-02-05 06:05:08

42

Views

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

Published on 05 February 2024 at 06:05

score 204 · Answer 19 · 2018-03-12 10:28:43

204

Views

How to sessionize / group the events in Akka Streams?

Published on 12 March 2018 at 10:28

score 1k · Answer 20 · 2018-03-13 18:05:17

1k

Views

Akka streams kafka commit offset after filter

Published on 13 March 2018 at 18:05

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

Trending Questions

Popular # Hahtags

Popular Questions