消息
创作中心
至此y 2021-07-22 00:54 采纳率: 100%
浏览 102
已结题

kafka实时传输数据，保证实时性

kafka定时扫描某个目录，然后需要给这个目录下定时推送文件怎么弄

  • 写回答

4条回答 默认 最新

  • CSDN专家-Time 2021-07-22 01:01
    关注

    用@Scheduled
    https://blog.csdn.net/limingcai168/article/details/103394041

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)
编辑
预览

报告相同问题？

  • kafka拉取不到数据 java kafka 分布式 有问必答
    2022-02-16 11:32
    回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
  • kafka如何获取到发送失败的数据 java kafka 有问必答
    2021-07-27 02:36
    回答 1 已采纳 kafka调用send方法发送数据后 会返回一个ListenableFuture 这个ListenableFuture可以添加callback进行监听d
  • kafka取不到监听数据 jar 有问必答
    2021-04-20 02:49
    回答 3 已采纳 https://gewu.pcwanli.com/front/article/10619.html
  • tcp实时传输kafka数据_kafka实时流数据架构
    2020-12-20 09:40
    weixin_39739234的博客 初识kafka简介Kafka经常用于实时流数据架构，用于提供实时分析。...kafka被用于实时数据流、收集大数据或者做一些实时分析。kafka是也为基于内存的微服务提供数据持久化并把数据传输给复杂的事件流系统和I...
  • flink消费kafka数据延迟 flink postgresql scala 有问必答
    2022-01-28 01:47
    回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
  • flinksql读取kafka数据报错 flink kafka
    2022-07-13 12:33
    回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
  • kafka可以生产无法消费的问题 java kafka
    2022-06-11 02:41
    回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
  • Java实现Kafka数据生产者
    2024-04-02 03:43
    Kafka提供了持久性存储、数据复制和容错机制，使得它适用于构建实时数据流处理应用、日志收集、指标监控等场景。 高吞吐量：Kafka能够处理数以千计的消息，每秒钟数百万条消息的传输量，适用于高负载的生产环境。 ...
  • kafka消费者创建不了 java kafka linux
    2022-08-23 02:01
    回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
  • Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
    2022-10-25 01:26
    回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
  • 不使用zk实现双机clickhouse、kafka数据同步 kafka zookeeper
    2023-02-02 08:54
    回答 4 已采纳 ''该回答引用ChatGPT''如对你的问题有帮助，请点击右侧采纳即可！没有使用ZooKeeper的话，一种可行的方案是利用ClickHouse的复制功能实现双机数据同步。ClickHouse的复制功
  • firehose:将数据从Kafka流式传输到任何数据存储区
    2021-04-07 20:19
    Firehose是一种云原生服务，用于将实时流数据传递到目的地，例如服务端点（HTTP或GRPC）和托管数据库（Postgres，InfluxDB，Redis和Elasticsearch）。 使用Firehose，您无需编写应用程序或管理资源。 可以扩大规模...
  • kafka如何保证数据可靠性
    2020-05-26 02:17
    喜剧之皇的博客 kafka中，每个partition可以有多个副本(Replica)，分为leader、follower，正常情况下，客户端只向leader发送数据、leader消费数据，follower的出现是为了保证kafka数据的高可用和一致性，也是作为灾备的存在。再保证...
  • Kafka快速实战与基本原理详解：从零到精通
    2023-12-25 11:39
    Kafka是一种分布式消息系统...总的来说，Kafka以其高性能、高可扩展性和丰富的功能，成为了实时数据处理和消息传递领域的重要工具。通过理解其核心概念和实际操作，开发者能够有效地构建和维护大规模的数据流处理系统。
  • 使用Apache Kafka构建实时数据流处理平台的技术详解
    2024-11-23 03:06
    瑕疵​的博客 Apache Kafka 是一个开源的分布式消息队列系统，最初由 LinkedIn 开发，后来成为 Apache 软件基金会的顶级项目。Kafka 旨在处理大规模的实时数据流，具有高吞吐量、低延迟和可扩展性等特点。
  • 没有解决我的问题, 去提问

问题事件

  • 系统已结题 5月15日
  • 已采纳回答 5月8日
  • 创建了问题 7月22日
手机看
程序员都在用的中文IT技术交流社区

程序员都在用的中文IT技术交流社区

专业的中文 IT 技术社区，与千万技术人共成长

专业的中文 IT 技术社区，与千万技术人共成长

关注【CSDN】视频号，行业资讯、技术分享精彩不断，直播好礼送不停！

关注【CSDN】视频号，行业资讯、技术分享精彩不断，直播好礼送不停！

 客服 返回
顶部