Get ahead
VMware offers training and certification to turbo-charge your progress.
Learn moreOn behalf of the team and everyone who contributed, I am pleased to announce the next milestone for the new Spring Integration 7.2 minor version.
The second milestone has made it to Maven Central.
Some notable changes in 7.2.0-M2:
spring-integration-kafka module now provides a KafkaShareMessageDrivenChannelAdapter implementation for the Share Kafka consumer abstraction based on the respective Spring for Apache Kafka foundation.
The Java DSL is also provided for this new functionality: @Bean
public IntegrationFlow shareListenerFromKafkaFlow(ShareConsumerFactory<String, String> shareConsumerFactory) {
return IntegrationFlow
.from(Kafka.shareMessageDrivenChannelAdapter(shareConsumerFactory, TEST_TOPIC))
.<String, String>transform(String::toUpperCase)
.channel(c -> c.queue("shareListeningResults"))
.get();
}
Updated Function<MimeMessage, ?> parameters to CheckedFunction, allowing lambdas to throw checked MessagingException directly without try-catch blocks.
.selector(message -> message.getSubject().equals("Test Email"))
See What's New in 7.2 for more details.
We are heading now to code freeze in Release Candidate 1. Don't hesitate to reach us out in GitHub issues for the project with any feedback!
Cheers,
Glenn