回顾 cmd / kafka.go-> deliveryChan-运河数据库-达科斯银行生产者-生产者 Lendo para ver se eu recebo novas msg-go kafka.DeliveryReport(deliveryChan) Cria o Processor做Kafka-kafkaProcessor Comeca消费msg-kafkaProcessor.Consume() application / kafka / process.go-> 使用服务集进行配置的主题2主题,事务确认交易-主题:= [] string {}交易的主题消息,用于事务的主题,用于