需要更改一些配置以禁用自动提交模式并启用手动配置。然后对代码进行一些调整。 application.properties:. spring.kafka.consumer.bootstrap-servers= ...
確定! 回上一頁