kafka-producer-api专题提供kafka-producer-api的最新资讯内容,帮你更好的了解kafka-producer-api。
我已经开始学习Kafka,并且在学习过程中,我对Kafka的工作过程遇到了一些困惑,我将与您分享这些困惑
<strong>我的设置:</strong> 因此,我刚刚完成了一个在<code>VM</code>上运行且地址为<code>192.168.0.100</code>的ka
按照ProducerConfig Java类中的LINGER_MS_DOC: <blockquote> “生产者将介于两者之间的任何记录分组在一起
我设置了以下生产者配置,但是,我注意到<code>request.timeout.ms</code>较高时,<code>replica.lag.time.max.ms</code>
我正在使用带有弹簧靴的kafka。我阅读了许多有关kafka调整的文章,并在生产者和消费者方面进行了一些
每18到20个小时之后,由于<code>Kafka</code>错误,<code>log</code>服务将继续出错。 <a href="https://i.stack.im
我的应用程序的用户使用Web应用程序提交csv文件。 kafka生产者读取每个CSV记录,并将其发送到kafka
出现此错误: 2020-11-12 20:16:35.463错误17552 --- [extractor-3] osksupport.LoggingProducerListener:发送带有key
简而言之,我启动了Kafka,成功创建了一个主题,启动了启用了密钥的制作人。到现在为止还挺好。我发
我正在尝试使用 Kafka 的 RoundRobinPartitioner 类在所有分区之间均匀分布消息。我的Kafka主题配置如下: <
我正在将一个 JSON 文件推送到 Kafka 主题中,在 presto 中连接该主题并将 JSON 数据构建到一个可查询的表
我是 confluent-kafka-python 的新手,我正在使用 <a href="https://github.com/confluentinc/cp-all-in-one" rel="nofollow noreferre
正如我们所知,我们可以使用 kafka 生产者发送一个密钥,该密钥在内部进行散列以查找主题数据中的哪
我正在使用 <a href="https://docs.confluent.io/clients-confluent-kafka-python/current/index.html" rel="nofollow noreferrer">Confluent
我有一个 API,它将 Message 对象作为输入,向 Kafka 生成一条消息。我还写了一个消费者,它消费消息并将
我无法生成我的 kafka 主题,我在控制台中收到此警告。 这个警告可能是原因吗? 我收到此异
我们有一个 spring boot 项目,我们已经将 KafkaListener 配置为一个主题。现在,在应用程序重新启动时,此
我在发布到 kafka 时看到这个问题时断时续,针对同一主题重试一段时间。我已经验证了所有网络,没有
同步副本配置为 <strong>Acks=all</strong> 和 <strong>min.insync.replicas = N</strong>, 想了解如何为未处理的生
我目前正在了解有关 Kafka Producer 的更多信息。我对文档中的以下段落感到有些困惑: <块引用> 写