在运行时在 kafka 主题上添加前缀/后缀

Question

所以这里假设如果环境是 TEST1 并且主题名称是 BENEFIT 那么它应该像 TEST1_BENEFIT 一样返回

object hello {
def Complete (jobId: BigInt, tableName: String, topic: String = configManager.getString("Kafka.Completion.Table.Topic")): Unit = {
val kafkaServer = configManager.getString("Kafka.Server")
val props = new Properties()
props.put("bootstrap.servers", kafkaServer)
props.put("key.serializer")
props.put("value.serializer")
props.put("batch.size", "1")
props.put("acks", "all")
val producer = new KafkaProducer[String, String](props)
val message = new ProducerRecord[String, String](topic, key, value)
producer.send(message)
}
}

Answer 1

作为answered before，使用字符串插值或串联

val message = new ProducerRecord[String, String](s"${environment}_${topic}", key, value)