StackOverflow Questions for Tag: reactor-kafka

EarthsPiligrim

Reputation: 61

How can i make manual resume work on Kafka Topic subscription?

spring-bootspring-webfluxproject-reactorreactor-kafka

Score: 0

Answers: 0

iris

Reputation: 103

Kafka reactor response

javaapache-kafkaspring-kafkareactor-kafka

Score: 0

Answers: 1

Ignasi

Reputation: 6185

Kafka connection loss due to "Cannot change principals during re-authentication"

apache-kafkaspring-kafkaaws-mskreactor-kafka

Score: 2

Answers: 0

PatPanda

Reputation: 5020

How to use Reactor Kafka KafkaSender API to send messages to two different topics (situated in two different Kafka clusters)?

javaapache-kafkareactor-kafka

Score: 0

Answers: 1

Iori Yagami

Reputation: 406

Integration Test fails to verify 2 KafkaReceiver flux at once

integration-testingspring-webfluxreactor-kafkaembedded-kafka

Score: 0

Answers: 0

bobryash

Reputation: 149

Implement Reactive Kafka Listener in Spring Boot application

javaapache-kafkaspring-kafkareactor-kafkareactive-kafka

Score: 10

Answers: 2

Josiah Foo

Reputation: 1

R2DBC Save Operation Triggers Multiple Times

spring-bootreactive-programmingr2dbcreactor-kafka

Score: 0

Answers: 1

2knight

Reputation: 1

ReactiveKafkaConsumer template pause/resume on rebalance

spring-bootkafka-consumer-apireactor-kafka

Score: 0

Answers: 0

ritratt

Reputation: 1858

How to reactively process kafka messages using Micronaut-Kafka

javamicronautreactor-kafkamicronaut-kafka

Score: 0

Answers: 0

Mikhail Geyer

Reputation: 1171

Kafka-reactor to read the same kafka message again if message processing failed

javaspring-kafkaproject-reactorreactor-kafka

Score: 2

Answers: 2

Emin Çiftçi

Reputation: 21

Reactor kafka: Consume messages, save to database and after insertion perform another action

spring-bootproject-reactorreactor-kafka

Score: 0

Answers: 0

stefaan dutry

Reputation: 1106

Kafka reactor KafkaReceiver (spring) - how to test?

testingapache-kafkakafka-consumer-apireactor-kafka

Score: 0

Answers: 0

koufa

Reputation: 113

Reactor Kafka receiveAutoAck and at least once semantics

springspring-bootapache-kafkaproject-reactorreactor-kafka

Score: 0

Answers: 1

koufa

Reputation: 113

Spring Kafka ReactiveKafkaConsumerTemplate and Reactor Kafka differences for at least once delivery

springspring-bootapache-kafkaspring-kafkareactor-kafka

Score: 0

Answers: 1

kumar

Reputation: 1

Retry logic for Reactive Kafka is not working

javaapache-kafkaspring-kafkareactor-kafkareactive-kafka

Score: 0

Answers: 0

PatPanda

Reputation: 5020

spring native kafka.common.KafkaException: Could not find a public no-argument constructor for io.confluent.kafka.serializers.KafkaJsonSerializer

javaspring-bootapache-kafkagraalvm-native-imagereactor-kafka

Score: -1

Answers: 1

candicetdh

Reputation: 61

Kafka topic partitions are paused for downstream consumer due to backpressure. Only one of the partitions got drained eventually

apache-kafkaproject-reactorreactor-kafka

Score: 0

Answers: 1

user7551211

Reputation: 707

Reactor Kafka Application Stops Unexpectedly Without Errors During High-Volume Consumption

apache-kafkakafka-consumer-apiproject-reactorreactor-kafka

Score: 1

Answers: 0

PatPanda

Reputation: 5020

Pattern to change Kafka producer type per configuration

javaapache-kafkaspring-kafkareactor-kafka

Score: 0

Answers: 1

PatPanda

Reputation: 5020

Intermittent "Node X disconnected" issue for Kafka despite batch.size , linger.ms change

javaapache-kafkaspring-kafkareactor-kafka

Score: 1

Answers: 0

PreviousPage 1Next

StackOverflow Questions for Tag: reactor-kafka

How can i make manual resume work on Kafka Topic subscription?

Kafka reactor response

Kafka connection loss due to &quot;Cannot change principals during re-authentication&quot;

How to use Reactor Kafka KafkaSender API to send messages to two different topics (situated in two different Kafka clusters)?

Integration Test fails to verify 2 KafkaReceiver flux at once

Implement Reactive Kafka Listener in Spring Boot application

R2DBC Save Operation Triggers Multiple Times

ReactiveKafkaConsumer template pause/resume on rebalance

How to reactively process kafka messages using Micronaut-Kafka

Kafka-reactor to read the same kafka message again if message processing failed

Reactor kafka: Consume messages, save to database and after insertion perform another action

Kafka reactor KafkaReceiver (spring) - how to test?

Reactor Kafka receiveAutoAck and at least once semantics

Spring Kafka ReactiveKafkaConsumerTemplate and Reactor Kafka differences for at least once delivery

Retry logic for Reactive Kafka is not working

spring native kafka.common.KafkaException: Could not find a public no-argument constructor for io.confluent.kafka.serializers.KafkaJsonSerializer

Kafka topic partitions are paused for downstream consumer due to backpressure. Only one of the partitions got drained eventually

Reactor Kafka Application Stops Unexpectedly Without Errors During High-Volume Consumption

Pattern to change Kafka producer type per configuration

Intermittent &quot;Node X disconnected&quot; issue for Kafka despite batch.size , linger.ms change

Kafka connection loss due to "Cannot change principals during re-authentication"

Intermittent "Node X disconnected" issue for Kafka despite batch.size , linger.ms change