🌟 AI 相关
Stable Diffusion 硬核生存指南:WebUI 中的 GFPGAN
Stable Diffusion 硬核生存指南:WebUI 中的 CodeFormer
Stable Diffusion 硬核生存指南:WebUI 中的 VAE
⭐️ Golang 相关
Golang三色标记混合写屏障GC模式全分析[Go三关典藏版]
浅析bitset的实现原理:一个将非负整数映射到布尔值的位集合库
Golang 如何操作 Kafka
一篇搞定:消息队列概念、kafka入门、Kafka Golang客户端库
Go 1.21 发布已延期,昨天才发布 Go 1.20.7 和 Go 1.21rc4
一款 IDEA 插件帮你优雅转化 DTO、VO、BO、PO、DO
如何用 Docker 容器运行单节点 Kafka 环境
version: '3'
services:
zookeeper:
image: confluentinc/cp-zookeeper
hostname: zookeeper
container_name: zookeeper
ports:
- "2181:2181"
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
kafka:
image: confluentinc/cp-kafka
depends_on:
- zookeeper
hostname: kafka
container_name: kafka
ports:
- "9092:9092"
environment:
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
运行以下命令启动 Kafka:
$ docker-compose up -d
使用以下命令进入 Kafka 容器并使用 Kafka 的命令行工具进行操作:
$ docker exec -it kafka /bin/bash
然后可以使用 Kafka 的命令行工具进行操作,例如,下面的命令会创建一个名为 test 的主题,并将其配置为单个分区和单个副本因子:
$ kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
使用 Kafka 命令行工具中的 kafka-console-producer.sh
脚本来启动一个生产者,可以将消息发送到 test 主题中。在命令行窗口中运行以下命令。当命令行提示符出现时,你可以开始输入消息。每输入一行,该消息就会被发布到 test 主题中。
$ kafka-console-producer --broker-list localhost:9092 --topic test
新开一个终端,使用 Kafka 命令行工具中的 kafka-console-consumer.sh
脚本来启动一个消费者,可以从 test 主题中接收消息。在命令行窗口中运行以下命令。该命令将打印 test 主题中的所有消息。
$ docker exec -it kafka /bin/bash
$ kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
推荐 GoLand 提供的 Kafka 插件:
https://www.jetbrains.com/help/idea/2023.2/big-data-tools-kafka.html#connect_to_kafka_custom
Go语言开发者的Apache Arrow使用指南:读写Parquet文件
GoLand 2023.2 发布:有 AI 助手
Go语言中常见100问题-#41 substrings and memory leaks