Мне нужно прочитать файлы свойств в мое задание spark, используя обычный java, т.е. java1.8v & snake yml jar.
Эта искровая работа - потребитель кафки.
Вместо того, чтобы иметь отдельные файлы свойств для потребителя и производителя, я хочу использовать один и тот же файл @Consumer и @Producer, как показано ниже.
common:
kafka:
bootstrapServers: localhost:9092
autoOffsetReset: latest
enableAutoCommit: true
infoTopic: inbound_info
consumer:
kafka:
groupId: ProcessingGroup
producer:
kafka:
partitioner: hashPartitionerVal
будет считан общий блок commonConfig, а потребительский блок будет считан в bean-компонент customerConfig.
Итак, как читать потребительский блок в классе ConsumerConfig, если он такой, как показано ниже
class ConsumerConfig{
private String groupId;
// getter setters
}