(airavata) branch master updated: fix: read the canonical kafka.broker.url key in KafkaProxyService (#641)

[yasith]

This is an automated email from the ASF dual-hosted git repository.

yasithdev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/master by this push:
     new bfa377caad fix: read the canonical kafka.broker.url key in 
KafkaProxyService (#641)
bfa377caad is described below

commit bfa377caad50d22b3c5a2e4f7239809db08f1b3b
Author: Yasith Jayawardana <yas...@gatech.edu>
AuthorDate: Sun Jun 7 21:18:20 2026 -0400

    fix: read the canonical kafka.broker.url key in KafkaProxyService (#641)
    
    KafkaProxyService injected ${airavata.kafka.broker-url}, a hyphenated key 
set only by the local Tilt/DinD compose file; real deployments 
(application.properties, ansible) define kafka.broker.url, so the proxy 
silently fell back to localhost:9092. Point the @Value at kafka.broker.url and 
drop the now-redundant -Dairavata.kafka.broker-url override from compose.yml.
---
 .../main/java/org/apache/airavata/server/kafka/KafkaProxyService.java   | 2 +-
 compose.yml                                                             | 1 -
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/airavata-server/src/main/java/org/apache/airavata/server/kafka/KafkaProxyService.java
 
b/airavata-server/src/main/java/org/apache/airavata/server/kafka/KafkaProxyService.java
index f5264c36c6..53fc7957ec 100644
--- 
a/airavata-server/src/main/java/org/apache/airavata/server/kafka/KafkaProxyService.java
+++ 
b/airavata-server/src/main/java/org/apache/airavata/server/kafka/KafkaProxyService.java
@@ -40,7 +40,7 @@ public class KafkaProxyService {
 
     private final KafkaProducer<String, String> producer;
 
-    public 
KafkaProxyService(@Value("${airavata.kafka.broker-url:localhost:9092}") String 
brokerUrl) {
+    public KafkaProxyService(@Value("${kafka.broker.url:localhost:9092}") 
String brokerUrl) {
         Properties props = new Properties();
         props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, brokerUrl);
         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, 
StringSerializer.class.getName());
diff --git a/compose.yml b/compose.yml
index 7b7bce9a7e..4a0aebed03 100644
--- a/compose.yml
+++ b/compose.yml
@@ -194,7 +194,6 @@ services:
       JAVA_TOOL_OPTIONS: >-
         -Dspring.datasource.url=jdbc:mariadb://db:3306/airavata
         -Dkafka.broker.url=kafka:9092
-        -Dairavata.kafka.broker-url=kafka:9092
         -Drabbitmq.broker.url=amqp://airavata:airavata@rabbitmq:5672
         -Dspring.rabbitmq.host=rabbitmq
         -Dspring.rabbitmq.port=5672