Skip to content

Instantly share code, notes, and snippets.

View erhwenkuo's full-sized avatar

ErhWen Kuo erhwenkuo

428 followers · 0 following
View GitHub Profile
@erhwenkuo
erhwenkuo / Marathon-Docker-Mysql
Created May 15, 2016 02:26
{
"id": "mysql-d3",
"container": {
"docker": {
"image": "mysql",
"network": "BRIDGE",
"portMappings": [
{ "containerPort": 3306, "hostPort": 0 }
],
"privileged": true,
@erhwenkuo
erhwenkuo / angular-mqtt-pub.html
Created July 24, 2016 08:02
e2-rtw-s01-homework(angular-mqtt-pub)
<!DOCTYPE html>
<html xmlns="http://www.w3.org/1999/xhtml" ng-app="rtwApp">
<head>
<meta charset="utf-8" />
<title>完成版:Angular-Mqtt-Pub</title>
<link rel="icon" type="image/png" href="assets/imgs/ok.ico">
<link href="assets/css/bootstrap.css" rel="stylesheet" /> <!-- 讓網頁漂亮一點的CSS Style -->
<link href="assets/css/main.css" rel="stylesheet" /> <!-- 讓表單與角落離開一點 -->
<script src="assets/js/angular.min.js"></script> <!-- 操控網頁元件的函式庫 -->
@erhwenkuo
erhwenkuo / angular-mqtt-sub.html
Created July 24, 2016 08:05
e2-rtw-s01-homework(angular-mqtt-sub)
<!DOCTYPE html>
<html xmlns="http://www.w3.org/1999/xhtml" ng-app="rtwApp">
<head>
<meta charset="utf-8" />
<title>完成版:Angular-Mqtt-Sub</title>
<link rel="icon" type="image/png" href="assets/imgs/ok.ico">
<link href="assets/css/bootstrap.css" rel="stylesheet" /> <!-- 讓網頁漂亮一點的CSS Style -->
<link href="assets/css/main.css" rel="stylesheet" /> <!-- 讓表單與角落離開一點 -->
<script src="assets/js/angular.min.js"></script> <!-- 操控網頁元件的函式庫 -->
@erhwenkuo
erhwenkuo / docker-compose.yml
Created August 13, 2018 08:16
ak-training-env-docker
---
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:5.0.0
hostname: zookeeper
ports:
- "2181:2181"
environment:
ZOOKEEPER_CLIENT_PORT: 2181
@erhwenkuo
erhwenkuo / ds01_AdminClient_cluster_info.java
Last active November 4, 2018 02:29
使用Kafka的AdminClient API來查詢Kafka叢集的基本資料
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.DescribeClusterResult;
import org.apache.kafka.clients.admin.KafkaAdminClient;
import org.apache.kafka.common.Node;
import java.util.Collection;
import java.util.Properties;
import java.util.concurrent.ExecutionException;
/**
* Kafka的AdminClient函式庫，支持管理和檢查topics, brokers, configurations和ACLs。
@erhwenkuo
erhwenkuo / ds01_AdminClient_create_topics.java
Last active November 4, 2018 02:29
使用Kafka的AdminClient API來創建新的Kafka Topic
import org.apache.kafka.clients.admin.*;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.Node;
import java.util.*;
import java.util.concurrent.ExecutionException;
/**
* Kafka的AdminClient函式庫，支持管理和檢查topics, brokers, configurations和ACLs。
* 所需的最小的Kafka broker版本為0.10.0.0。有些API會需要更高版本的Kafka broker的話會註解在API中。
@erhwenkuo
erhwenkuo / ds01_AdminClient_describe_topics.java
Last active July 6, 2021 03:55
使用Kafka的AdminClient API來查詢Kafka Topic的meta data
import org.apache.kafka.clients.admin.*;
import org.apache.kafka.common.Node;
import org.apache.kafka.common.TopicPartitionInfo;
import java.util.*;
import java.util.concurrent.ExecutionException;
/**
* Kafka的AdminClient函式庫，支持管理和檢查topics, brokers, configurations和ACLs。
* 所需的最小的Kafka broker版本為0.10.0.0。有些API會需要更高版本的Kafka broker的話會註解在API中。
*/
@erhwenkuo
erhwenkuo / ds01_AdminClient_delete_topics.java
Created November 4, 2018 02:32
使用Kafka的AdminClient API來刪除Kafka Topic
import org.apache.kafka.clients.admin.*;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.errors.UnknownTopicOrPartitionException;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ExecutionException;
@erhwenkuo
erhwenkuo / ds01_AdminClient_describe_cg_info.java
Last active June 8, 2022 06:55
使用Kafka的AdminClient API來查詢Kafka中每一個ConsumerGroup己經消費過的offset最大值
import org.apache.kafka.clients.admin.*;
import org.apache.kafka.clients.consumer.OffsetAndMetadata;
import org.apache.kafka.common.TopicPartition;
import java.util.*;
import java.util.concurrent.ExecutionException;
/**
* Kafka的AdminClient函式庫，支持管理和檢查topics, brokers, configurations和ACLs。
* 所需的最小的Kafka broker版本為0.10.0.0。有些API會需要更高版本的Kafka broker的話會註解在API中。
@erhwenkuo
erhwenkuo / ds01_AdminClient_describe_cg_info2.java
Created November 9, 2018 06:31
使用Kafka的AdminClient API來查詢Kafka中特定ConsumerGroup的offset
import org.apache.kafka.clients.admin.*;
import org.apache.kafka.clients.consumer.OffsetAndMetadata;
import org.apache.kafka.common.TopicPartition;
import java.util.*;
import java.util.concurrent.ExecutionException;
/**
* Kafka的AdminClient函式庫，支持管理和檢查topics, brokers, configurations和ACLs。