Question

Reactive and Non-Blocking Method Micronaut with apache kafka

score 832 · Answer 1 · 2025-01-02 01:52:37

832

Views

Reactive and Non-Blocking Method Micronaut with apache kafka

Published on 02 January 2025 at 01:52

score 73 · Answer 2 · 2025-01-02 01:54:33

73

Views

Can I use same group id between Kafka Streams topology and a normal Kafka consumer?

Published on 02 January 2025 at 01:54

score 799 · Answer 3 · 2025-01-02 01:52:18

799

Views

Is it OK to call Kafka Streams StreamBuilder.build() multiple times

Published on 02 January 2025 at 01:52

score 537 · Answer 4 · 2025-01-02 01:47:09

537

Views

Micronaut Kafka is blocking

Published on 02 January 2025 at 01:47

score 1.1k · Answer 5 · 2025-01-02 01:55:15

1.1k

Views

Proto + Kafka Producer: Error serializing object to JSON: Direct self-reference leading to cycle (through reference chain unknownFields

Published on 02 January 2025 at 01:55

score 1.7k · Answer 6 · 2025-01-02 01:53:59

1.7k

Views

Micronaut-Kafka with auto.commit.enable=false: how commit manually an offset

Published on 02 January 2025 at 01:53

score 382 · Answer 7 · 2025-01-02 01:54:58

382

Views

Kafka Producer: how code onSuccess/onError callbacks with Reactive and Non-Blocking Producer

Published on 02 January 2025 at 01:54

score 3.7k · Answer 8 · 2025-01-02 01:51:26

3.7k

Views

From inside of Kafka Consumer, how get the message header

Published on 02 January 2025 at 01:51

score 263 · Answer 9 · 2025-01-02 01:47:41

263

Views

Micronaut 3+ and Kafka integration

Published on 02 January 2025 at 01:47

score 542 · Answer 10 · 2025-01-02 01:54:38

542

Views

Why sometimes Kafka Messaging Queue returns no message when writing Integration Test?

Published on 02 January 2025 at 01:54

score 664 · Answer 11 · 2025-01-02 01:49:26

664

Views

Providing order to Test class execution Java

Published on 02 January 2025 at 01:49

score 128 · Answer 12 · 2025-01-02 01:54:51

128

Views

RabbitMq Consumer not working because micronaut assigns executor threads to kafka consumer

Published on 02 January 2025 at 01:54

score 290 · Answer 13 · 2025-01-02 01:54:37

290

Views

Replacing micronaut's default KafkaProducerFactory with custom factory implementation

Published on 02 January 2025 at 01:54

score 121 · Answer 14 · 2025-01-02 01:54:22

121

Views

Exactly once semantics possible in consumer-producer-cycle with micronaut kafka?

Published on 02 January 2025 at 01:54

score 786 · Answer 15 · 2025-01-04 12:03:59

786

Views

Retrying a failed kafka message using Micronaut listener

Published on 04 January 2025 at 12:03

score 3.4k · Answer 16 · 2025-01-02 01:52:17

3.4k

Views

Micronaut Kafka: Health check fails with "Cluster authorization failed"

Published on 02 January 2025 at 01:52

score 489 · Answer 17 · 2025-01-07 22:20:21

489

Views

Kafka Streams failing with Materialized.`as`(STORE_NAME)

Published on 07 January 2025 at 22:20

score 326 · Answer 18 · 2025-01-08 00:52:25

326

Views

In micronaut-kafka, How can I use JAAS config to two different consumers from one application?

Published on 08 January 2025 at 00:52

score 993 · Answer 19 · 2025-01-02 01:50:30

993

Views

Kafka stream messages being processed multiple times

Published on 02 January 2025 at 01:50

score 2.7k · Answer 20 · 2025-01-02 01:53:21

2.7k

Views

How to configure Rate Limiting on Kafka Topic while publishing message?

Published on 02 January 2025 at 01:53

List Question

Reactive and Non-Blocking Method Micronaut with apache kafka

Can I use same group id between Kafka Streams topology and a normal Kafka consumer?

Is it OK to call Kafka Streams StreamBuilder.build() multiple times

Micronaut Kafka is blocking

Proto + Kafka Producer: Error serializing object to JSON: Direct self-reference leading to cycle (through reference chain unknownFields

Micronaut-Kafka with auto.commit.enable=false: how commit manually an offset

Kafka Producer: how code onSuccess/onError callbacks with Reactive and Non-Blocking Producer

From inside of Kafka Consumer, how get the message header

Micronaut 3+ and Kafka integration

Why sometimes Kafka Messaging Queue returns no message when writing Integration Test?

Providing order to Test class execution Java

RabbitMq Consumer not working because micronaut assigns executor threads to kafka consumer

Replacing micronaut's default KafkaProducerFactory with custom factory implementation

Exactly once semantics possible in consumer-producer-cycle with micronaut kafka?

Retrying a failed kafka message using Micronaut listener

Micronaut Kafka: Health check fails with "Cluster authorization failed"

Kafka Streams failing with Materialized.`as`(STORE_NAME)

In micronaut-kafka, How can I use JAAS config to two different consumers from one application?

Kafka stream messages being processed multiple times

How to configure Rate Limiting on Kafka Topic while publishing message?

Trending Questions

Popular # Hahtags

Popular Questions