Question

Reactive and Non-Blocking Method Micronaut with apache kafka

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

841

Views

Reactive and Non-Blocking Method Micronaut with apache kafka

Published on 02 January 2025 at 01:52

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

80

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 805 · Answer 3 · 2025-01-02 01:52:18

805

Views

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

Published on 02 January 2025 at 01:52

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

543

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 389 · Answer 7 · 2025-01-02 01:54:58

389

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 270 · Answer 9 · 2025-01-02 01:47:41

270

Views

Micronaut 3+ and Kafka integration

Published on 02 January 2025 at 01:47

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

548

Views

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

Published on 02 January 2025 at 01:54

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

669

Views

Providing order to Test class execution Java

Published on 02 January 2025 at 01:49

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

133

Views

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

Published on 02 January 2025 at 01:54

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

295

Views

Replacing micronaut's default KafkaProducerFactory with custom factory implementation

Published on 02 January 2025 at 01:54

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

126

Views

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

Published on 02 January 2025 at 01:54

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

791

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 494 · Answer 17 · 2025-01-07 22:20:21

494

Views

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

Published on 07 January 2025 at 22:20

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

334

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 998 · Answer 19 · 2025-01-02 01:50:30

998

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