From 9471ac754589cbeaf7494f5ebc2bea7113edf04d Mon Sep 17 00:00:00 2001 From: Boyang Jerry Peng Date: Thu, 27 Aug 2020 22:15:01 -0700 Subject: [PATCH] Add hostname to consumer/producer properties in Pulsar Functions (#7897) Co-authored-by: Jerry Peng --- .../apache/pulsar/functions/instance/InstanceUtils.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java index d34436448b9..3d4aa1034e3 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java @@ -23,6 +23,7 @@ import static org.apache.commons.lang3.StringUtils.isEmpty; import lombok.experimental.UtilityClass; +import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.functions.api.SerDe; @@ -33,9 +34,12 @@ import org.apache.pulsar.common.util.Reflections; import net.jodah.typetools.TypeResolver; import org.apache.pulsar.functions.utils.FunctionCommon; +import java.net.InetAddress; +import java.net.UnknownHostException; import java.util.HashMap; import java.util.Map; +@Slf4j @UtilityClass public class InstanceUtils { public static SerDe initializeSerDe(String serdeClassName, ClassLoader clsLoader, Class typeArg, @@ -134,6 +138,11 @@ public class InstanceUtils { } properties.put("id", fullyQualifiedName); properties.put("instance_id", String.valueOf(instanceId)); + try { + properties.put("instance_hostname", InetAddress.getLocalHost().getHostName()); + } catch (UnknownHostException e) { + log.warn("[{}:{}] Failed to get hostname of instance", fullyQualifiedName, instanceId, e); + } return properties; } } -- GitLab