Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

4. Configure Kafka Streams application #32

Open
dagmendez opened this issue May 16, 2023 · 0 comments
Open

4. Configure Kafka Streams application #32

dagmendez opened this issue May 16, 2023 · 0 comments

Comments

@dagmendez
Copy link
Collaborator

dagmendez commented May 16, 2023

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.
@dagmendez dagmendez added this to the Include Kafka Streams milestone May 16, 2023
@dagmendez dagmendez changed the title Integration test for kafka stream 4. Configure Kafka Streams application May 17, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant