kafka-producer-api 相关问题

Kafka序列化器和模式注册

在我的生产者中，我有一个属性kafkaProducer.value.serializer，并设置为org.apache.kafka.common.serialization.StringSerializer。我只想知道架构注册表是否具有相同的用途或执行这些操作...

何时使用Kafka交易API？

我试图了解Kafka的事务性API。该链接定义了如下原子读取过程写入周期：首先，让我们考虑一下原子读取过程写入周期的含义。在...

如何从集合中有效地向Kafka生成消息

在我的Scala（2.11）流应用程序中，我正在使用IBM MQ中一个队列中的数据，并将其写入具有一个分区的Kafka主题。从MQ消耗数据后，消息有效负载就会得到...

Kafka Connect和自定义查询

我有兴趣在创建发票时使用Kafka Source JDBC连接器执行发布到Kafka。在源端，它分为2个表Invoice和InvoiceLine。 ...

充分利用kafka-node

我需要为我的项目使用什么正确的Kafka结构以及为什么的建议。我的项目Im正在创建投资机器人管理平台。非常高级-您可以编码...

如何检查Ruby-Kafka重试是否有效？

在文档中提到生产者重试以基于max_retries将消息发送到队列。因此，我关闭了Kafka，然后尝试了制作人。我收到此错误正在获取...

Kafka生产者回调异常

[当我们生成消息时，我们可以定义一个回调，该回调可能会发生异常：kafkaProducer.send（producerRecord，new Callback（）{

Kafka生产者回调专有

[当我们产生消息时，我们可以定义一个回调，该回调可能会发生异常：kafkaProducer.send（producerRecord，new Callback（）{public void onCompletion（...

如何使用点网在Kafka中生成墓碑Avro记录？

我的接收器属性：{“名称”：“ jdbc-oracle”，“配置”：{“ connector.class”：“ io.confluent.connect.jdbc.JdbcSinkConnector”，“ tasks.max”：“ 1” ，“主题”：“订单”，“ connection.url”：...

如何使用dotnet在Kafka中生成墓碑Avro记录？

我的接收器属性：{“名称”：“ jdbc-oracle”，“ config”：{“ connector.class”：“ io.confluent.connect.jdbc.JdbcSinkConnector”，“ tasks.max”：“ 1”， “ topics”：“ orders”，“ connection.url”：...

Kakfa重试概念-卡夫卡将停止哪些基础重试？

作为Kafka的新手，试图了解Kafka中的重试概念。什么基础的重试过程将完成？示例Retries参数我们设置为7。现在问题在这里，卡夫卡将是...

Apache Camel-Kafka组件-单一生产者多个消费者

[我正在创建两个Apache骆驼（蓝图XML）kafka项目，一个是kafka-producer，它接受请求并将其存储在kafka服务器中，另一个是kafka-consumer，它从...中拾取消息。

Kafka Producer超时异常：即使最大请求超时和正确的批处理大小，也是如此

[我们目前有大约80个应用程序（大约200个K8s副本）每天向kafka写入16-17百万条记录，其中一些记录由于超时和重新平衡而间歇性地失败...

如何通过Kafka控制台使用者和生产者使用JSON模式消费和产生消息

可以分别使用kafka-console-consumer和kafka-console-producer在Kafka中使用JSON模式消费和产生消息吗？

如何通过Kafka控制台使用者和生产者使用JSON模式消费和产生消息

可以分别使用kafka-console-consumer和kafka-console-producer在Kafka中使用JSON模式消费和产生消息吗？

等待Kafka Send API返回的ListenAbleFuture列表

我有ListenAbleFuture列表。如果他们尚未完成，我想等待此ListenableFuture >列表至少15分钟。我怎样才能做到这一点。 ...

等待kafkaTemplate等待未来

我正在执行异步操作，该操作将在循环中返回将来的对象（例如10条消息）。据我了解，当Future完成时，回调方法会自动触发并执行...

如何使用Spark Java将Spark Dataframe写入Kafka Producer时控制记录数

我有一个带有两列的spark数据框，分别为'keyCol'列和'valCol'列。数据帧的大小巨大，将近1亿行。我想将数据帧写入/生成到mini ...中的kafka主题...

通过jmeter中的Pepperbox采样器连接kafka服务器时发生异常

我正在JMeter中使用pepprBox Sample连接kafka服务器并发送有关主题的消息。应用程序团队共享了两个JKS证书以及密码来连接Kafka服务器。为此，我有...

这个goroutine如何连续运行（它如何工作？）>

我对goroutine的基本理解是，它是创建线程的简化方法。以confluent-kafka-go库为例，给出以下代码：go func（）{...