LMLPHP后院

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);
}
LMLPHP,可爱滴WEB开发框架

2017-07-27 04:36:03 1501101363 0.009767