0%

kafka主题

kafka提供了一个kafka-topics.sh用于对主题的相关操作,如创建主题、删除主题、修改主题分区数和副本分配以及修改主题级别的配置信息,查看主题信息等操作。指令包括—list、—describe、—create、—alter和—delete。

阅读全文 »

kafka启动

kafka依赖于zookeeper,在启动kafka之前需要先启动zookeeper,kafka中包含有zookeeper启动脚本,为防止kafka与zookeeper版本问题,使用kafka中自带的zookeeper。

阅读全文 »

CyclicBarrier和CountDownLatch

这两个类都在jdk的并发包中,都可以用来表示代码运行到某个点上

阅读全文 »

mybatis拦截器

mybatis拦截器也叫做插件,mybatis允许开发者自定义拦截器对SQL语句执行过程中的某一个点进行拦截。默认mybatis允许拦截Mybatis中的四大核心对象:Executor中的方法、ParameterHandler的方法、ResultSetHandler的方法以及StatementHandler中的方法

阅读全文 »

kafka监控

kafka使用Yammer Metrics进行内部状态的监控,用来收集报告KafkaServer端和客户端的metrics信息,可以将信息通过JMX、控制台、CSV、日志等形式发布出来。kafka默认通过JMX来报告metrics信息,可以通过JConsole或者Visual VM来查看metrics信息

阅读全文 »