-
Notifications
You must be signed in to change notification settings - Fork 222
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Can you add spring boot + reactive kafka tutorials? #220
Comments
Have you looked at the samples ? |
@javaHelper there is an example of integration with Spring Boot here https://github.com/Kevded/example-reactive-spring-kafka-consumer-and-producer ReactiveKafkaProducerTemplate & ReactiveKafkaConsumerTemplate. |
Hi @garyrussell , all, just out of curiosity I have a question, do you see any issue if we use spring-kafka without reactor-kafka on webflux (netty). I tried to run it, it and was looking fine , just creates its own producer and consumer threads. I know it will be blocking , but is there any other drawback apart from this. |
@Aniket-Singla Producer should be fine; I am not sure what you mean on the consumer side; please clarify. |
Hi Gary, on Consumer side too I am following the native approach (spring-kafka KafkaListener annotation )
For creating consumer factory:
I can confirm that messages are getting consumed on webflux (netty) as well. I was wondering if there can be any issue if I do not migrate to reactor-kafka. Thanks. |
It is still not clear; sorry; the |
Yes, that is true, "it creates its own task executor to create threads". By saying :
I meant my spring boot application is running on netty , but spring-kafka is creating its own executor. I just wanted to make sure that going with @KafkaListner threads in webflux is limited to the below issue:
Thanks |
But, the |
I already got your point thanks. By saying
I mean, @KafkaListener's threads will be blocking netty's threads because my @KafkaListener's threads will internally call logic that runs on Reactor's threads. I think I am clear now. Thanks for helping till here. |
@garyrussell Can you please confirm whether the last comment made by @Aniket-Singla is correct or not? |
I don't know - I don't understand what (s)he's trying to say. If the task is handed off to a netty thread spring-kafka is out of the picture. |
Waiting for this |
spring-projects/spring-boot#29080 is related to here. |
spring webflux + reactive Kafka checkout this article. |
No description provided.
The text was updated successfully, but these errors were encountered: