kafka-producer-api 相关问题

我对使用已经在云上创建的kafka生产者和使用新的Producer生产者=新的KafkaProducer以编程方式创建新的生产者感到困惑我对使用已经在云上创建的 kafka 生产者和使用 new Producer Producer = new KafkaProducer （props）以编程方式创建新的 prodcuer 之间感到困惑。我如何调用已经存在的生产者，即在云上创建的生产者。假设它是一个简单的java类，没有使用任何像spring这样的框架创建新生产者与调用现有生产者连接到已在云上创建的 Kafka 生产者需要配置 Kafka 客户端以连接到远程 Kafka 集群。以下是在简单的 Java 类中使用 Kafka 生产者 API 连接到在云上创建的现有 Kafka 生产者的步骤，无需任何 Spring 等框架：配置 Kafka Producer 属性：从云提供商或管理员处获取现有 Kafka 生产者的配置详细信息（例如引导服务器、安全设置）。相应地更新您的属性。 Properties props = new Properties(); props.put("bootstrap.servers", "cloud-kafka-broker1:9092,cloud-kafka-broker2:9092"); // Add other required properties like security settings, serializers, etc. 创建Kafka生产者：使用 KafkaProducer 类创建具有提供的属性的 Kafka 生产者实例。 Producer<String, String> producer = new KafkaProducer<>(props); 发送消息：您可以使用send方法向云端Kafka集群中的主题发送消息。 ProducerRecord<String, String> record = new ProducerRecord<>("your-topic", "key", "value"); producer.send(record); 关闭生产者：使用完生产者释放资源后，请确保将其关闭。 producer.close(); 完整的 Java 类可能如下所示： import org.apache.kafka.clients.producer.*; import java.util.Properties; public class CloudKafkaProducer { public static void main(String[] args) { Properties props = new Properties(); props.put("bootstrap.servers", "cloud-kafka-broker1:9092,cloud-kafka-broker2:9092"); // Add other required properties like security settings, serializers, etc. Producer<String, String> producer = new KafkaProducer<>(props); try { ProducerRecord<String, String> record = new ProducerRecord<>("your-topic", "key", "value"); producer.send(record); } catch (Exception e) { e.printStackTrace(); } finally { producer.close(); } } } 确保将 "cloud-kafka-broker1:9092,cloud-kafka-broker2:9092" 和 "your-topic" 分别替换为实际的云 Kafka 代理地址和主题名称。此外，根据云提供商的规范配置其他必要的属性。

apache-kafka spring-kafka kafka-producer-api

回答 1 投票 0

AWS MSK 事务支持

我正在尝试在 Lambda 函数内创建一个 Kafka Producer，并启用 Exactly-Once Delivery 支持以将消息推送到 MSK。编辑：MSK IAM Auth 用于 Kafka 和

apache-kafka kafka-producer-api aws-msk kafka-transactions-api

回答 1 投票 0

主题在 60000 毫秒后不存在于元数据中

用例场景：我试图确保万一生产者为了获取元数据而连接的代理（引导程序之一）不可用，然后在阻止它之后...

apache-kafka spring-kafka confluent-platform kafka-producer-api

回答 1 投票 0

kafka-console- Producer.sh错误：无法找到或加载主类kafka.tools.ConsoleProducer

刚刚安装了spotify/kafka的Docker镜像。须藤码头工人 PS： 82c411a52a38 spotify/kafka "supervisord -n" 26 分钟前更新 26 分钟 0.0.0.0:2181->