Trình bày các công nghệ CLOUD một cách dễ hiểu.
![[Kafka-connect]Single Message Transform: lesson 3 – Flatten and LongConverter](https://nimtechnology.com/wp-content/uploads/2022/02/Screen-Shot-2022-02-21-at-10.36.27.png)
Khi data trong 1 topic ở format Avro,… mà ta muốn sink vào DB thì nó sẽ bị lỗi ở việc tạo field column cho 1 table. 1) Setup the components. Phần setup kafka, bạn có thể coi lại link này he:Setup the needing components of Kafka 2) Practice. Launch ksqlDB: OK giờ bạn thấy…
Read More “[Kafka-connect]Single Message Transform: lesson 3 – Flatten and LongConverter” »
![[Kafka-connect] Single Message Transform: lesson 2 – ValueToKey and ExtractField in Sink](https://nimtechnology.com/wp-content/uploads/2022/02/Screen-Shot-2022-02-20-at-23.21.46.png)
1) Setup Phần setup kafka, bạn có thể coi lại link này he:Setup the needing components of Kafka 2) Practice giờ chui vào mysql nghịch: tạo table và insert data. Giờ chúng ta đã có table mới: Create source connector reference links:https://github.com/confluentinc/demo-scene/blob/master/kafka-connect-single-message-transforms/day2.adochttps://docs.confluent.io/current/connect/kafka-connect-jdbc/source-connector/Kafka Connect Deep Dive – JDBC Source Connector Giờ bạn run command để tạo…
![[Kafka-connect] A few APIs are helpful in Kafka-connect.](https://nimtechnology.com/wp-content/uploads/2022/02/0_BL5luf8JGjn459u6.png)
list topic: List các connector: show status connector: show config connector: delete connector show error or exception a task of a connector:
![[Kafka-connect] Single Message Transform: lesson 1 – InsertField in Sink](https://nimtechnology.com/wp-content/uploads/2022/02/image-217.png)
Bài này chúng ta sem cách anh tây hướng dẫn insert field hay còn gọi là cột dữ liệu mà ảnh muốn khi mà anh sink data từ topic của kafka vào database (Mysql) và đây là bài của ảnh:https://github.com/confluentinc/demo-scene/blob/master/kafka-connect-single-message-transforms/day1.adoc 1) Setup the needing components of Kafka Và dưới đây là phần note của mình:…
Read More “[Kafka-connect] Single Message Transform: lesson 1 – InsertField in Sink” »
![[Kafka-connect] Streaming the data of Postgresql through Kafka-connect and Debezium plugin.](https://nimtechnology.com/wp-content/uploads/2022/02/1_QHyilhmVJi6N29YAzTuZTQ.png)
Ố dè! Chúng ta thử lab kafka-connect sẽ stream 1 table trong 1 database của postgres vào 1 topic trong kafka. 1) Install postgresql Chúng ta có 1 file compose postgresql. rồi anh em gõ docker-compose up -d nhé giờ tiến hành exec vào container postgres tạo 1 table Nếu cần add thêm table vào…
![[Kafka-connect] Streaming the data of MySQL throughs Kafka-connect and Debezium plugin.](https://nimtechnology.com/wp-content/uploads/2022/02/debezium-1024x423-1.png)
1) Install and configurate mysql to use to the kafka-connect Lab. Run docker MySQL: giờ sửa file: mysql.cnf xong rồi thoát ra restart docker In order for Debezium MySQL to track all the changes in bin-log, it needs a user with SELECT, RELOAD, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT permissions. Grant them to the user…
![[Kafka] Install kafka and zookeeper cluster on kubernetes.](https://nimtechnology.com/wp-content/uploads/2022/02/zookeeper-kafka.png)
Mới đây mình research ra các cái kafka trên k8s khá tiệnhttps://docs.bitnami.com/tutorials/deploy-scalable-kafka-zookeeper-cluster-kubernetes/ Link helm:https://charts.bitnami.com/bitnami Nó gồm 1 phần: – Install zookeeper. – Install Kafka. 1) Install zookeeper values.yaml Nếu bạn có sài lọnghorn thì ko cần quan tâm đến pvc. Khoẻ re. 2) Install kafka on kubernetes. values.yaml Bạn để ý là mình lựu chọn…
Read More “[Kafka] Install kafka and zookeeper cluster on kubernetes.” »
![[Kafka/Schema-registry] Installing Schema-registry to use for the Kafka and Kafka-connect model](https://nimtechnology.com/wp-content/uploads/2022/02/schema-registry-and-kafka.png)
1) what is the Schema-registry Hiện giờ mình mình cũng chưa hiểu rõ Schema-registry.Mình có 1 số link tham khảo:https://docs.confluent.io/platform/current/schema-registry/index.html#sr-overview A few words about Avro By default, Debezium writes the JSON-formatted data. This method is acceptable for sandboxes and small volumes of data but can be a problem in high-load databases. Avro is an excellent alternative to…
![[Kafka-connect] Install Kafka-connect on Kubernetes through helm-chart.](https://nimtechnology.com/wp-content/uploads/2022/02/Screen-Shot-2022-02-09-at-15.42.22.png)
1) Overview Mình đã có 1 vài bài về kafka cũng như kafka-connect.Kafka-connect thì có nhiệm vụ là Lấy data từ source nào đó như là: file, database, … ===> rồi ghi vào topic của KafkaKhi mà topic đó đã có data:– thì client có read trực tiếp data từ topic đó.– Hoặc sử dụng…
Read More “[Kafka-connect] Install Kafka-connect on Kubernetes through helm-chart.” »
![[Kafka-connect] Install lenses to manage Kafka.](https://nimtechnology.com/wp-content/uploads/2022/02/Screen-Shot-2022-02-09-at-00.50.44.png)
Như bạn thấy mình đã có những bài nói về comand trong kafka cũng như kafka-connectChúng sẽ có 1 UI để quản lý đó là lense, giao diện khá đẹp. 1) License Để run được lenses chúng ta cần có file là license.json 1.1) It’s free! chúng ta cần vào trang web này để đăng…
Read More “[Kafka-connect] Install lenses to manage Kafka.” »
