io.confluent.parallelconsumer parallel-consumer-parent 0.5.3.3 4.0.0 parallel-consumer-core Confluent Parallel Consumer Core org.apache.kafka kafka-clients ${kafka.version} com.github.luben zstd-jni 1.5.5-4 compile org.xerial.snappy snappy-java 1.1.10.5 compile io.micrometer micrometer-core compile org.awaitility awaitility test org.junit.jupiter junit-jupiter-params test org.junit-pioneer junit-pioneer test org.testcontainers testcontainers test org.testcontainers kafka test org.testcontainers junit-jupiter test org.apache.commons commons-lang3 test me.tongfei progressbar test org.testcontainers postgresql test org.postgresql postgresql 42.7.1 test com.github.tomakehurst wiremock-jre8 test org.threeten threeten-extra 1.7.2 test io.stubbs.truth truth-generator-api ${truth-generator-maven-plugin.version} test uk.co.jemos.podam podam 8.0.1.RELEASE test io.stubbs.truth truth-generator-maven-plugin ${truth-generator-maven-plugin.version} false false true 8 io.confluent.parallelconsumer.PollContext io.confluent.parallelconsumer.ParallelEoSStreamProcessor io.confluent.parallelconsumer.internal.ProducerManager io.confluent.parallelconsumer.state.WorkContainer io.confluent.parallelconsumer.state.WorkManager io.confluent.parallelconsumer.state.PartitionState io.confluent.parallelconsumer.state.ProcessingShard io.confluent.parallelconsumer.state.ShardKey io.confluent.parallelconsumer.offsets.OffsetEncoding org.apache.kafka.clients.consumer.OffsetAndMetadata org.apache.kafka.clients.consumer.ConsumerRecord org.apache.kafka.clients.consumer.ConsumerRecords org.apache.kafka.clients.consumer.Consumer org.apache.kafka.clients.producer.RecordMetadata org.apache.kafka.clients.producer.ProducerRecord org.apache.kafka.clients.producer.Producer io.confluent.parallelconsumer generate-test-sources generate