-
Notifications
You must be signed in to change notification settings - Fork 433
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
Document GRPC starter + Kafka Stream usage #219
Comments
If you could provide the project that reproduces the behavior, it would be great. |
Great, I'll fix a minimal project to reproduce the issue shortly. |
Here is sample project that shows the problem. https://github.com/jedvardsson/grpc-spring-boot-starter-hangs-waiting-for-kafka-bug |
Thanks @jedvardsson, I'll have a look |
@jedvardsson , according to this, we will need to explicitly set the consumer/producer function definitions, no way to mark the Consumer/Produce/Function beans as not eligible for registration. |
@jedvardsson , this is essential if you have more than 1 Consumer/Producer/Function bean. |
Hi, I am having problem starting a spring cloud app using this project when no Kafka is available, which is normal in development. The app will hang until KafkaAdminClient times out after 60 s before the app is fully started.
What happens is that the bean
grpcInternalConfigurator
which is defined as aConsumer<ServerBuilder<?>>
seems to request a Kafka Topic. This is because spring cloud streaming treats beans ofConsumer
,Supplier
andFunction
as part of their messing system.I am not sure if the intent of
GRpcAutoConfiguration
is to depend on this feature. From what I can tell it does not look so, however, I am a novice in this area so I could be wrong.The text was updated successfully, but these errors were encountered: