Artem Bilan

Well, still doesn’t sound as reasonable. This store type is exactly for the `QueueChannel` - the `group` is a `queue`,- which may have a consumer or not. That’s exactly the...

So, you talk now about "time to live per message", which really has nothing to do with the message group expiration as a part of `MessageGroupStoreReaper` logic. That's exactly my...

Good. Together with messages streaming for a group in this store abstraction I will look into an iterator implementation similar to the `AbstractMessageGroupStore`. Remember: this `ChannelMessageStore` is not only for...

It is possible at the moment with a combination of Reactor Kafka and `MessageProducerSupport.subscribeToPublisher(Publisher> publisher)`: https://docs.spring.io/spring-integration/docs/current/reference/html/reactive-streams.html#event-driven-channel-adapter. Or there is a nice trick via `ReactiveMessageSourceProducer` and existing `KafkaMessageSource`. See the same...

BTW, the logic for Reactor Kafka channel adapters really might be borrowed from a new Reactor Kafka binder in Spring Cloud Stream: https://github.com/spring-cloud/spring-cloud-stream/blob/main/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinder.java

I wonder if this is really going to be a robust solution since we just might not have `MV` permission on that SFTP side, only reading one. I would suggest...

Right. Isn't that what we do with distributed `MetadataStore` in source filters and in the idempotent receiver as well? What is the point to fetch the same file in another...

We had a similar ticket on JIRA for a while: https://jira.spring.io/browse/INT-4442

@gopibalagala , your question is not related to this ticket. Please, use StackOverflow for the proper question-answer interaction. Nevertheless your goal could be achieved via `SftpOutboundGateway` and its `GET`. See...

Right. We don't have any objections to move `JsonPropertyAccessor` from Spring Integration to Spring Framework. The `SpelPropertyAccessorRegistrar` has direct interaction with the `AbstractEvaluationContextFactoryBean` which produces `prototype` instances of the `EvaluationContext`...