parallel-consumer-core
Used in:
components
- OverviewOverview
- VersionsVersions
- DependentsDependents
- DependenciesDependencies
<dependency> <groupId>io.confluent.parallelconsumer</groupId> <artifactId>parallel-consumer-core</artifactId> <version>0.5.3.2</version> </dependency>
<?xml version="1.0" encoding="UTF-8"?> <!-- Copyright (C) 2020-2024 Confluent, Inc. --> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> <groupId>io.confluent.parallelconsumer</groupId> <artifactId>parallel-consumer-parent</artifactId> <version>0.5.3.2</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>parallel-consumer-core</artifactId> <name>Confluent Parallel Consumer Core</name> <dependencies> <!-- Main --> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>${kafka.version}</version> </dependency> <dependency> <groupId>com.github.luben</groupId> <artifactId>zstd-jni</artifactId> <version>1.5.5-4</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.xerial.snappy</groupId> <artifactId>snappy-java</artifactId> <version>1.1.10.5</version> <scope>compile</scope> </dependency> <dependency> <groupId>io.micrometer</groupId> <artifactId>micrometer-core</artifactId> <scope>compile</scope> </dependency> <!-- Testing --> <dependency> <groupId>org.awaitility</groupId> <artifactId>awaitility</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.junit.jupiter</groupId> <artifactId>junit-jupiter-params</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.junit-pioneer</groupId> <artifactId>junit-pioneer</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.testcontainers</groupId> <artifactId>testcontainers</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.testcontainers</groupId> <artifactId>kafka</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.testcontainers</groupId> <artifactId>junit-jupiter</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>me.tongfei</groupId> <artifactId>progressbar</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.testcontainers</groupId> <artifactId>postgresql</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.postgresql</groupId> <artifactId>postgresql</artifactId> <version>42.7.1</version> <scope>test</scope> </dependency> <dependency> <groupId>com.github.tomakehurst</groupId> <artifactId>wiremock-jre8</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.threeten</groupId> <artifactId>threeten-extra</artifactId> <version>1.7.2</version> <scope>test</scope> </dependency> <dependency> <groupId>io.stubbs.truth</groupId> <artifactId>truth-generator-api</artifactId> <version>${truth-generator-maven-plugin.version}</version> <scope>test</scope> </dependency> <dependency> <groupId>uk.co.jemos.podam</groupId> <artifactId>podam</artifactId> <version>8.0.1.RELEASE</version> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>io.stubbs.truth</groupId> <artifactId>truth-generator-maven-plugin</artifactId> <version>${truth-generator-maven-plugin.version}</version> <configuration> <cleanTargetDir>false</cleanTargetDir> <useHas>false</useHas> <useGetterForLegacyClasses>true</useGetterForLegacyClasses> <releaseTarget>8</releaseTarget> <classes> <class>io.confluent.parallelconsumer.PollContext</class> <class>io.confluent.parallelconsumer.ParallelEoSStreamProcessor</class> <class>io.confluent.parallelconsumer.internal.ProducerManager</class> <class>io.confluent.parallelconsumer.state.WorkContainer</class> <class>io.confluent.parallelconsumer.state.WorkManager</class> <class>io.confluent.parallelconsumer.state.PartitionState</class> <class>io.confluent.parallelconsumer.state.ProcessingShard</class> <class>io.confluent.parallelconsumer.state.ShardKey</class> <class>io.confluent.parallelconsumer.offsets.OffsetEncoding</class> </classes> <legacyClasses> <!-- todo check legacy is recursive --> <class>org.apache.kafka.clients.consumer.OffsetAndMetadata</class> <class>org.apache.kafka.clients.consumer.ConsumerRecord</class> <class>org.apache.kafka.clients.consumer.ConsumerRecords</class> <class>org.apache.kafka.clients.consumer.Consumer</class> <class>org.apache.kafka.clients.producer.RecordMetadata</class> <class>org.apache.kafka.clients.producer.ProducerRecord</class> <class>org.apache.kafka.clients.producer.Producer</class> </legacyClasses> <entryPointClassPackage>io.confluent.parallelconsumer</entryPointClassPackage> </configuration> <executions> <execution> <phase>generate-test-sources</phase> <goals> <goal>generate</goal> </goals> </execution> </executions> </plugin> </plugins> </build> </project>