как создать слушателей кафки и динамически добавлять их в весенний контекст - PullRequest
0 голосов
/ 15 марта 2020

привет, я разрабатываю groovy dsl, который позволяет динамически создавать потребителей kafka с пружинной загрузкой, например, я могу написать.

consumer("topic1","group_id_1"){
//
}
consumer("topic2","group_id_2"){
//
}

и из этого кода я динамически создаю двух потребителей kafka, потребитель к topi c «topic1» с идентификатором группы «group_id_1» и потребителем в направлении topi c «topi c 2» и с идентификатором группы «group_id_2» и добавьте этих двух потребителей в контекстное приложение весны.

...