astubbs/parallel-consumer - 6 Help Wanted Issues

Open Issues Need Help

upstream #266: feature: Option for batch to only contain messages of the same key 43 minutes ago

enhancement good first issue upstream-mirror area/batching-ordering

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

Java

upstream #640: Error log to verbose in AbstractParallelEoSStreamProcessor about 1 hour ago

enhancement good first issue 0.6.0.0 upstream-mirror area/observability

astubbs/parallel-consumer

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

Java

upstream #631: Warning log to verbose in RemovedPartitionState about 1 hour ago

enhancement good first issue 0.6.0.0 upstream-mirror area/observability

astubbs/parallel-consumer

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

Java

upstream #622: Wrong multiplier value in retry delay function example about 1 hour ago

bug good first issue 0.6.0.0 upstream-mirror area/docs

astubbs/parallel-consumer

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

Java

upstream #629: Missing topic and offset infos when login error in ConsumerOffsetCommitter about 2 hours ago

enhancement good first issue upstream-mirror area/observability

astubbs/parallel-consumer

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

Java

upstream #180: vertxHttpReqInfo only supports GET (Unable to call HTTP POST or PUT etc) about 2 hours ago

help wanted question upstream-mirror area/modules

astubbs/parallel-consumer

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

Java