Filtering a Spark Dataset against a collection of data values is a commonly encountered use case for many data analytics scenarios. This article explains four different ways to achieve the same.
In this post, we will be implementing a Kafka Producer and Consumer using the Ports and Adapters (a.k.a. Hexagonal) architecture in a multi-module Maven project.