akka-http-avro

License	Apache-2.0
Categories	Akka Container Microservices Reactive libraries
GroupId	fr.davit
ArtifactId	akka-http-avro_2.11
Last Version	0.1.1
Release Date	Jul 3, 2020
Type	jar
Description	akka-http-avro akka-http-avro
Project URL	https://github.com/RustedBones/akka-http-avro
Project Organization	Michel Davit
Source Code Management	https://github.com/RustedBones/akka-http-avro

Download akka-http-avro_2.11

Filename	Size
akka-http-avro_2.11-0.1.1.pom
akka-http-avro_2.11-0.1.1.jar	33 KB
akka-http-avro_2.11-0.1.1-sources.jar	3 KB
akka-http-avro_2.11-0.1.1-javadoc.jar	393 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/fr.davit/akka-http-avro_2.11/ -->
<dependency>
    <groupId>fr.davit</groupId>
    <artifactId>akka-http-avro_2.11</artifactId>
    <version>0.1.1</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/fr.davit/akka-http-avro_2.11/
implementation 'fr.davit:akka-http-avro_2.11:0.1.1'

Gradle Kotlin

// https://jarcasting.com/artifacts/fr.davit/akka-http-avro_2.11/
implementation ("fr.davit:akka-http-avro_2.11:0.1.1")

Apache Buildr

'fr.davit:akka-http-avro_2.11:jar:0.1.1'

Apache Ivy

<dependency org="fr.davit" name="akka-http-avro_2.11" rev="0.1.1">
  <artifact name="akka-http-avro_2.11" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='fr.davit', module='akka-http-avro_2.11', version='0.1.1')
)

Scala SBT

libraryDependencies += "fr.davit" % "akka-http-avro_2.11" % "0.1.1"

Leiningen

[fr.davit/akka-http-avro_2.11 "0.1.1"]

Dependencies

compile (3)

Group / Artifact	Type	Version
org.scala-lang : scala-library	jar	2.11.12
com.typesafe.akka : akka-http_2.11	jar	10.1.12
org.apache.avro : avro	jar	1.10.0

provided (2)

Group / Artifact	Type	Version
com.typesafe.akka : akka-stream_2.11	jar	2.5.31
ch.qos.logback : logback-classic	jar	1.2.3

test (3)

Group / Artifact	Type	Version
com.typesafe.akka : akka-testkit_2.11	jar	2.5.31
com.typesafe.akka : akka-http-testkit_2.11	jar	10.1.12
org.scalatest : scalatest_2.11	jar	3.2.0

Project Modules

There are no modules declared in this project.

akka-http-avro

akka-http avro marshalling/unmarshalling for generated java avro specific records

Versions

Version	Release date	Akka Http version	Avro version	Scala versions
0.1.2	2020-09-18	10.2.0	1.10.0	2.13.3, 2.12.12
0.1.1	2020-07-03	10.1.12	1.10.0	2.13.3, 2.12.11, 2.11.12
0.1.0	2020-03-01	10.1.11	1.9.2	2.13.1, 2.12.10, 2.11.12

The complete list can be found in the CHANGELOG file.

Getting akka-http-avro

Libraries are published to Maven Central. Add to your build.sbt:

libraryDependencies += "fr.davit" %% "akka-http-avro" % <version>

Quick start

For the examples, we are using the following avro domain model

{
  "namespace": "com.example",
  "type": "record",
  "name": "Item",
  "fields": [
    {
      "name": "name",
      "type": "string"
    },
    {
      "name": "id",
      "type": "long"
    }
  ]
}

and

{
  "namespace": "com.example",
  "type": "record",
  "name": "Order",
  "fields": [
    {
      "name": "items",
      "type": {
        "type" : "array",
        "items": "com.example.Item"
      }
    }
  ]
}

Marshalling/Unmarshalling of the generated classes depends on the Accept/Content-Type header sent by the client:

• Content-Type: application/json: json
• Content-Type: avro/binary: binary

-No Accept header or matching several (eg Accept: application/*) will take the 1st matching type from the above list.

Avro

The implicit marshallers and unmarshallers for your generated avro classes are defined in AvroSupport. Specific (un)marshallers can be imported from AvroBinarySupport, AvroJsonSupport. You simply need to have them in scope.

import akka.http.scaladsl.server.Directives._
import fr.davit.akka.http.scaladsl.marshallers.avro.AvroSupport._


object MyAvroService {

  val route =
    get {
      pathSingleSlash {
        complete(Item.newBuilder().setName("thing").setId(42).build())
      }
    } ~ post {
      entity(as[Order]) { order =>
        val itemsCount = order.getItems.size
        val itemNames = order.getItems.asScala.map(_.getName).mkString(", ")
        complete(s"Ordered $itemsCount items: $itemNames")
      }
    }
}

Limitation

Entity streaming (http chunked transfer) is at the moment not supported by the library.

Versions

Version
0.1.1 Jul 3, 2020
0.1.0 Mar 1, 2020