kafka的0.10的api-kafka消费-kafka集群-手机站-阿里云

kafka的0.10的api 相关的博客

kafka-0.10.0官网翻译（一）入门指南

1.1 IntroductionKafka is a distributed streaming platform. What exactly does that mean?kafka是一个分布式的流式平台，它到底是什么意思？ We think of a st

刘洋intsmaze 8年前 655

kafka启动时出现FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) java.io.IOException: Permission denied错误解决办法（图文

问题详情　　然后，我启动时，出现如下 [hadoop@master kafka_2.10-0.9.0.1]$ nohup bin/kafka-server-start.sh config/server.properties & [1] 9164 [hadoo

技术小哥哥 7年前 6677

storm-kafka-0.8-plus 源码解析

寒凝雪 7年前 1525

基于Web的Kafka管理器工具之Kafka-manager的编译部署详细安装 (支持kafka0.8、0.9和0.10以后版本)（图文详解）（默认端口或任意自定义端口）

至于为什么，要写这篇博客以及安装Kafka-manager？问题详情　　无奈于，在kafka里没有一个较好自带的web ui。启动后无法观看，并且不友好。所以，需安装一个第三方的kafka管理工具功能　　为了简化开发者和服务工程师维护Kafka集群的工

技术小哥哥 7年前 4896

kafka0.8--0.11各个版本特性预览介绍

kafka-0.8.2 新特性　　producer不再区分同步（sync）和异步方式（async），所有的请求以异步方式发送，这样提升了客户端效率。producer请求会返回一个应答对象，包括偏移量或者错误信。这种异步方地批量的发送消息到kafka broke

刘洋intsmaze 7年前 1437

mac kafka 环境搭建

请叫我东子 7年前 1093

windows下kafka源码阅读环境搭建

工具准备：jdk1.8,scala-2.11.11,gradle-3.1,zookeeper-3.4.5,kafka-0.10.0.1-src.tgz, kafka_2.11-0.10.0.1.tgz 安装jdk 安装scala 搭建zookeeper ka

科技小先锋 6年前 1910

kafka简单安装部署

一、安装、配置　１．下载 kafka是由linkedin开源的，但是已经托管在了apache，所以需要从apache下载，http://kafka.apache.org/downloads.html。安装推荐的版本安装就可以了，例如下面0.10.0.0是最

付磊-起扬 8年前 1066

kafka的0.10的api 相关的问答

kafka.common.KafkaException：错误的请求类型18

我正在运行这段代码。streamingInputDF是Kafka主题的readStream。我正在运行spark 2.4.0和Kafka 0.10.2 val activityQuery = streamingInputDF.writeStream .

社区小助手 5年前 764

如何在Scala中使用Flink的KafkaSource？

尝试用Flink的KafkaSource运行一个简单的测试程序，内容如下： Flink 0.9 Scala 2.10.4 Kafka 0.8.2.1 import org.apache.flink.streaming.api.scala._ impo

【方向】 6年前 670

flink state.backend是rocksdb，存储在hdfs上，经常遇到checkpoint执行不成功的情况 checkpoint超时过期的原因（设置checkpoint超时为60s）

flink程序在yarn上执行 kafka source topic分区为20 设置程序并行度为10，-yn 2 -ys 5 -ytm 26600 -yjm 5120，我看到网上有说是因为程序并行度太高导致打开的文件数太多，从而导致的在hdfs创建文件不成功，

莱昂007 6年前 1970

Flink 从Checkpoint恢复失败

``` import java.util.Properties import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink.str

冷丰 5年前 1326

如何使用Spark结构化流媒体为Kafka流实现自定义反序列化？

我正在尝试迁移我当前的流媒体应用程序，这是基于使用RDD（从他们的文档）到他们使用结构化流媒体的新数据集API，我被告知这是使用Spark进行实时流媒体的首选方法。目前，我的应用程序设置使用了一个名为“SATELLITE”的主题，该主题包含一个包含密钥

社区小助手 5年前 321

在EMR类中找不到Spark-submit异常java

我有一个jar包捆绑创建一个弹簧启动应用程序，其中我创建spark会话来做一些操作。然后我发送这个jar AWS EMR，要么运行的spark-submit或者java -jar未工作的可执行文件。这是我的jar结构 jar -tf <jar

小六码奴 5年前 178

Spark导入数据到HBase问题(BulkLoad)

import java.util.ArrayList; import java.util.Iterator; import java.util.List; import org.apache.hadoop.fs.Path; import org.apa

hbase小能手 6年前 817

kafka的0.10的api

免费套餐

校园扶持

API服务