Artem Bilan
Artem Bilan
Yeah... My bad, sorry. Yes, the nature of `JdbcChannelMessageStore` is really a queue, so only one can poll the message from that persistent store, even if they are competing. The...
I find this as an abuse of relation database: it is really better to use tools which were designed for messaging: Apache Kafka, RabbitMQ, Pub/Sub, Event Hubs etc. Hazelcast or...
Hi @daniel-oelert ! Would you mind confirming that you still use Java 17? Or that is only a problem starting with Java 21 and enabled virtual threads for your Spring...
Can you share such a simple project with us? I mentioned WebSocket client in my fix, but my impression might be false and we really may fail to keep alive...
Thank you for the sample! I had to fix it like this: ``` "wss://fstream.binance.com/ws/bnbusdt@aggTrade" ``` to make it emitting data when `spring.main.keep-alive=true`, but I see what is going on. The...
Reopen after revert (https://github.com/spring-projects/spring-integration/commit/2cf2f109f97e23f7af9dc07f14e6b701d6da1018). See linked Spring Boot issue: we will reconsider the feature to something more generic or more flexible in the future release. A general idea is to...
If we take a closer look into that PR, we will see that even `@RetryableTopic` was original with a `SameIntervalTopicReuseStrategy.MULTIPLE_TOPICS`. Exactly same value as we still see in the `RetryTopicConfigurationBuilder`....
See the `AbstractConsumerSeekAwareTests` you have introduced and that my `TODO` on `concurrency` attribute. I have an impression that the same callback is used for different groups (or different container instances...
No worries! The first milestone is out today. The next one in a month, so we have plenty of time 😅
So, is the idea for fix to filter out only actual partition to seek and ignore those which are not assigned to us at the moment?