Recent Posts

在 Docker 中初始化 MongoDB 資料

 1. 在專案資料夾放一個檔案 ./mongo/docker-entrypoint-initdb.d:/initdb.sh ``` echo '=====================================>' mongo --eval 'db.getSiblingDB("testqq...

Start Kafka by docker-compose

docker-compose.yml services: zookeeper-server: image: bitnami/zookeeper:latest ports: - "2181:2181" environment: - ALLOW_ANONYMOUS_...

用 docker-compose 啟動 Kafka

docker-compose.yml services: zookeeper-server: image: bitnami/zookeeper:latest ports: - "2181:2181" environment: - ALLOW_ANONYMOUS_LO...

Kafka Client assign 與重設 offset

 1. Producer 發送訊息 ``` private static void sendMessages(Properties kafkaProps, String topic) {     for (int i = 0; i < MSG_COUNT; i++) { &nb...

Kafka Consumer specify offset

1. Producer send messages ``` private static void sendMessages(Properties kafkaProps, String topic) {     for (int i = 0; i < MSG_COUNT; i++) { ...

Kafka Consumer 指定 offset

1. Producer 發送訊息 ``` private static void sendMessages(Properties kafkaProps, String topic) {     for (int i = 0; i < MSG_COUNT; i++) {   &n...

Kafka Client Java Example

 Full Example: https://github.com/shooeugenesea/study-practice/blob/kafka/src/main/java/examples/Main.java Create topic by Java private static void cr...

Kafka Client Java 範例

 完整範例: https://github.com/shooeugenesea/study-practice/blob/kafka/src/main/java/examples/Main.java 用 Java 建立 topic private static void createTopicIfNot...

Run Kafka by docker

 https://itnext.io/how-to-install-kafka-using-docker-a2b7c746cbdc Create network $ sudo docker network create kafka-net --driver bridge Install zookee...

用 Docker 跑 Kafka

 https://itnext.io/how-to-install-kafka-using-docker-a2b7c746cbdc 建立網路 $ sudo docker network create kafka-net --driver bridge 安裝 Zookeeper 容器 $ sudo d...

MongoDB config docker cluster

Start mongo and bind with interfacesudo docker run --name mongo1 -d -p 27017:27017 mongo --bind_ip_all --replSet rs1sudo docker run --name mongo2 -d -p 27018...

MongoDB Docker 叢集設定

啟動 mongo 並綁定網路介面sudo docker run --name mongo1 -d -p 27017:27017 mongo --bind_ip_all --replSet rs1sudo docker run --name mongo2 -d -p 27018:27017 mongo --bind...

MongoDB group

 $group to group data by specified attribute // prepare data> db.company.insertOne({"name":"A","foundYear":1980,"numberOfEmployee":50}){ "ackn...

MongoDB Group（分組）

 $group 依指定屬性分組資料 // prepare data> db.company.insertOne({"name":"A","foundYear":1980,"numberOfEmployee":50}){ "acknowledged" : true, "i...