Skip to content

Bugfix/spring upgrade #217

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Michael7371 merged 11 commits into from
Sep 4, 2025
Merged

Bugfix/spring upgrade #217

Show file tree
Hide file tree
Changes from 6 commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
6f0ef45
updating spring boot version to 3.5.4 and fixing kafka embedded kafka…
Michael7371 Aug 14, 2025
9e59c46
fixing asn1 encoded data router unit tests
Michael7371 Aug 15, 2025
193b766
updates to unit tests with updated spring boot version
Michael7371 Aug 19, 2025
eb2e378
fix error in AbstractUdpReceiverPublisher
Michael7371 Aug 19, 2025
9cd1efc
adding ssl bean to tests
Michael7371 Aug 20, 2025
a20b631
chore: checkstyle updates
Michael7371 Aug 21, 2025
9514d35
reverting ssl config
Michael7371 Aug 24, 2025
b2a83c7
reverting formatting changes
Michael7371 Aug 28, 2025
d9c8887
reverting formatting changes to the asn1encodeddatarouter
Michael7371 Aug 28, 2025
600c3be
reverting changes to application.yml
Michael7371 Aug 29, 2025
af5fcbe
removal of redundant start check in embedded kafka getter
Michael7371 Sep 2, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 6 additions & 9 deletions jpo-ode-core/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<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">
<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">
<modelVersion>4.0.0</modelVersion>

<parent>
Expand Down Expand Up @@ -37,19 +39,13 @@
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.14</version>
</dependency>

<dependency>
<groupId>io.dropwizard.metrics</groupId>
<artifactId>metrics-core</artifactId>
</dependency>
<dependency>
<groupId>io.dropwizard.metrics</groupId>
<artifactId>metrics-graphite</artifactId>
</dependency>
<dependency>
<groupId>com.sun.jersey</groupId>
<artifactId>jersey-core</artifactId>
<version>1.19.4</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
Expand Down Expand Up @@ -89,6 +85,7 @@
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.15.1</version>
</dependency>
<dependency>
<groupId>com.networknt</groupId>
Expand Down
45 changes: 25 additions & 20 deletions jpo-ode-svcs/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<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">
<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">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>usdot.jpo.ode</groupId>
Expand Down Expand Up @@ -32,10 +34,10 @@
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>com.vaadin.external.google</groupId>
<artifactId>android-json</artifactId>
<groupId>com.vaadin.external.google</groupId>
<artifactId>android-json</artifactId>
</exclusion>
</exclusions>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
Expand All @@ -46,9 +48,9 @@
<artifactId>spring-boot-starter-data-rest</artifactId>
</dependency>
<dependency>
<groupId>jakarta.xml.bind</groupId>
<artifactId>jakarta.xml.bind-api</artifactId>
<version>4.0.0</version>
<groupId>jakarta.xml.bind</groupId>
<artifactId>jakarta.xml.bind-api</artifactId>
<version>4.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
Expand Down Expand Up @@ -99,7 +101,7 @@
<dependency>
<groupId>org.webjars</groupId>
<artifactId>webjars-locator</artifactId>
<version>0.40</version>
<version>0.40</version>
</dependency>
<dependency>
<groupId>org.webjars</groupId>
Expand All @@ -114,6 +116,7 @@
<dependency>
<groupId>org.webjars</groupId>
<artifactId>jquery</artifactId>
<version>3.7.1</version>
</dependency>
<dependency>
<groupId>org.webjars</groupId>
Expand Down Expand Up @@ -146,9 +149,9 @@
<version>2.1.1</version>
</dependency>
<dependency>
<groupId>javax.annotation</groupId>
<artifactId>javax.annotation-api</artifactId>
<version>1.3.2</version>
<groupId>javax.annotation</groupId>
<artifactId>javax.annotation-api</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>com.networknt</groupId>
Expand Down Expand Up @@ -185,17 +188,19 @@
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<executions>
<execution>
<id>build-info</id>
<goals>
<goal>build-info</goal>
</goals>
</execution>
</executions>
<execution>
<id>build-info</id>
<goals>
<goal>build-info</goal>
</goals>
</execution>
</executions>
</plugin>

</plugins>
</build>
<!-- profile to output only source code and not include any spring boot dependencies in published jar -->
<!-- profile to output only source code and not include any spring boot dependencies in published
jar -->
<profiles>
<profile>
<id>package-jar</id>
Expand Down Expand Up @@ -229,4 +234,4 @@
</build>
</profile>
</profiles>
</project>
</project>
28 changes: 16 additions & 12 deletions jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/kafka/KafkaConsumerConfig.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
import java.util.Map;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
import org.springframework.boot.ssl.SslBundles;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.EnableKafka;
Expand All @@ -24,28 +25,31 @@ public class KafkaConsumerConfig {

private final KafkaProperties kafkaProperties;
private final OdeKafkaProperties odeKafkaProperties;
private final SslBundles sslBundles;

/**
* Constructs a new instance of KafkaConsumerConfig with the specified Kafka properties.
*
* @param kafkaProperties The general Kafka properties used for configuring consumer settings.
* @param kafkaProperties The general Kafka properties used for configuring consumer settings.
* @param odeKafkaProperties The specific Ode Kafka properties which may include custom
* configurations relevant to the Ode system, possibly including
* brokers and other kafka-specific settings.
* configurations relevant to the Ode system, possibly including brokers and other
* kafka-specific settings.
* @param sslBundles The SSL bundles for secure connections.
*/
public KafkaConsumerConfig(KafkaProperties kafkaProperties,
OdeKafkaProperties odeKafkaProperties) {
public KafkaConsumerConfig(KafkaProperties kafkaProperties, OdeKafkaProperties odeKafkaProperties,
SslBundles sslBundles) {
this.kafkaProperties = kafkaProperties;
this.odeKafkaProperties = odeKafkaProperties;
this.sslBundles = sslBundles;
}

/**
* Creates and configures a {@link ConsumerFactory} for Kafka consumers with String key and
* value deserialization. The factory is configured using Kafka consumer properties defined
* in the application configuration.
* Creates and configures a {@link ConsumerFactory} for Kafka consumers with String key and value
* deserialization. The factory is configured using Kafka consumer properties defined in the
* application configuration.
*
* @return a {@link ConsumerFactory} instance configured to produce Kafka consumers with
* String key and value serialization.
* @return a {@link ConsumerFactory} instance configured to produce Kafka consumers with String
* key and value serialization.
*/
@Bean
public ConsumerFactory<String, String> consumerFactory() {
Expand All @@ -58,7 +62,7 @@ public ConsumerFactory<String, String> consumerFactory() {
* from Kafka topics.
*
* @return a ConcurrentKafkaListenerContainerFactory setup with a defined consumer factory that
* determines how Kafka consumers are created and configured.
* determines how Kafka consumers are created and configured.
*/
@Bean
public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
Expand All @@ -69,7 +73,7 @@ public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerCont
}

private Map<String, Object> getKafkaConsumerProperties() {
Map<String, Object> props = new HashMap<>(kafkaProperties.buildConsumerProperties());
Map<String, Object> props = new HashMap<>(kafkaProperties.buildConsumerProperties(sslBundles));
if ("CONFLUENT".equals(this.odeKafkaProperties.getKafkaType())) {
props.putAll(this.odeKafkaProperties.getConfluent().buildConfluentProperties());
}
Expand Down
Loading