24 Commits

Author	SHA1	Message	Date
mcy	62f975deeb	加上 if (logger.isDebugEnabled()) 防止message.toString每次都会被运行，message过大会卡cpu	2018-08-17 19:55:08 +08:00
winger	2accfbf5db	升级Kafka 版本至 2.11_1.1.1	2018-08-17 19:55:08 +08:00
七锋	c421ff718b	preapre for 1.1.0 release	2018-08-17 19:55:08 +08:00
winger	8a952d3a5f	fix bug: kafka get row data for performance	2018-08-06 11:11:57 +08:00
七锋	26edbeaa28	fixed kafka performance	2018-08-02 13:58:41 +08:00
winger	3d5f13fec8	kafka producer 适配 row data for performance #726	2018-07-31 10:34:19 +08:00
mcy	f867b183ab	降低kafka依赖的版本为0.9.0.1 ... 申明server的running为volatile	2018-06-18 12:15:28 +08:00
七锋	a4255a6377	fixed format	2018-06-14 19:25:34 +08:00
rewerma	e23a19cd85	整理代码	2018-06-13 18:29:15 +08:00
rewerma	df668a6f72	kafka 修改日志输出问题	2018-06-13 17:20:16 +08:00
rewerma	cb6c7ef3e8	完善注释	2018-06-13 14:24:32 +08:00
rewerma	4bd2a79905	kafka pom调整	2018-06-13 14:17:07 +08:00
rewerma	345e22bd2c	kafka 设置独立logback.xml	2018-06-13 14:16:37 +08:00
rewerma	efb7b32694	kafka producer 修改配置，一个destination可以对应多个kafka topic	2018-06-13 13:36:28 +08:00
rewerma	d991e6be60	kafka 客户端消费代码整理	2018-06-13 10:34:28 +08:00
rewerma	e7846085fc	kafka 客户端消费完成基本测试	2018-06-12 19:25:03 +08:00
rewerma	6faa3fd586	增加对message的验证，过滤transaction begin end 类型	2018-06-12 13:28:49 +08:00
rewerma	3e97e6b771	整理pom格式	2018-06-12 10:53:46 +08:00
rewerma	330da50a5e	修改kafka配置项属性	2018-06-12 10:23:50 +08:00
rewerma	e35a06743c	增加kafka的日志	2018-06-12 09:46:54 +08:00
rewerma	e4cde2f6a1	修改withoutNetty的bug	2018-06-12 09:00:55 +08:00
machengyuan4081	9b7d62717e	kafka system.properties 的 bug	2018-06-11 23:31:02 +08:00
machengyuan4081	b306bde3ec	kafka producer	2018-06-11 23:19:28 +08:00
rewerma	31f72e1aac	增加 kafaka producer 直接从canal server消费数据发送	2018-06-11 19:52:55 +08:00