class Saler: def __init__(self,name,sex,ident): self.name = name self.sex = sex self.ident = ident def sale(self): print('%s卖东西'%self.name) def add_go ...
分类：
其他好文 时间：
2020-01-15 13:39:52
阅读次数：
63
KafkaConfig.java package com.niugang.config; import java.util.HashMap; import java.util.Map; import org.apache.kafka.clients.consumer.ConsumerConfig; ...
分类：
编程语言 时间：
2020-01-13 14:33:55
阅读次数：
107
kafka的bin目录下有很多脚本，其中kafka-console-producer.sh是生产者脚本、kafka-console-consumer.sh是消费者脚本，下面用这两个脚本进行模拟发送消息和接收消息。在前面的3篇中已经介绍了kafka的配置。按照步骤启动zookeeper和kafka。 ...
分类：
其他好文 时间：
2020-01-12 22:18:30
阅读次数：
129
https://www.cnblogs.com/huxi2b/p/6061110.html 1.老版本的kafka的offset是维护在zk上的，新版本的kafka把consumer的offset维护保存在kafka的内部topic上 bin/kafka-simple-consumer-shell. ...
分类：
其他好文 时间：
2020-01-12 20:24:17
阅读次数：
94
1，Context:不需要在任何组件间添加props方法，可以任意之间的组件树进行 const Context = React.createContext(); const Provider = Context.Provider; //提供者 const Consumer = Context.Con ...
分类：
其他好文 时间：
2020-01-11 20:22:28
阅读次数：
88
Apache Kafka是一个开放源代码流处理软件平台，用于处理实时数据存储。Apache Kafka在两方（即发送方和接收方）之间充当经纪人。它一天可以处理大约数万亿个数据事件。Apache Kafka是一个基于分布式流式处理过程的软件平台。Apache Kafka是一个发布-订阅消息传递系统，它... ...
分类：
Web程序 时间：
2020-01-11 15:20:11
阅读次数：
112
原文链接:https://cloud.tencent.com/developer/article/1462432 一、概述 在新消费者客户端中，消费位移是存储在Kafka内部的主题 __consumer_offsets 中。把消费位移存储起来（持久化）的动作称为 “提交” ，消费者在消费完消息之后需 ...
分类：
其他好文 时间：
2020-01-10 22:36:40
阅读次数：
150
1.变量定义： num = 2+2 num = "2"+2 num = "2"+"2" str = "string"..'string' str = [[ string ]] 2.定义表格： tab = {k="kk",v="vv"} tab = {k="kk","vv"} tab = {"kk". ...
分类：
编程语言 时间：
2020-01-10 15:26:47
阅读次数：
79
Kafka作为时下最流行的开源消息系统，被广泛地应用在数据缓冲、异步通信、汇集日志、系统解耦等方面。相比较于RocketMQ等其他常见消息系统，Kafka在保障了大部分功能特性的同时，还提供了超一流的读写性能。 针对Kafka性能方面进行简单分析，相关数据请参考：https://segmentfau ...
分类：
其他好文 时间：
2020-01-09 20:48:30
阅读次数：
79
今天是继续对之前 kafka 集群遗留问题的查漏补缺。 扩容后对副本进行再平衡： 今天检查 kafka manager 发现了一个 __consumer_offsets 主题（消费者分区位移保存主题）的 leader 副本只被部署在了已有三节点中的两个节点上。并没有将三个 broker 上都平均分布 ...
分类：
其他好文 时间：
2020-01-09 18:39:38
阅读次数：
83
