早上好.
我正在做一个Sping Boot 项目,其中已经实现了Kafka集成(一个Kafka消息生成器)。Kafka配置在www.example.com中完成application.properties,如下所示:
spring.kafka.bootstrap-servers=
spring.kafka.properties.sasl.jaas.config=
spring.kafka.properties.security.protocol=
spring.kafka.properties.sasl.mechanism=
spring.kafka.producer.key-serializer=
spring.kafka.producer.value-serializer=
spring.kafka.producer.acks=
现在我们引入AsyncAPI来更好地描述和记录我们的事件驱动架构。
我想知道如何在java代码中导入javaApi.yaml(包含Kafka描述)文件。
请告诉我如何使用Api.yaml文件来实现一个Kafka生产者。是否可以使用pocapi.yaml生成pojo类?
我正在使用Springboot和maven,我没有找到一个合适的方法来集成项目中的Api.yaml
非常感谢.
1条答案
按热度按时间lbsnaicq1#
有一个库可以理解AsyncAPI,从中提取模式,并可以用不同的语言生成模型,包括Java-> https://github.com/asyncapi/modelina
它集成在AsyncAPI CLI中,您可以使用它来生成这些模型,如
asyncapi generate models java asyncapi.yml
-> https://github.com/asyncapi/cli/blob/master/docs/usage.md#asyncapi-generate-models-language-fileAsyncAPI CLI不仅作为NPM包提供,而且还是一个可以在Maven中调用的二进制文件。对不起,我没有一个示例Maven配置,我可以与您分享。但是,是的,你有很多不同的选择,比如只是docker -> https://www.asyncapi.com/docs/tools/cli/installation