This article is part of a blog series that explores the newly redesigned Spring Cloud Stream applications based on Java Functions. In this post, we will look at the Elasticsearch sink that allows us to index records in Elasticsearch, and its corresponding Consumer function.

Here are all the previous parts of this blog series.

• Introducing Function Based Streaming Applications

• Function Composition with Streaming Applications

• How to Build a Supplier and Source Application

• How to Build a Consumer and Sink Application

• Build and Run a Simple Stream Application

• Case Study: HTTP Request Function and Processor

• Case Study: File Source and MongoDB Sink

• Case Study: Relational Database Source and File Sink

• Case Study: Remote File Ingest with Spring Cloud Data Flow

• Case Study: Aggregator Function and Processor

…

The Spring Data MongoDB 3.1 release is one of the modules that highly benefited from the recent changes in the Spring Data Commons module, by leveraging the infrastructure built there to bring reactive features like auditing and SpEL. The following snippet gives you an impression of what this means for declarative MongoDB queries using SpEL:

@Query("{ 'supervisor' : ?#{ hasRole('ROLE_ADMIN') " +
  "? new Document('$regex', '*') : principal.name } }")
Flux<Person> findAllFilteredByRole();

@EnableReactiveMongoAuditing uses the common infrastructure so you can keep track of changes easily.

…

Hi Spring fans! Welcome to another installment of a Bootiful Podcast! In this installment Josh Long (@starbuxman) looks at the week that was, talks about the JUST released Spring Boot 2.4, and then talks to industry legend and larger-than-life friend John Davies (@jtdavies)

Hi, Spring fans! Welcome to another installment of This Week in Spring! It's November 10th, 2020, as I write this and I, for one, can not believe that we're closer to 2021 than we are to 2019 at this point. That's insane. Time has absolutely rocketed by in some senses and stood utterly still in others. Odd year, this one.

I hope you're all doing well! I'm at the Reactive Summit today (virtually, of course). This afternoon I was on a wonderful panel with all sorts of folks from around the ecosystem. And soon, around 17:30 or so, if memory serves, I'll be speaking about RSocket and its use in…

As part of the 2020.0.0 version of Spring Data, we released Spring Data JDBC 2.1. This article presents the four most interesting changes in this version.

• Use @Value on entity constructor arguments.
• RowMapper and ResultSetExtractor as beans.
• Improved performance for entities.
• Support of Oracles temporal types.

#Use @Value on Entity Constructor Arguments

In some cases, not all the data that goes into an entity comes from the ResultSet of a query. You now may provide an @Value annotation with a SPeL expression that is evaluated, and the result is passed as an argument upon construction of the…

If you regularly listen to A Bootiful Podcast, you might have heard about the improvements we made to Spring Framework’s cron support. Cron expressions are mostly used in Spring applications through the @Scheduled annotation. In Spring 5.3, we introduced the CronExpression class, which represents — you guessed it — a cron expression.

CronExpression replaces CronSequenceGenerator, which is based on java.util.Calendar and which has several known issues that none of the Spring team members felt comfortable solving. Introducing a new type allowed us to use the superior java.time APIs, solve the…

Spring Data 2020.0, based on Spring Framework 5.3, is out and with it, a ton of new features across the various stores, which are covered by the individual modules. While posting highlights along with the milestone announcements, we wanted to give you a more detailed description of the new features in a series of blog posts. These posts will cover, among other things:

• Reactive Context Access features in Data Commons.
• Lifecycle callbacks and baselining to Spring R2DBC in R2DBC.
• General Repository and store-specific Redis Cache Metrics.
• Neo4J reactive repositories.
• Paging repository APIs for Spring Data for Apache Geode.
• Geoshape, index, and reactive search improvements for Spring Data Elasticsearch.
• Partial filter and aggregation hints in MongoDB.
• @Bean row mappers for the JDBC module.
• Per-statement key spaces definition for the Apache Cassandra abstraction.
• Declarative Couchbase N1QL queries.
…

Hi, Spring fans! In this episode Josh Long (@starbuxman) talks to Spring legend Thomas Risberg (@trisberg).

Hi, Spring fans! I hope you're all doing well, staying safe, healthy and happy. Today's election day here in the US, so I am super happy to have the chance to dive into this week's roundup as a bit of a distraction. We've got a ton to get through today, so let's!

• I really enjoyed last week's A Bootiful Podcast episode with Spring Test Framework lead and JUnit contributor Sam Brannen
• Spring Integration 5.4 goes GA; some other Integration releases
• Spring Boot 2.4.0.RC1 is now available
• Notice of Permissions Changes to repo.spring.io, Fall and Winter, 2020
• Congrats, Carsten Hoffmann, on your first live-coding presentation, and congrats on starting your work from my second favorite place on the internet: start.spring.io!
• Oleh Dokuka on Twitter: "Woo! ? ? New RSocket 1.1.0 is GA. It includes, among other things, 10x better performance than before, reworked loadbalance API and implementation, a new RSocketClient…