Skip to content

Commit

Permalink
MOR-188 : Equals check for kafka auto commit corrected (#1644)
Browse files Browse the repository at this point in the history
  • Loading branch information
vishwa-vyom authored Dec 19, 2022
1 parent e110c15 commit 90419ee
Show file tree
Hide file tree
Showing 25 changed files with 59 additions and 59 deletions.
16 changes: 8 additions & 8 deletions registration-processor/core-processor/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,13 @@
</properties>
<modules>
<module>registration-processor-demo-dedupe-stage</module>
<!-- <module>registration-processor-bio-dedupe-stage</module>-->
<!-- <module>registration-processor-uin-generator-stage</module> -->
<!-- <module>registration-processor-abis</module> -->
<!-- <module>registration-processor-manual-verification-stage</module>-->
<!-- <module>registration-processor-reprocessor-stage</module>-->
<!-- <module>registration-processor-abis-handler-stage</module>-->
<!--<module>registration-processor-abis-middleware-stage</module>-->
<!--<module>registration-processor-biometric-authentication-stage</module>-->
<module>registration-processor-bio-dedupe-stage</module>
<module>registration-processor-uin-generator-stage</module>
<!-- <module>registration-processor-abis</module> -->
<module>registration-processor-manual-verification-stage</module>
<module>registration-processor-reprocessor-stage</module>
<module>registration-processor-abis-handler-stage</module>
<module>registration-processor-abis-middleware-stage</module>
<module>registration-processor-biometric-authentication-stage</module>
</modules>
</project>
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>core-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>

<artifactId>registration-processor-abis-handler-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>core-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-abis-middleware-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>core-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>

<artifactId>registration-processor-bio-dedupe-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>core-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-biometric-authentication-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,11 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>core-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>

<artifactId>registration-processor-manual-verification-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>core-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-reprocessor-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<name>registration-processor-reprocessor-stage</name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>core-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-uin-generator-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
4 changes: 2 additions & 2 deletions registration-processor/init/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,14 +6,14 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>registration-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>init</artifactId>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<modules>
<module>registration-processor-packet-receiver-stage</module>
<module>registration-processor-registration-status-service</module>
<!-- <module>registration-processor-registration-status-service</module> -->
</modules>
</project>
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,11 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>init</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>

<artifactId>registration-processor-packet-receiver-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<name>registration-processor-packet-receiver-stage</name>

<properties>
Expand Down
12 changes: 6 additions & 6 deletions registration-processor/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@

<!-- local -->
<registration.status.service.version>1.1.5.5-P1</registration.status.service.version>
<registration.processor.core.version>1.1.5.5</registration.processor.core.version>
<registration.processor.core.version>1.1.5.5-P2</registration.processor.core.version>
<packet.manager.version>1.1.5.5</packet.manager.version>
<registration.processor.rest.client.version>1.1.5.5-P1</registration.processor.rest.client.version>
<packet.info.storage.service.version>1.1.5.5</packet.info.storage.service.version>
Expand Down Expand Up @@ -310,19 +310,19 @@
</dependencyManagement>

<modules>
<!-- <module>registration-processor-core</module> -->
<module>registration-processor-core</module>
<!--<module>registration-processor-rest-client</module>-->
<!-- <module>registration-processor-packet-manager</module> -->
<!--<module>registration-processor-common-camel-bridge</module>-->
<module>registration-processor-common-camel-bridge</module>
<!-- <module>registration-processor-bio-dedupe-service-impl</module>-->
<!--<module>registration-processor-info-storage-service</module> -->
<!--<module>registration-processor-registration-status-service-impl</module>-->
<!-- <module>registration-processor-quality-checker</module> -->
<!-- <module>registration-processor-message-sender-impl</module> -->
<!--<module>init</module>-->
<!--<module>pre-processor</module>-->
<module>init</module>
<module>pre-processor</module>
<module>core-processor</module>
<!--<module>post-processor</module>-->
<module>post-processor</module>
</modules>

<!-- <profiles>
Expand Down
4 changes: 2 additions & 2 deletions registration-processor/post-processor/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>registration-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<artifactId>post-processor</artifactId>
<name>post-processor</name>
<properties>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,11 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>post-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>

<artifactId>registration-processor-message-sender-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>post-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-printing-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
4 changes: 2 additions & 2 deletions registration-processor/pre-processor/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,9 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>registration-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<artifactId>pre-processor</artifactId>
<name>pre-processor</name>
<properties>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>pre-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>

<artifactId>registration-processor-external-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>pre-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-osi-validator-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>pre-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-packet-classifier-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,9 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>pre-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>pre-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-packet-validator-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>pre-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>

<artifactId>registration-processor-quality-checker-stage</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@
<parent>
<artifactId>pre-processor</artifactId>
<groupId>io.mosip.registrationprocessor</groupId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>

<artifactId>registration-processor-securezone-notification-stage</artifactId>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>registration-processor</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-common-camel-bridge</artifactId>
<version>1.1.5.5-P1</version>
<version>1.1.5.5-P2</version>
<packaging>jar</packaging>

<properties>
Expand Down
4 changes: 2 additions & 2 deletions registration-processor/registration-processor-core/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@
<parent>
<groupId>io.mosip.registrationprocessor</groupId>
<artifactId>registration-processor</artifactId>
<version>1.1.5.5</version>
<version>1.1.5.5-P2</version>
</parent>
<artifactId>registration-processor-core</artifactId>
<version>1.1.5.5</version>
<version>1.1.5.5-P2</version>
<dependencies>
<dependency>
<groupId>org.mockito</groupId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ public KafkaMosipEventBus(Vertx vertx, String bootstrapServers, String groupId,
consumerConfig.put("group.id", groupId);
consumerConfig.put("auto.offset.reset", "latest");
consumerConfig.put("max.poll.records", maxPollRecords);
if (commitType == "auto")
if (commitType.equals("auto"))
consumerConfig.put("enable.auto.commit", "true");
else
consumerConfig.put("enable.auto.commit", "false");
Expand Down

0 comments on commit 90419ee

Please sign in to comment.