我在用 kafka-connect-elasticsearch 使用自定义转换器，扩展标准 org.apache.kafka.connect.json.JsonConverter .
在我的自定义转换器中，我需要访问一个环境变量。
让我们假设，我需要在每条消息后面附加集群的名称，该名称被写入环境变量 CLUSTER .
如何访问转换器中的环境变量？
可能在转换器配置阶段读取( configure(Map<String, ?> configs) 方法）？
我怎样才能前进 CLUSTER env变量值 configs Map？