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
Multiple StreamListeners errors when connected to Kafka #1508
Comments
@yonigibbs Noticed the issue on Stack Overflow. We will get to it as soon as possible (within a day or two). Thanks! |
Great stuff, thanks @sobychacko. |
@yonigibbs When you have multiple processors (
You probably want to test with the latest snapshots (2.1.0) as we made some recent changes in the way applicaion id is processed by the binder. |
Thanks @sobychacko, that did indeed sort it, and you're right that I had to upgrade to the latest snapshot release, otherwise the changes had no impact. I guess that's maybe related to issue 448. I was going to suggest that the documentation might need to be clarified about this, but I've just spotted you've already done this as part of this commit. So, thanks again! |
Apologies if this isn't the right forum to post this, as I'm not sure if it's a bug or (more likely) something I'm doing wrong. However I tried posting a question on StackOverflow and had no luck.
I have two methods annotated with
@StreamListener
. One takes in two KTables, and the other takes in a KStream. The Spring Boot app starts correctly, but after a few seconds this error is shown:The code is as follows (in Kotlin):
And the application.yml file is:
A github repo where this problem can be replicated is available here.
Thanks in advance for any pointers on this.
The text was updated successfully, but these errors were encountered: