1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. K>
  5. kakfa producer api

当前主题:kakfa producer api

kakfa producer api相关的博客

查看更多 写博客

Kafka最佳实践

前言 Kafka 是一种分布式的,基于发布/订阅体系的消息队列系统。 能够以 时间复杂度为 O(1) 的方式提供消息持久化能力,即使对 TB 级以上数据也能保证 常数时间复杂度 的访问性能。 即使在非常廉价的商用机器上也能做到单机支持每秒 100K 条以上消

阅读全文

Kakfa生产者详解

kafka producer所有实现的接口: java.io.Closeable, java.lang.AutoCloseable, Producer<K,V> 生产者用于向kafka集群发送消息。 生产者是线程安全的,通常在多线程中使用一个生产者实例比使用

阅读全文

kafka入门介绍(转载)

Kafka作为一个分布式的流平台,这到底意味着什么? 我们认为,一个流处理平台具有三个关键能力: 发布和订阅消息(流),在这方面,它类似于一个消息队列或企业消息系统。 以容错的方式存储消息(流)。 在消息流发生时处理它们。 什么是kakfa的优势? 它应用于

阅读全文

Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka

聊什么 为了满足本系列读者的需求,在完成《Apache Flink 漫谈系列(14) - DataStream Connectors》之前,我先介绍一下Kafka在Apache Flink中的使用。所以本篇以一个简单的示例,向大家介绍在Apache Flin

阅读全文

从源码分析如何优雅的使用 Kafka 生产者

前言 在上文 设计一个百万级的消息推送系统 中提到消息流转采用的是 Kafka 作为中间件。 其中有朋友咨询在大量消息的情况下 Kakfa 是如何保证消息的高效及一致性呢? 正好以这个问题结合 Kakfa 的源码讨论下如何正确、高效的发送消息。 内容较多,对源

阅读全文

一文看懂 kafka 机制

Kafka的特性 高吞吐量、低延迟:kafka每秒可以处理几十万条消息,它的延迟最低只有几毫秒,每个topic可以分多个partition, consumer group 对partition进行consume操作。 可扩展性:kafka集群支持热扩展 持久

阅读全文

消息中间件(Kafka/RabbitMQ)收录集

本篇主要整理工作中遇到的一些消息中间件的相关知识,包括Kafka, RabbitMQ, RocketMQ, ActiveMQ等,不排除收录其他消息中间件的可能。 这里会持续收录相关知识,包括安装、部署、使用示例、监控、运维、原理等。 所有新撰写的与中间件有关

阅读全文

E-MapReduce Kafka Benchmark - I

0. 测试目的 本文介绍如何利用Kafka自带的性能测试脚本测试E-MapReduce Kafka集群的性能,文末给出一份单机测试Kafka集群的性能数据。此数据仅供参考,不代表官方性能指标承诺。 非特定表述,以下所有Kafka集群指E-MapReduce

阅读全文