1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. K>
  5. kafka 服务器

当前主题:kafka 服务器

Java工程师学习指南(完结篇)

Java工程师学习指南 完结篇 先声明一点,文章里面不会详细到每一步怎么操作,只会提供大致的思路和方向,给大家以启发,如果真的要一步一步指导操作的话,那至少需要一本书的厚度啦。 因为笔者还只是一名在校生,所以写的内容主要还是针对Java初学者或者接触Java

阅读全文

从 Storm 到 Flink,汽车之家基于 Flink 的实时 SQL 平台设计思路与实践

作者:王刚、刘首维 在 2019 年之前,之家的大部分实时业务都是运行在 Storm 之上的。Storm 作为早期主流的实时计算引擎,凭借简单的 Spout 和 Bolt 编程模型以及集群本身的稳定性,俘获了大批用户。下图是实时计算团队 Storm 平台页面

阅读全文

基于commons-pool2实现KafkaProducer池来提升kafka发送消息性能

业务场景 Spark用fileStream实时从NFS获取一批文件,将文件中JSON结构里面的大小图二进制数据上传云存储获取url然后再将url以string回写到json中发送kafka,最早使用多线程并行发送内个线程创建一个KafkaProducer速度

阅读全文

云栖干货回顾 | 行业顶级NoSQL成员坐阵,NoSQL数据库专场重点解析!

NoSQL数据库作为数据库市场最重要的组成之一,它的一举一动都影响着成千上万的企业。本专场邀请了行业顶级的NoSQL核心成员与大家共同展望NoSQL数据库的未来,**阿里巴巴、MongoDB、Redisson、斗鱼等**公司的技术大咖与大家共同分享了阿里云N

阅读全文

一文读懂分布式架构知识体系(内含超全核心知识大图)

作者 | 晓土  阿里巴巴高级工程师 姊妹篇阅读推荐:**《**云原生时代,分布式系统设计必备知识图谱(内含22个知识点)**》** 导读:本文力求从分布式基础理论、架构设计模式、工程应用、部署运维、业界方案这几大方面,介绍基于 MSA(微服务架构)的分布式

阅读全文

袋鼠云研发手记 | 数栈DTinsight:详解FlinkX中的断点续传和实时采集

袋鼠云云原生一站式数据中台PaaS——数栈,覆盖了建设数据中心过程中所需要的各种工具(包括数据开发平台、数据资产平台、数据科学平台、数据服务引擎等),完整覆盖离线计算、实时计算应用,帮助企业极大地缩短数据价值的萃取过程,提高提炼数据价值的能力。 数栈架构图

阅读全文

Dubbo 常见错误及解决方法

导读 『StabilityGuide』是阿里多位阿里技术工程师共同发起的稳定性领域的知识库开源项目,涵盖性能压测、故障演练、JVM、应用容器、服务框架、流量调度、监控、诊断等多个技术领域,以更结构化的方式来打造稳定性领域的知识库,欢迎您的加入。 @GitHu

阅读全文

那些年,我们见过的 Java 服务端“问题”

导读 明代著名的心学集大成者王阳明先生在《传习录》中有云: 道无精粗,人之所见有精粗。如这一间房,人初进来,只见一个大规模如此。处久,便柱壁之类,一一看得明白。再久,如柱上有些文藻,细细都看出来。然只是一间房。 是的,知识理论哪有什么精粗之分,只是人的认识程

阅读全文

kafka 服务器相关问答

查看更多 提问题

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

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

阅读全文

kafka数据导入greenplum爆出Connetion refused的错误

![gpkafka](https://yqfile.alicdn.com/f6cb2f1c3070c6632adbb3b49a9fa92fbfd49ebf.png) 按照官网教程,配置loadcfg2.yaml,已经配置了localhost_name和端口,

阅读全文

Flink kafka - Flink作业不向不同分区发送消息

我有以下配置: 一个带有2个分区的kafka主题 一个zookeeper实例 一个kafka实例 两个具有相同组ID的消费者 Flink工作片段: speStream.addSink(new FlinkKafkaProducer011(ka

阅读全文

使用flink的kafka到opentsdb:java.lang.NoClassDefFoundError:无法初始化类org.apache.http.conn.ssl.SSLConnectionSocketFactory

"这是我的代码: def saveToOpenTSDB(rows: Iterator[String], url: String) { val requestConfig: RequestConfig = RequestConfig.

阅读全文

阿里MQ怎么解决固定ip访问带来的单服务器带宽问题

请问阿里MQ的http方式是如何解决通过固定url访问产生的带宽瓶颈的?固定url是对应的一台服务器吗,如果是一台服务器,那应该会有带宽的瓶颈吧,是否用到了硬件负载? 我看kafka可以配置多个ip地址进行消息写入,不清楚MQ的处理逻辑。

阅读全文

无法访问阿里云部署的kafka

使用1.0.1版本kafka,设置listeners为阿里云私有ip,advertised.listeners设置为公网ip.为何访问不了?报[2018-06-10 21:43:55,501] WARN [Producer clientId=console-p

阅读全文

Java开发者你们在哪里,社区请Java专家团来答疑解惑了

[<p style="text-align:center">![600_300](https://yqfile.alicdn.com/966bd386f66b9570b0919deb560419782d0c6840.jpeg)</p>](https://yq.

阅读全文

zookeeper+hdoop+hbase+storm+kafka集群所需要的服务器性价比最高的配置,求推荐

目前需要申请阿里云服务器,搭建zookeeper+hdoop+hbase+storm+kafka集群,租用一下短期服务器测试性能,求推荐的服务器最佳配置策略

阅读全文