(beam) branch master updated: revert kafka host change (#29725)

[yhu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 5d42cb654c0 revert kafka host change (#29725)
5d42cb654c0 is described below

commit 5d42cb654c08508125abd0a038acd97248298dfa
Author: johnjcasey <95318300+johnjca...@users.noreply.github.com>
AuthorDate: Wed Dec 13 09:21:58 2023 -0500

    revert kafka host change (#29725)
---
 .../java/src/main/java/org/apache/beam/examples/KafkaStreaming.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/examples/java/src/main/java/org/apache/beam/examples/KafkaStreaming.java 
b/examples/java/src/main/java/org/apache/beam/examples/KafkaStreaming.java
index 602c34d4219..5bad7911e64 100644
--- a/examples/java/src/main/java/org/apache/beam/examples/KafkaStreaming.java
+++ b/examples/java/src/main/java/org/apache/beam/examples/KafkaStreaming.java
@@ -102,7 +102,7 @@ public class KafkaStreaming {
      * to use your own Kafka server.
      */
     @Description("Kafka server host")
-    @Default.String("localhost:9092")
+    @Default.String("kafka_server:9092")
     String getKafkaHost();
 
     void setKafkaHost(String value);