Confluent Parallel Consumer Project Reactor.io

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

License	Apache License, Version 2.0
Categories	React User Interface Web Frameworks Reactor Container Microservices Reactive libraries
GroupId	io.confluent.parallelconsumer
ArtifactId	parallel-consumer-reactor
Last Version	0.5.1.0
Release Date	May 18, 2022
Type	jar
Description	Confluent Parallel Consumer Project Reactor.io 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	Confluent, Inc.

Download parallel-consumer-reactor

Filename	Size
parallel-consumer-reactor-0.5.1.0.pom
parallel-consumer-reactor-0.5.1.0.jar	5 KB
parallel-consumer-reactor-0.5.1.0-tests.jar	9 KB
parallel-consumer-reactor-0.5.1.0-sources.jar	2 KB
parallel-consumer-reactor-0.5.1.0-javadoc.jar	394 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/io.confluent.parallelconsumer/parallel-consumer-reactor/ -->
<dependency>
    <groupId>io.confluent.parallelconsumer</groupId>
    <artifactId>parallel-consumer-reactor</artifactId>
    <version>0.5.1.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/io.confluent.parallelconsumer/parallel-consumer-reactor/
implementation 'io.confluent.parallelconsumer:parallel-consumer-reactor:0.5.1.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/io.confluent.parallelconsumer/parallel-consumer-reactor/
implementation ("io.confluent.parallelconsumer:parallel-consumer-reactor:0.5.1.0")

Apache Buildr

'io.confluent.parallelconsumer:parallel-consumer-reactor:jar:0.5.1.0'

Apache Ivy

<dependency org="io.confluent.parallelconsumer" name="parallel-consumer-reactor" rev="0.5.1.0">
  <artifact name="parallel-consumer-reactor" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='io.confluent.parallelconsumer', module='parallel-consumer-reactor', version='0.5.1.0')
)

Scala SBT

libraryDependencies += "io.confluent.parallelconsumer" % "parallel-consumer-reactor" % "0.5.1.0"

Leiningen

[io.confluent.parallelconsumer/parallel-consumer-reactor "0.5.1.0"]

Dependencies

compile (7)

Group / Artifact	Type	Version
io.confluent.parallelconsumer : parallel-consumer-core	jar	0.5.1.0
io.projectreactor : reactor-core	jar	3.4.18
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 (18)

Group / Artifact	Type	Version
io.confluent.parallelconsumer : parallel-consumer-core	jar	0.5.1.0
me.tongfei : progressbar	jar	0.9.3
org.junit.jupiter : junit-jupiter-params	jar	5.8.2
org.junit-pioneer : junit-pioneer	jar	1.7.0
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.

Versions

Version
0.5.1.0 May 18, 2022
0.5.0.0 May 5, 2022
0.4.0.1 Sep 28, 2021
0.4.0.0 Sep 17, 2021