kafka-producer-api 相关问题

如何通过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（）{...

间歇性获取KafkaProducerException：无法发送org.apache.kafka.common.errors.TimeoutException

我正走出错误-原因：org.apache.kafka.common.errors.TimeoutException：到期1条以下记录，原因：org.apache.kafka.common.errors.TimeoutException：到期1。 ..

Kafka文件流连接和流API

正在使用文件流连接器，我在文件中有超过一千万条记录（这不是一个文件，它是按帐户＃划分的）。我必须将这些文件加载 到主题中并更新我的...

如何处理Kafka模式演变

我是kafka的新手。这是我对不断变化的kafka模式的疑问。我们如何在kafka使用者端处理架构变更？如果我们在kafka发布者端更改有效负载结构，如何...

卡夫卡消费者滞后指标

我们正在使用kafka 2.12.XXXX-并且需要观察消费者在一个主题的所有分区上有多少滞后。是./kafka-consumer-groups.sh中LAG列的总和-描述一个...

kafka标头，在使用者处

我想利用Kafka标头功能。产生事件时，我将设置标题。然后，根据消耗量，我将读取标题并根据该标题内容做出决定。参见...

Reactor Kafka生产者-无法重试

我已经使用（reactor.kafka.sender.KafkaSender）和Reactor Kafka（用于Kafka的功能Java API）创建了KafkaProducer。使用以下生产者配置，max.block.ms = 8000个请求。...

如果我不关闭kafka生产者，会发生什么

我正在处理xml，我需要为每个记录发送一条消息，当我收到最后一条记录时，我关闭了kafka生产者，这里的问题是kafka生产者的send方法是异步的，...

Kafka主题存在，但不能从经纪人那里获得

我有1,000多个主题。中断后，我发现列出主题时仅显示少数主题。如果我写一个现有的但不可用的主题，它说：[2020-04-17 16:17:09，...

kafka消费者组重新平衡后的ProducerFencedException

我无法在类似主题上发表评论：仅生产者和读取过程写入的TransactionId前缀-ProducerFencedException，所以我将提出一个新问题。用例：一个带有2个分区的主题Spring ...

[Kafka消费消息，然后产生另一个主题

我必须从Kafka主题中消费，获取消息并执行json清理和过滤工作，然后我需要将新消息生成给另一个Kafka主题，我的代码是这样的：public static ...

Kafka Producer错误：'未指定值序列化程序，并且没有为类型…定义默认序列化程序。'

我刚开始使用Kafka并遇到以下菜鸟错误：'值不能为null。参数名称：未指定值序列化程序，并且没有为ActMessage类型定义默认的序列化程序。 ...

两个kafkaTemplate对象之间的动态切换

我有两个kafka群集（主动-被动）。我创建了两个KafkaTemplate对象来产生事件（每个事件一个）。只要运行状况良好，我将继续使用主kafkaTemplate发送事件。 ...

如何将创建的用户传递给Kubernetes Strimzi Kafka运算符集群中的producer.sh/consumer.sh？

我为Kafka部署了Strimzi运算符并启用了TLS / ACL，现在我被卡住了！如何在创建的9093传递用户上运行producer.sh/consumer.sh？以下是在端口上禁用ACL的命令...