Auto Configuration: Sparkstreaming Stream Kinesis

Zipkin AWS (Parent)

License

License

Categories

Categories

AWS Container PaaS Providers Zipkin Application Testing & Monitoring Application Performance Monitoring (APM) Auto Application Layer Libs Code Generators config Configuration
GroupId

GroupId

io.zipkin.aws
ArtifactId

ArtifactId

zipkin-sparkstreaming-autoconfigure-stream-kinesis
Last Version

Last Version

0.9.0
Release Date

Release Date

Type

Type

jar
Description

Description

Auto Configuration: Sparkstreaming Stream Kinesis
Zipkin AWS (Parent)
Project Organization

Project Organization

OpenZipkin

Download zipkin-sparkstreaming-autoconfigure-stream-kinesis

How to add to project

<!-- https://jarcasting.com/artifacts/io.zipkin.aws/zipkin-sparkstreaming-autoconfigure-stream-kinesis/ -->
<dependency>
    <groupId>io.zipkin.aws</groupId>
    <artifactId>zipkin-sparkstreaming-autoconfigure-stream-kinesis</artifactId>
    <version>0.9.0</version>
</dependency>
// https://jarcasting.com/artifacts/io.zipkin.aws/zipkin-sparkstreaming-autoconfigure-stream-kinesis/
implementation 'io.zipkin.aws:zipkin-sparkstreaming-autoconfigure-stream-kinesis:0.9.0'
// https://jarcasting.com/artifacts/io.zipkin.aws/zipkin-sparkstreaming-autoconfigure-stream-kinesis/
implementation ("io.zipkin.aws:zipkin-sparkstreaming-autoconfigure-stream-kinesis:0.9.0")
'io.zipkin.aws:zipkin-sparkstreaming-autoconfigure-stream-kinesis:jar:0.9.0'
<dependency org="io.zipkin.aws" name="zipkin-sparkstreaming-autoconfigure-stream-kinesis" rev="0.9.0">
  <artifact name="zipkin-sparkstreaming-autoconfigure-stream-kinesis" type="jar" />
</dependency>
@Grapes(
@Grab(group='io.zipkin.aws', module='zipkin-sparkstreaming-autoconfigure-stream-kinesis', version='0.9.0')
)
libraryDependencies += "io.zipkin.aws" % "zipkin-sparkstreaming-autoconfigure-stream-kinesis" % "0.9.0"
[io.zipkin.aws/zipkin-sparkstreaming-autoconfigure-stream-kinesis "0.9.0"]

Dependencies

compile (4)

Group / Artifact Type Version
io.zipkin.aws : zipkin-sparkstreaming-stream-kinesis jar 0.9.0
org.springframework.boot : spring-boot-autoconfigure jar
org.springframework.boot : spring-boot-test jar
io.zipkin.zipkin2 : zipkin jar 2.7.0

provided (1)

Group / Artifact Type Version
com.google.auto.value : auto-value jar 1.5.3

test (3)

Group / Artifact Type Version
junit : junit jar 4.12
org.assertj : assertj-core jar 3.9.0
ch.qos.logback : logback-classic jar 1.2.2

Project Modules

There are no modules declared in this project.

zipkin-aws

Gitter chat Build Status Maven Central

Shared libraries that provide Zipkin integration with AWS Kinesis, SQS, and X-Ray. Requires JRE 8 or later.

Usage

These components provide Zipkin Reporters and Senders, which build off interfaces provided by the zipkin-reporters-java, and and Collectors, which are used in a Zipkin server.

We also have tracing libraries that extend Brave.

Tracing libraries

Tracing libraries extend Brave and ensure Amazon libraries are visible in your traces.

Instrumentation Description
AWS SDK Traces AmazonWebServiceClient
AWS SDK V2 Traces SdkClient
AWS SQS Messaging Traces AmazonSQS

We also have a library to read Amazon's trace header.

Reporters and Senders

The component in a traced application that sends timing data (spans) out of process is called a Reporter. It is responsible for handling the queueing and encoding of outbound spans.

Reporters that are sending Zipkin data to Zipkin typically make use of a Sender, which implements the wire protocol to a particular technology used to send the encoded spans. Typically Senders are called on interval by an async reporter.

NOTE: Applications can be written in any language. While we currently only have Reporters and Senders in Java, senders in other languages are welcome.

Reporter Description
X-Ray UDP Reports spans to X-Ray, AWS's alternative to Zipkin.
Sender Description
SQS Sends tracing data to Zipkin using SQS, a message queue service.
SQS v2 Sends tracing data to Zipkin using SQS, a message queue service.
Kinesis Sends tracing data to Zipkin using Kinesis, an alternative similar to Kafka.

Collectors

The component in a zipkin server that receives trace data is called a collector. This decodes spans reported by applications and persists them to a configured storage component.

Collector Description
SQS An alternative to Kafka.
Kinesis An alternative to Kafka.

Server integration

Integration with Zipkin server is done for you in [Docker][docker]. If you cannot use Docker, you can integrate a Java module instead.

Configuration layered over Zipkin server is documented here.

Artifacts

All artifacts publish to the group ID "io.zipkin.aws". We use a common release version for all components.

Library Releases

Releases are at Sonatype and Maven Central

Library Snapshots

Snapshots are uploaded to Sonatype after commits to master.

Docker Images

Released versions of zipkin-aws are published to Docker Hub as openzipkin/zipkin-aws and GitHub Container Registry as ghcr.io/openzipkin/zipkin-aws.

See docker for details.

io.zipkin.aws

Open Zipkin

Versions

Version
0.9.0
0.8.11
0.8.10
0.8.9
0.8.8
0.8.7
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.1
0.7.0
0.6.1
0.6.0
0.5.2
0.5.1
0.5.0
0.4.2
0.4.1
0.4.0
0.3.2
0.3.1
0.3.0
0.2.5
0.2.4
0.2.3
0.2.2
0.2.1
0.2.0