is not current version
Last Version 0.5.1.0

Confluent Parallel Consumer Example - Streams 0.4.0.1

Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

License

License

GroupId

GroupId

io.confluent.parallelconsumer
ArtifactId

ArtifactId

parallel-consumer-example-streams
Version

Version

0.4.0.1
Type

Type

jar
Description

Description

Confluent Parallel Consumer Example - Streams
Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.
Project Organization

Project Organization

Confluent, Inc.

Download parallel-consumer-example-streams 0.4.0.1


<!-- https://jarcasting.com/artifacts/io.confluent.parallelconsumer/parallel-consumer-example-streams/ -->
<dependency>
    <groupId>io.confluent.parallelconsumer</groupId>
    <artifactId>parallel-consumer-example-streams</artifactId>
    <version>0.4.0.1</version>
</dependency>
// https://jarcasting.com/artifacts/io.confluent.parallelconsumer/parallel-consumer-example-streams/
implementation 'io.confluent.parallelconsumer:parallel-consumer-example-streams:0.4.0.1'
// https://jarcasting.com/artifacts/io.confluent.parallelconsumer/parallel-consumer-example-streams/
implementation ("io.confluent.parallelconsumer:parallel-consumer-example-streams:0.4.0.1")
'io.confluent.parallelconsumer:parallel-consumer-example-streams:jar:0.4.0.1'
<dependency org="io.confluent.parallelconsumer" name="parallel-consumer-example-streams" rev="0.4.0.1">
  <artifact name="parallel-consumer-example-streams" type="jar" />
</dependency>
@Grapes(
@Grab(group='io.confluent.parallelconsumer', module='parallel-consumer-example-streams', version='0.4.0.1')
)
libraryDependencies += "io.confluent.parallelconsumer" % "parallel-consumer-example-streams" % "0.4.0.1"
[io.confluent.parallelconsumer/parallel-consumer-example-streams "0.4.0.1"]

Dependencies

compile (7)

Group / Artifact Type Version
io.confluent.parallelconsumer : parallel-consumer-core jar 0.4.0.1
org.apache.kafka : kafka-streams jar 2.8.0
org.apache.commons : commons-lang3 jar 3.11
com.github.bsideup.jabel : jabel-javac-plugin jar 0.3.0
org.slf4j : slf4j-api jar 1.7.30
pl.tlinkowski.unij : pl.tlinkowski.unij.api jar 0.1.3
pl.tlinkowski.unij : pl.tlinkowski.unij.bundle.jdk8 jar 0.1.3

provided (1)

Group / Artifact Type Version
org.projectlombok : lombok jar 1.18.16

test (14)

Group / Artifact Type Version
org.apache.kafka : kafka-streams-test-utils jar 2.8.0
org.awaitility : awaitility jar 4.1.0
io.confluent.parallelconsumer : parallel-consumer-core jar 0.4.0.1
org.testcontainers : testcontainers jar 1.15.3
org.testcontainers : junit-jupiter jar 1.15.3
org.testcontainers : kafka jar 1.15.3
ch.qos.logback : logback-classic jar 1.2.3
org.junit.jupiter : junit-jupiter-api jar 5.7.0
org.junit.jupiter : junit-jupiter-engine jar 5.7.0
org.junit.platform : junit-platform-launcher jar 1.7.0
org.junit.platform : junit-platform-commons jar 1.7.0
org.assertj : assertj-core jar 3.18.0
org.mockito : mockito-core jar 3.6.0
com.google.auto.service : auto-service-annotations jar 1.0-rc7

Project Modules

There are no modules declared in this project.