I hereby claim:
- I am bphenriques on github.
- I am brunohenriques (https://keybase.io/brunohenriques) on keybase.
- I have a public key ASDBvK6Uperq-flymbh8yrArf4lMmyRbue35VPMUQW2Qzgo
To claim this, I am signing this object:
bphenriques
/ ForwardSchemaCompatability.scala
Last active
October 20, 2023 16:27
CheckForwardJsonSchemaCompatibility
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| //> using scala 3.3.1 | |
| //> using repository https://packages.confluent.io/maven/ | |
| //> using dep io.confluent:kafka-json-schema-provider:7.5.1 | |
| //> using dep org.typelevel::cats-core:2.10.0 | |
| //> using dep co.fs2::fs2-core:3.9.2 | |
| //> using dep co.fs2::fs2-io:3.9.2 | |
| import io.confluent.kafka.schemaregistry.json.JsonSchema | |
| import fs2.io.file.* |
bphenriques
/ kafka-config.scala
Last active
January 13, 2023 12:41
Create Kafka consumer properties file
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/usr/bin/env -S scala-cli shebang --scala-version 2 | |
| //> using repository "https://packages.confluent.io/maven/" | |
| //> using repository "jitpack" | |
| //> using repository "https://kaluza.jfrog.io/artifactory/maven/" | |
| //> using lib "is.cir::ciris::3.0.0" | |
| //> using lib "com.ovoenergy::ciris-aiven-kafka::3.0.0" | |
| //> using lib "org.typelevel::cats-core:2.9.0" | |
| //> using lib "org.typelevel::cats-effect:3.4.4" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| // ### Installation | |
| // sbt: brew install sbt@1 | |
| // ammonite: brew install ammonite-repl | |
| // ### Dependencies | |
| import $ivy.`com.typesafe.akka::akka-http:10.1.9` | |
| import $ivy.`com.typesafe.akka::akka-stream:2.5.23` | |
| // ### Configuration | |
| val Host = "localhost" |