apache kafka api

阿里云 > 云栖社区> 主题地图> A> apache kafka api

apache kafka api 相关的博客

Apache Kafka学习 (一)

前言：最近公司开始要研究大数据的消息记录，于是开始研究kafka。 市面上kafka的书很少，有的也版本比较落后，于是仗着自己英文还不错，上官网直接学习。 ^_^   1. 开始 - 基本概念 学习一样东西，我们首先要知道它是什么。 那么kafka是什么呢？
master_haku 7年前 802

实用 | 从Apache Kafka到Apache Spark安全读取数据

引言 随着在CDH平台上物联网(IoT)使用案例的不断增加，针对这些工作负载的安全性显得至关重要。本篇博文对如何以安全的方式在Spark中使用来自Kafka的数据，以及针对物联网(IoT)使用案例的两个关键组件进行了说明。 Cloudera Distribu
反向一觉 7年前 1089

实用 | 从Apache Kafka到Apache Spark安全读取数据

引言 随着在CDH平台上物联网(IoT)使用案例的不断增加，针对这些工作负载的安全性显得至关重要。本篇博文对如何以安全的方式在Spark中使用来自Kafka的数据，以及针对物联网(IoT)使用案例的两个关键组件进行了说明。 Cloudera Distribu
知与谁同 7年前 1243

Apache Kafka源码分析 – Broker Server

1. Kafka.scala 在Kafka的main入口中startup KafkaServerStartable, 而KafkaServerStartable这是对KafkaServer的封装 1: val kafkaServerStartble = new
寒凝雪 7年前 1820

KSQL，用于Apache Kafka的流数据SQL引擎

Apache Kafka是一个分布式的、分区的、多复本的日志提交服务，使用Scala编写，以可水平扩展和高吞吐率而被广泛使用。Kafka最初是由LinkedIn开发，并于2011年初开源，目标是为实时数据处理提供一个统一、高通量、低等待的平台。目前，越来越多的
反向一觉 7年前 1274

什么时候该用RabbitMQ ，什么时候该用 Apache Kafka

人类如何做出决策? 在日常生活中，情感总是短路因素，导致在复杂或压倒性的决定上扣动扳机。但对于做有长期影响，复杂决策，的表意识，不可能是纯粹的冲动。高性能的人通常使用断路器，“本能,” “直觉,” 或其他的情绪，只有一次他们的表意识，潜意识吸收了作出决定所需
知与谁同 7年前 1613

Kafka API实践

系统学习三步骤走：理解原理、搭建系统、Api练习。 从哪里找到Api？Document和git。 例如，Kafka在github上的地址github.com/apache/kafka，找到example目录。 这也算是一个小技巧/apache/xxx，就是X
白头雁 6年前 1304

Apache Kafka是分布式发布-订阅消息系统

转自： http://www.infoq.com/cn/articles/apache-kafka?utm_source=infoq&utm_medium=popular_links_homepage 简介 Apache Kafka是分布式发布-订阅消息系统
广贤 10年前 2598

apache kafka api 相关的问答

Apache Flink：Python流API中的Kafka连接器，“无法加载用户类”

我正在尝试使用Flink的新Python流API并尝试运行我的脚本./flink-1.6.1/bin/pyflink-stream.sh examples/read_from_kafka.py。python脚本相当简单，我只是尝试使用现有主题并将所有内容发送到
flink小助手 5年前 1486

flink 注册kafka得csv格式

用flink注册kafka得消息源，format选择csv报错,选择avro可以。是不是kafka连接器不支持csv格式。 报错如下：Exception in thread "main" org.apache.flink.table.api.NoMatchi
jocean 6年前 994

flink表api异常

"我正在使用flink表api，使用kafka作为输入源，使用json作为表模式。提交程序时出现此错误：```程序完成以下异常： org.apache.flink.client.program.ProgramInvocationException: Th
flink小助手 5年前 1182

Apache Flink：如何处理Kafka接收器中的异常？

我有一个Flink工作，将数据写入Kafka。Kafka主题的最大邮件大小设置为5 MB，因此如果我尝试写入任何大于5 MB的记录，它会抛出以下异常并将作业关闭。 java.lang.Exception: Failed to send data to K
flink小助手 5年前 514

Flink 的 Scala API 怎么指定 时间字段

代码如下 ```scala import com.alibaba.fastjson.JSON import com.alibaba.fastjson.serializer.SerializeFilter import org.apache.flink.
冷丰 5年前 361

flink checkpoint 在 window 操作下 全局配置失效的问题。

#背景 - flink 版本号 1.6.2 - flink 集群模式 flink on yarn - 使用flink 读取kafka 数据 简单处理之后使用自定义richWindowFunction 处理数据的时候出现异常报错: ``
千狼 6年前 1100

Flink collector.collect 是报Buffer pool is destroyed.

使用的是事件时间 java.lang.RuntimeException: Buffer pool is destroyed. at org.apache.flink.streaming.runtime.io.RecordWriterOutput.push
ryan_wfa 5年前 1161

Flink 从Checkpoint恢复失败

``` import java.util.Properties import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink.str
冷丰 5年前 1326

相关主题

apache commons api apache api中文手册 kafka消费 kafka集群 kafka消息顺序 kafka 消息堆积 消息队列 kafka kafka云主机 api api 短信 大鱼api 大于api 护照API 名片API 鉴黄API 车牌API api短信 短信api 快递api 汇率api 股票api api文档 api参考 免费api 彩票api api管理 视频api api中心 邮箱api 绿网api 调用api 域名api 支付api 数加api 高德api 视频api api权限 api中心 开放api 调用api wcf连接数据库 域名备案能用多久 c#socket ip 域名 shell域名 域控服务器 不设dns ios7网络老是转 android数据库jar包 mysql数据库访问慢 电脑xp关闭网络共享 openload网站