Orchestrator.java

public class Orchestrator {
    public Orchestrator(ProductClient productClient) {
        ...
    }
    
    public static void main(String[] args) {
        Iterator<List<Product>> productsIterator = productClient.fetchAllProducts();
        while (productsIterator.hasNext()) {
            List<Product> products = iterator.next();
            products.stream()
                .map(Product::transform)
                .forEach(Product::publishToKafka)
                .forEach(Product::writeToSQL);
        }
    }
}