个人中心
gpt4 book ai didi

java - @Autowired 处理器为空

转载 作者：行者123 更新时间：2023-11-29 04:05:17 26 4
gpt4 key购买 nike

<分区>

我正在使用 Spring Cloud Stream 的 OOTB 示例。

我的主程序中有这段代码。

@SpringBootApplication
@EnableBinding(Processor.class)
@EnableSchemaRegistryClient
public class AvroKafkaApplication {

    public static void main(String[] args) throws InterruptedException {

        SpringApplication.run(AvroKafkaApplication.class, args);
     }
}

当我向其中扔东西时，我的生产者类中的 Processor 类为空。

@Service
public class AvroProducer {

    @Autowired
    private Processor processor;

    public void produceEmployeeDetails(int empId, String firstName, String lastName) {

        // creating employee details
        Employee employee = new Employee();
        employee.setId(empId);
        employee.setFirstName(firstName);
        employee.setLastName(lastName);
        employee.setDepartment("IT");
        employee.setDesignation("Engineer");

        // creating partition key for kafka topic
        EmployeeKey employeeKey = new EmployeeKey();
        employeeKey.setId(empId);
        employeeKey.setDepartmentName("IT");

        Message<Employee> message = MessageBuilder.withPayload(employee)
            .setHeader(KafkaHeaders.MESSAGE_KEY, employeeKey)
            .build();

        processor.output()
            .send(message);
    }

}

@Autowired 注释工作正常，因为我在功能上没有错误，但过程变量在任何时候都是空的。

可以从这里克隆基础项目: https://github.com/eugenp/tutorials/tree/master/spring-cloud/spring-cloud-stream/spring-cloud-stream-kafka

对此有什么想法吗？

提前致谢!

26 4 0
文章推荐： ios - Xib 用于自定义 UIView 或类设置为此自定义 UIView 的 UIView
文章推荐： MYSQL统计每类item的颜色数
文章推荐： ios - 从被拒绝的证书中清除 XCode 缓存
文章推荐： java - MySQL DB 或 JDBC 驱动程序不处理 LocalDate.MAX
行者123
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com