This task involves managing the magic numbers / hard coded values with the Cir.is library.
Configure the Kafka Streams application by specifying the Kafka broker addresses, application ID, and other required properties.
This can be done through a properties file or programmatically in Scala:
Create a new configuration wrapper case class or reuse an existing one in the module core-headers in the package com.fortyseven.coreheaders.config similar to the final case class KafkaConsumerConfig.
Create a new configuration case class in the package com.fortyseven.coreheaders.config.internal
Create an instance of the configuration in the module configurationin the package com.fortyseven.configuration.
This task involves managing the magic numbers / hard coded values with the Cir.is library.
This can be done through a properties file or programmatically in Scala:
core-headersin the packagecom.fortyseven.coreheaders.configsimilar to the final case classKafkaConsumerConfig.com.fortyseven.coreheaders.config.internalconfigurationin the packagecom.fortyseven.configuration.