root


License

License

Categories

Categories

Scala Languages
GroupId

GroupId

io.github.moleike
ArtifactId

ArtifactId

kafka-streams-avro-scala_2.12
Last Version

Last Version

0.2.5
Release Date

Release Date

Type

Type

jar
Description

Description

root
root
Project URL

Project URL

https://github.com/moleike/kafka-streams-avro-scala
Project Organization

Project Organization

io.github.moleike
Source Code Management

Source Code Management

https://github.com/moleike/kafka-streams-avro-scala

Download kafka-streams-avro-scala_2.12

How to add to project

<!-- https://jarcasting.com/artifacts/io.github.moleike/kafka-streams-avro-scala_2.12/ -->
<dependency>
    <groupId>io.github.moleike</groupId>
    <artifactId>kafka-streams-avro-scala_2.12</artifactId>
    <version>0.2.5</version>
</dependency>
// https://jarcasting.com/artifacts/io.github.moleike/kafka-streams-avro-scala_2.12/
implementation 'io.github.moleike:kafka-streams-avro-scala_2.12:0.2.5'
// https://jarcasting.com/artifacts/io.github.moleike/kafka-streams-avro-scala_2.12/
implementation ("io.github.moleike:kafka-streams-avro-scala_2.12:0.2.5")
'io.github.moleike:kafka-streams-avro-scala_2.12:jar:0.2.5'
<dependency org="io.github.moleike" name="kafka-streams-avro-scala_2.12" rev="0.2.5">
  <artifact name="kafka-streams-avro-scala_2.12" type="jar" />
</dependency>
@Grapes(
@Grab(group='io.github.moleike', module='kafka-streams-avro-scala_2.12', version='0.2.5')
)
libraryDependencies += "io.github.moleike" % "kafka-streams-avro-scala_2.12" % "0.2.5"
[io.github.moleike/kafka-streams-avro-scala_2.12 "0.2.5"]

Dependencies

compile (4)

Group / Artifact Type Version
org.scala-lang : scala-library jar 2.12.7
org.apache.kafka : kafka-clients jar 2.0.0
io.confluent » kafka-avro-serializer jar 5.0.0
com.sksamuel.avro4s : avro4s-core_2.12 jar 2.0.3

test (2)

Group / Artifact Type Version
org.scalacheck : scalacheck_2.12 jar 1.13.5
org.scalatest : scalatest_2.12 jar 3.0.5

Project Modules

There are no modules declared in this project.

kafka-streams-avro-scala

This library provides marshalling of Avro records into case classes with Schema Registry for schema evolution.

Install

To use this library add the following line to your dependencies:

"io.github.moleike" %% "kafka-streams-avro-scala" % "0.2.5"

Synopsis

First bring the implicit generic SerDe into scope:

import com.moleike.kafka.streams.avro.generic.Serdes._

Then configure the Serdes:

implicit val conf: Config = Map("schema.registry.url" -> "http://localhost:8081")

Use case classes with no boilerplate in your Kafka Streams application:

import org.apache.kafka.streams.scala.StreamsBuilder
import org.apache.kafka.streams.scala.kstream._

case class Store(name: String, address: String)

val builder = new StreamsBuilder()

val stores: KStream[String, Store] = builder.stream("stores")

License

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this software except in compliance with the License.

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Versions

Version
0.2.5