脚本作用kafkaserverstart.shkafka启动kafkaserverstop.shkafka停止kafkatopics.sh查看创建删除topickafkaconsoleconsumer.sh消费者操作，例如监听topickafkaconsoleproducer.sh生产者操作，例如

在部署前需确保网络正常及已安装JDK和Zookeeper环境JDK安装教程(https://my.oschina.net/linch/blog/1817152)部署Zookeeper(https://my.oschina.net/linch/blog/1816836)zookeeper最好也把IP给绑定上去ClientPortAdd

\resourcejar\_pathclazzjobNamebootstrap\_servertopicgroupIdisSecuritytrueconsumerStrategyredis\_hostnameredis\_portif\"$isSecu

Ahighthroughputdistributedmessagingsystem.\ApacheKafkaKafka作为时下最流行的开源消息系统，被广泛地应用在数据缓冲、异步通信、汇集日志、系统解耦等方面。相比较于RocketMQ等其他常见消息系统，Kafka在保障了大部分功能特性的同时，还提供了超一流的读写性能。本文将针对K

使用flinkFlinkKafkaProducer往kafka写入数据的时候要求使用EXACTLY\_ONCE语义本以为本以为按照官网写一个就完事，但是却报错了代码packagecom.meda.testimportorg.apache.flink.streaming.connectors.kafk

因为两者都是处理日志，数据模型也类似，所以这篇文章主要从技术角度讨论ApacheKafka与DistributedLog的不同点。我们会尽量做到客观，但由于我们不是ApacheKafka的专家，因此我们可能会对ApacheKafka存在误解。如果发现有错，也请大家直接指出。首先，让我们简单地介绍一下Kafka和Distribu

Redis:间值数据库，适合缓存用户Session会话与经常需要查的数据1.Redis集群，为什么在项目中使用集群 1.持久化，持久化是最简单的高可用方法（有时甚至不被归为高可用的手段），主要左右是数据备份，即将数据存储在硬盘，保证数据不会因进程退出而丢失；2、复制：主从复制是高可用Redis的基础，哨兵和集群都是在复制基础上实现高可用

写在前面1.用到了kafka,于是借机会看看代码,顺便复习下Scala,看到一半,换电脑了,搭环境有搭了半天,所以记录下.注意这里是0.8.2.2版本,因为公司用的就是这个版本.依赖的软件1.Git2.ScalaIDE(4.4.1)3.Gradle4.ZooKeeper环

!(https://oscimg.oschina.net/oscnet/f75f01e442b51135178340448c6d282ac43.jpg)(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fmp.weixin.qq.com%2Fs%3F__biz%3DMzU3MzgwNT

缘起生产环境突然报：log地址：kafkalua客户端地址：