问答 2024-08-16 来自:开发者社区

kafka client生产datahub消息,topic如何使用?

kafka client生产datahub消息,topic如何使用?

问答 2024-08-06 来自:开发者社区

kafka client 生产 datahub 消息 topic 使用方法有哪些?

kafka client 生产 datahub 消息 topic 使用方法有哪些?

问答 2022-12-20 来自:开发者社区

请教一下为什么用用kafka的client可以正常消费数据,但是用flink消费kafka就报错?

请教一下为什么用用kafka的client可以正常消费数据,但是用flink消费kafka就报错?

问答 2022-07-22 来自:开发者社区

大佬们,flink sql client实现 mysql表实时同步到hive,除了中间转kafka再

大佬们,flink sql client实现 mysql表实时同步到hive,除了中间转kafka再写hive,有没有别的方式,能一步到位。

问答 2019-02-01 来自:开发者社区

kafka 三台,linux环境,本地windows用kafka的client可以拉取到数据,将程序发布到服务器上,就不行了 什么坑

kafka 三台,linux环境,本地windows用kafka的client可以拉取到数据,将程序发布到服务器上,就不行了 什么坑

文章 2017-03-07 来自:开发者社区

Kafka发送超过broker限定大小的消息时Client和Broker端各自会有什么异常?

前几天遇到一个bug,查看发送日志发现java.io.IOException: Broken pipe的错误,通过深入了解发现当kafka producer发送的消息体大于Broker配置的默认值时就会报这个异常。如果仅发送一次是不会报这个异常的,要连续发送才会报这个异常。 本博文记录一下当Kafka发送超过broker限定大小的消息时Client和Broker端各自会有什么异常。 Kafk...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注