See #469. Refactored.

j3-signalroom · Nov 18, 2024 · 5d5255f · 5d5255f
1 parent 00bc345
commit 5d5255f
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/java/app/src/main/java/kickstarter/AvroDataGeneratorApp.java b/java/app/src/main/java/kickstarter/AvroDataGeneratorApp.java
@@ -97,7 +97,7 @@ public static void main(String[] args) throws Exception {
 		 */
         DataStream<Properties> dataStreamProducerProperties = 
 			env.fromData(new Properties())
-			   .map(new ConfluentClientConfigurationLookup(false, serviceAccountUser))
+			   .map(new ConfluentClientConfigurationMapFunction(false, serviceAccountUser))
 			   .name("kafka_producer_properties");
 		Properties producerProperties = new Properties();
 

diff --git a/java/app/src/main/java/kickstarter/DataGeneratorApp.java b/java/app/src/main/java/kickstarter/DataGeneratorApp.java
@@ -90,7 +90,7 @@ public static void main(String[] args) throws Exception {
 		 */
         DataStream<Properties> dataStreamProducerProperties = 
 			env.fromData(new Properties())
-			   .map(new ConfluentClientConfigurationLookup(false, serviceAccountUser))
+			   .map(new ConfluentClientConfigurationMapFunction(false, serviceAccountUser))
 			   .name("kafka_producer_properties");
 		Properties producerProperties = new Properties();
 

diff --git a/java/app/src/main/java/kickstarter/FlightImporterApp.java b/java/app/src/main/java/kickstarter/FlightImporterApp.java
@@ -68,7 +68,7 @@ public static void main(String[] args) throws Exception {
 		 */
         DataStream<Properties> dataStreamConsumerProperties = 
 			env.fromData(new Properties())
-			   .map(new ConfluentClientConfigurationLookup(true, serviceAccountUser))
+			   .map(new ConfluentClientConfigurationMapFunction(true, serviceAccountUser))
 			   .name("kafka_consumer_properties");
 		Properties consumerProperties = new Properties();
 
@@ -97,7 +97,7 @@ public static void main(String[] args) throws Exception {
 		 */
         DataStream<Properties> dataStreamProducerProperties = 
 			env.fromData(new Properties())
-			   .map(new ConfluentClientConfigurationLookup(false, serviceAccountUser))
+			   .map(new ConfluentClientConfigurationMapFunction(false, serviceAccountUser))
 			   .name("kafka_producer_properties");
 		Properties producerProperties = new Properties();
 

diff --git a/java/app/src/main/java/kickstarter/FlyerStatsApp.java b/java/app/src/main/java/kickstarter/FlyerStatsApp.java
@@ -60,7 +60,7 @@ public static void main(String[] args) throws Exception {
 		 */
         DataStream<Properties> dataStreamConsumerProperties = 
 			env.fromData(new Properties())
-			   .map(new ConfluentClientConfigurationLookup(true, serviceAccountUser))
+			   .map(new ConfluentClientConfigurationMapFunction(true, serviceAccountUser))
 			   .name("kafka_consumer_properties");
 		Properties consumerProperties = new Properties();
 
@@ -93,7 +93,7 @@ public static void main(String[] args) throws Exception {
 		 */
         DataStream<Properties> dataStreamProducerProperties = 
 			env.fromData(new Properties())
-			   .map(new ConfluentClientConfigurationLookup(false, serviceAccountUser))
+			   .map(new ConfluentClientConfigurationMapFunction(false, serviceAccountUser))
 			   .name("kafka_producer_properties");
 		Properties producerProperties = new Properties();