Confluent Parallel Consumer Vert.x

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-vertx
Last Version

Last Version

0.5.1.0
Release Date

Release Date

Type

Type

jar
Description

Description

Confluent Parallel Consumer Vert.x
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-vertx

How to add to project

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

Dependencies

compile (7)

Group / Artifact Type Version
io.confluent.parallelconsumer : parallel-consumer-core jar 0.5.1.0
io.vertx : vertx-web-client jar 4.3.0
com.google.guava : guava jar 31.1-jre
org.slf4j : slf4j-api jar 1.7.36
pl.tlinkowski.unij : pl.tlinkowski.unij.api jar 0.1.3
pl.tlinkowski.unij : pl.tlinkowski.unij.bundle.jdk8 jar 0.1.3
org.mockito : mockito-junit-jupiter jar 4.5.1

provided (2)

Group / Artifact Type Version
org.projectlombok : lombok jar 1.18.24
com.github.bsideup.jabel : jabel-javac-plugin jar 0.4.2

test (20)

Group / Artifact Type Version
io.confluent.parallelconsumer : parallel-consumer-core jar 0.5.1.0
io.vertx : vertx-junit5 jar 4.3.0
com.github.tomakehurst : wiremock jar 2.33.2
me.tongfei : progressbar jar 0.9.3
org.testcontainers : kafka jar 1.17.1
org.testcontainers : junit-jupiter jar 1.17.1
ch.qos.logback : logback-classic jar 1.2.11
org.junit.jupiter : junit-jupiter-api jar 5.8.2
org.junit.jupiter : junit-jupiter-engine jar 5.8.2
org.junit.platform : junit-platform-launcher jar 1.8.2
org.junit.platform : junit-platform-commons jar 1.8.2
org.assertj : assertj-core jar 3.22.0
org.mockito : mockito-core jar 4.5.1
com.google.auto.service : auto-service-annotations jar 1.0.1
com.google.truth : truth jar 1.1.3
com.google.truth.extensions : truth-java8-extension jar 1.1.3
org.awaitility : awaitility jar 4.2.0
com.google.flogger : flogger jar 0.7.4
com.google.flogger : flogger-slf4j-backend jar 0.7.4
one.util : streamex jar 0.8.1

Project Modules

There are no modules declared in this project.
io.confluent.parallelconsumer

Confluent Inc.

Real-time streams powered by Apache Kafka®

Versions

Version
0.5.1.0
0.5.0.0
0.4.0.1
0.4.0.0
0.3.2.0
0.3.1.0
0.3.0.3
0.3.0.2
0.3.0.1
0.3.0.0
0.2.0.3
0.2.0.2
0.2.0.1
0.2.0.0
0.1.0