阿里云文档 2024-11-05

如何创建迁移任务将元数据迁移至已有实例

本文介绍如何在云消息队列 Kafka 版控制台创建迁移任务,将元数据迁移至云消息队列 Kafka 版已有实例。

问答 2023-09-20 来自:开发者社区

Flink CDC有同时包含kafka以及cdc的pom文件啊 我这边一直在报依赖问题?

Flink CDC有同时包含kafka以及cdc的pom文件啊 我这边一直在报依赖问题?

问答 2023-09-06 来自:开发者社区

Flink CDC文件有没有cdc还是说需要加 工具(filebeat + kafka)才能实现吗?

Flink CDC文件有没有cdc还是说需要加 工具(filebeat + kafka)才能实现吗 ?

问答 2023-07-31 来自:开发者社区

dataworks可以订阅kafka和DataHub 然后生成文件吗?

dataworks可以订阅kafka和DataHub 然后生成文件吗?

问答 2023-05-26 来自:开发者社区

为什么rocketmq不像Kafka那样使用sendfile发送文件?

对于MQ而言,无非就是生产者发送数据到MQ然后持久化到磁盘,之后消费者从MQ读取数据。 对于RocketMQ来说这两个步骤使用的是mmap+write,而Kafka则是使用mmap+write持久化数据,发送数据使用sendfile。 原提问者GitHub用户AdventurerJohn

问答 2023-05-14 来自:开发者社区

Flink CDC如果不用kafka呢,直接用logstash做log文件的读取可以吗?

Flink CDC如果不用kafka呢,直接用logstash做log文件的读取可以吗?主要是kafka这块对接过程我不了解,应该配置什么,主要是log4j加了配置后起不来flink?

文章 2022-12-29 来自:开发者社区

Flume监控文件并将数据输入至Kafka

Flume配置文件a1.sources = r1 a1.sinks = k1 a1.channels = c1 a1.sources.r1.type = exec a1.sources.r1.bind = tail -F /usr/local/hive.log a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink a1.sinks.k1....

问答 2022-10-30 来自:开发者社区

flink cdc内置了kafka 监听binlog文件的时候 是把所有监听的数据写入kafka的

还是只是记录偏移量 数据还是从biglog取的

问答 2022-02-15 来自:开发者社区

安装pipeline_kafka,make时报错Makefile:19: /usr/pgsql-11/lib/pgxs/src/makefiles/pgxs.mk: 没有那个文件或目录,找到lib下面,确实没有pgxs,只有pgxs.so请问怎么解决

安装pipeline_kafka,make时报错Makefile:19: /usr/pgsql-11/lib/pgxs/src/makefiles/pgxs.mk: 没有那个文件或目录,找到lib下面,确实没有pgxs,只有pgxs.so请问怎么解决

文章 2022-01-09 来自:开发者社区

kafka log4j日志级别修改,一天生成一个日志文件

kafka的log4j日志默认配置中,有如下配置:log4j.appender.kafkaAppender=org.apache.log4j.DailyRollingFileAppender log4j.appender.kafkaAppender.DatePattern='.'yyyy-MM-dd-HH这有什么问题呢,虽然说我们用一天一次的滚动日志,但是我们配置的DataPattern为小时级....

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

产品推荐

云消息队列

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

+关注