Skip to content

Instantly share code, notes, and snippets.

View JoshuaChi's full-sized avatar

Joshua Chi JoshuaChi

18 followers · 32 following
  • ShangHai,China
View GitHub Profile
@JoshuaChi
JoshuaChi / topic-as-stream.sql
Created August 8, 2023 14:49 — forked from confluentgist/topic-as-stream.sql
ksqlDB example: read topic as stream
-- Create ksqlDB stream from Kafka topic.
CREATE STREAM myStream (username VARCHAR, location VARCHAR)
WITH (KAFKA_TOPIC='input-topic', VALUE_FORMAT='...');
@JoshuaChi
JoshuaChi / topic-as-table.sql
Created August 8, 2023 14:49 — forked from confluentgist/topic-as-table.sql
ksqlDB example: read topic as table
-- Create ksqlDB table from Kafka topic.
CREATE TABLE myTable (username VARCHAR, location VARCHAR)
WITH (KAFKA_TOPIC='input-topic', KEY='username', VALUE_FORMAT='...');
@JoshuaChi
JoshuaChi / aggregation.sql
Created August 8, 2023 13:45 — forked from confluentgist/aggregation.sql
ksqlDB example: Continuously aggregating a stream into a table with a push query
-- Continuously aggregating a stream into a table with a ksqlDB push query.
CREATE STREAM locationUpdatesStream ...;
CREATE TABLE locationsPerUser AS
SELECT username, COUNT(*)
FROM locationUpdatesStream
GROUP BY username
EMIT CHANGES;
@JoshuaChi
JoshuaChi / scanner.go
Created January 22, 2022 12:45 — forked from xialeistudio/scanner.go
Golang实现自定义TCP协议
```go
package main
import (
"bufio"
"bytes"
"encoding/binary"
"fmt"
"io"
)
@JoshuaChi
JoshuaChi / tcp_demo.go
Created November 6, 2021 14:51 — forked from hyper0x/tcp_demo.go
The interaction demo via TCP in Golang.
package main
import (
"bufio"
"bytes"
"fmt"
"io"
"log"
"net"
"os"
@JoshuaChi
JoshuaChi / .gitlab.ci.yml
Created July 3, 2021 17:23 — forked from yannhowe/.gitlab.ci.yml
.gitlab.ci.yml for SSH with private key.
# Image neeeds to have ssh-client
image: docker:git
services:
- docker:dind
stages:
- staging
before_script:
- docker login -u gitlab-ci-token -p $CI_BUILD_TOKEN $CI_REGISTRY
@JoshuaChi
JoshuaChi / kafka集群安全认证配置.md
Created July 4, 2019 03:10 — forked from fuyuntt/kafka集群安全认证配置.md

kafka 集群安全认证配置

本文主要介绍下 kafka 0.10.0 版如何实现sasl/plain认证机制及权限控制

kafka安全机制

kakfa 的安全机制主要分为两部分：

  • 身份认证（Authentication）： 对客户端的身份进行认证
  • 权限控制（Authorization）： 对topic级别的权限进行控制

kafka 身份认证

kafka 目前支持 SSL，SASL(Kerberos)，SASL（PLAIN) 三种认证机制。

@JoshuaChi
JoshuaChi / gist:6ea7764d0ca0c93e929731d9cc14543a
Created March 14, 2019 07:08
PLAY [all] *************************************************************************************
TASK [set_fact] ********************************************************************************
Thursday 14 March 2019 07:04:49 +0000 (0:00:00.240) 0:00:00.240 ********
ok: [ip-172-16-0-157.cn-northwest-1.compute.internal]
ok: [ip-172-16-0-231.cn-northwest-1.compute.internal]
ok: [ip-172-16-0-32.cn-northwest-1.compute.internal]
TASK [Storing commands output] *****************************************************************
Thursday 14 March 2019 07:04:49 +0000 (0:00:00.388) 0:00:00.628 ********
@JoshuaChi
JoshuaChi / gist:4bcf4e2eb2ab051dfb45b709712b0815
Created March 14, 2019 07:03
TASK [kubernetes/master : Backup old certs and keys] *******************************************
task path: /home/centos/kubespray/roles/kubernetes/master/tasks/kubeadm-certificate.yml:2
Thursday 14 March 2019 06:05:10 +0000 (0:00:01.655) 0:06:23.774 ********
TASK [kubernetes/master : Remove old certs and keys] *******************************************
task path: /home/centos/kubespray/roles/kubernetes/master/tasks/kubeadm-certificate.yml:16
Thursday 14 March 2019 06:05:10 +0000 (0:00:00.245) 0:06:24.019 ********
TASK [kubernetes/master : Generate new certs and keys] *****************************************
task path: /home/centos/kubespray/roles/kubernetes/master/tasks/kubeadm-certificate.yml:28
@JoshuaChi
JoshuaChi / npm.taobao.sh
Last active December 22, 2017 03:29 — forked from 52cik/npm.taobao.sh
npm 淘宝镜像配置
npm set registry https://registry.npm.taobao.org # 注册模块镜像
npm set disturl https://npm.taobao.org/dist # node-gyp 编译依赖的 node 源码镜像
## 以下选择添加
npm set chromedriver_cdnurl http://cdn.npm.taobao.org/dist/chromedriver # chromedriver 二进制包镜像
npm set operadriver_cdnurl http://cdn.npm.taobao.org/dist/operadriver # operadriver 二进制包镜像
npm set phantomjs_cdnurl http://cdn.npm.taobao.org/dist/phantomjs # phantomjs 二进制包镜像
npm set sass_binary_site http://cdn.npm.taobao.org/dist/node-sass # node-sass 二进制包镜像
npm set electron_mirror http://cdn.npm.taobao.org/dist/electron/ # electron 二进制包镜像
npm set selenium_cdnurl=http://npm.taobao.org/mirrors/selenium