Kafka 快速入门官方教程技术
希望对初学者有帮助。
此教程假设你开始一个新的环境，不存在 Kafka 和 ZooKeeper 数据。Kafka 控制台脚本在 Unix 环境和 Windows 环境略有不同，在 Windows 上请将 "bin/" 替换为 "bin\windows\" 然后加上脚本后缀 ".bat"。
下载
下载编译好的 Kafka 解压：
$ tar -zxf kafka_2.11-0.11.0.0.tgz $ cd kafka_2.11-0.11.0.0
启动服务
启动一个单节点 ZooKeeper 实例，默认 2181 端口。
$ nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
Error: Could not find or load main class config.zookeeper.properties技术
本文希望帮助那些刚入门学习 Kafka 的朋友。
启动时报错，Error: Could not find or load main class config.zookeeper.properties，怎么办？
起因，下载的是源码，应该下载已编译好的压缩包。
http://kafka.apache.org/downloads.html
Released June 28, 2017
Release Notes
Source download: kafka-0.11.0.0-src.tgz (asc, md5)
Binary downloads:
Scala 2.11 - kafka_2.11-0.11.0.0.tgz (asc, md5)
Java jdbc Mysql datetime 多个 .0技术
数据库字段为 datetime 类型，Java 中 Entity 使用 String 类型，选出的数据后面会包含 ".0"，有人说是由于 MySQL datetime 是包含毫秒的。如下时间格式：
2017-07-12 18:08:02.0
一个不太文雅的解决方案，简单粗暴。
public String getCreateTimeStr() {
if (create_time == null) {
return "";
}
return create_time.substring(0, create_time.length() - 2);
}
不知道那些 Java 高手是怎么做的，欢迎评论。
两种父母与他们的孩子院内
晚上在餐厅吃饭，空气宁静。
中途，来了一家子在邻桌。不一会，孩子们手舞足蹈，站台沙发上蹦蹦跳跳，嘴上说个不停像是现在白天的知了，时而坐在沙发靠背上，已经影响到我们了。
孩子们的父亲对我们笑着说：不好意思啊，孩子比较吵。我们笑了笑。
事情到此结束，没有问题，一会儿也就烟消云散。谁知世间竟有那么蹊跷的事情，偏偏要让人铭心刻骨。
须臾，来了一家三口，爸爸妈妈带着小女儿，也是坐在我们邻桌，这桌没有沙发。
小女儿不知怎么回事，难道是看到那桌小朋友有沙发？就嘟囔着要坐沙发。但这个小姑娘的妈妈马上就训话到：“哪里有沙发啦，要坐什么沙发？又不是有人跟你抢沙发？”。小姑娘就鼓着嘴，不再说话了。
看到这种情形！老婆和我说：“那一桌的小孩也太吵了吧，父母也不管”。我对老婆说：以后我们的宝宝会不会像他们一样。老婆说，当然不会啊。
Spring Boot Jpa 使用原生 SQL 和动态分页技术
使用 Jpa 分页报个错：
Cannot use native queries with dynamic sorting and/or pagination in method public abstract org.springframework.data.domain.Page
Jpa 的原生 SQL 对命名没有严格的要求，如下示例：
package com.lmlphp.test;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.data.repository.query.Param;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
public interface TestRepository extends JpaRepository<Test, Long> {
@Query(
value="select * from table_name where status=:status \n#pageable\n",
countQuery = "select count(*) from table_name where status=:status",
nativeQuery=true)
Page<Test> findByStatus(@Param("status") int status, Pageable pageable);
}