原文:Kafka实战系列--Kafka API使用体验

前言: kafka是linkedin开源的消息队列, 淘宝的metaq就是基于kafka而研发. 而消息队列作为一个分布式组件, 在服务解耦 异步化, 扮演非常重要的角色. 本系列主要研究kafka的思想和使用, 本文主要讲解kafka的一些基本概念和api的使用. 准备工作 配置maven依赖 lt dependency gt lt groupId gt org.apache.kafka lt ...

2014-07-22 16:00 0 4788 推荐指数:

查看详情

kafka系列九、kafka事务原理、事务API使用场景

一、事务场景 最简单的需求是producer发的多条消息组成一个事务这些消息需要对consumer同时可见或者同时不可见 。 producer可能会给多个topic,多个partition发消息,这些消息也需要能放在一个事务里面,这就形成了一个典型的分布式事务。 kafka的应用 ...

Sun Dec 16 07:52:00 CST 2018 0 10626
kafka系列五、kafka常用java API

引入maven包 一、同步发送消息 1、创建topic: ./bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --partitions 3 --replication-factor 1 --topic ...

Tue Dec 11 07:16:00 CST 2018 0 2795
Kafka ACL使用实战

自0.9.0.0.版本引入Security之后,Kafka一直在完善security的功能。当前Kafka security主要包含3大功能:认证(authentication)、信道加密(encryption)和授权(authorization)。信道加密就是为client到broker ...

Fri Aug 18 00:47:00 CST 2017 17 8243
kafka api的基本使用

kafka API kafka Consumer提供两套Java API:高级Consumer API、和低级Consumer API。 高级Consumer API 优点: 高级API写起来简单,易用。 不需要自行去管理offset,API已经封装好了offset这块的东西,会通 ...

Thu May 09 02:46:00 CST 2019 0 856
kafka java API使用

  Kafka包含四种核心的API:   1、Producer API支持应用将数据流发送到Kafka集群的主题   2、Consumer API支持应用从Kafka集群的主题中读取数据流   3、Streams API支持数据流从输入主题转化到输出主题   4、Connect API支持 ...

Fri Sep 14 23:14:00 CST 2018 0 4609
Kafka系列三 java API操作

使用java API操作kafka 1.pom.xml 2.producer和consumer配置文件   2.1producer.properties   2.2consumer.properties 3.生产者和消费者代码   3.1 ...

Fri Mar 16 18:33:00 CST 2018 0 2665
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM