一:生产者发送流程二:生产者如何确定消息发送成功?1:启动kafka并创建主题2:异步发送内容package com.dashu; import com.dashu.interceptor.ValueInterCaptorTest; import org.apache.kafka.clients.producer.*; import org.apache.kafka.common.serialization.StringSerializer; import java.util.Properties; import java.util.concurrent.ExecutionException; public class KafkaProviderCallBackTest { // 代码中不要使用自定义主