Lorenzo SilvestriniDynamically derivate JSON traits and case classes with Circe in ScalaIn our scenario to decode and model a Json string (e.g. a configuration file) that may have different data structures for its fields.2 min read·Mar 10, 2021----
Lorenzo SilvestriniWriting on the same folder with multiple replicas in Google Cloud StorageThe writing process of different files into the same folder in Google Cloud Storage could lead to conflicts in case of this step is…3 min read·Mar 6, 2021----
Lorenzo SilvestriniIntegrate a ZIO Kafka Producer in an I/O database environmentA lot of modern big data scenarios are designed to extract, transform and load data in a continuous input/output architecture as a result…2 min read·Sep 4, 2020----
Lorenzo SilvestriniRead from specific partitions with Flink Kafka Consumer in a Docker swarm clusterApache Flink offers a powerful integration with Kafka service, with an high level wrapper for the consumer. The main part of the code…3 min read·Jun 30, 2020----