一键在 Manus 中运行任何 Skill

开始使用

event-driven-architecture

星标11

分支0

更新时间2026年7月25日 13:28

Best practices for Kafka/RabbitMQ message brokering and event sourcing.

安装

用 Codex 或 Claude 帮你安装复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。

在 Manus 中运行

来源

j4flmao

j4flmao/agent-skills

打开 GitHub 仓库查看创作者相关仓库

下载

在 Manus 中运行

Event Driven Architecture

Core Concepts

Message Brokering: Decouples producers and consumers.
Event Sourcing: State is determined by a sequence of events.

Diagram

flowchart TD
    A[Producer] --> B(Message Broker)
    B --> C[Consumer 1]
    B --> D[Consumer 2]
    B --> E[(Event Store)]

Go Example (Kafka Producer)

package main

import (
    "github.com/confluentinc/confluent-kafka-go/kafka"
    "log"
)

func produceEvent(topic, message string) {
    p, _ := kafka.NewProducer(&kafka.ConfigMap{"bootstrap.servers": "localhost"})
    defer p.Close()

    p.Produce(&kafka.Message{
        TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny},
        Value:          []byte(message),
    }, nil)
    p.Flush(15 * 1000)
    log.Println("Event produced")
}

同仓库更多 Skills

同仓库

quantum-scientist-persona

j4flmao/agent-skills

Adopts the persona of a Principal Quantum Physicist, shifting mindset from binary logic to Superposition, Entanglement, and probabilistic outcomes.

2026-07-2511

grover-s-algorithm

j4flmao/agent-skills

Amplitude amplification and unstructured database search in O(sqrt(N)) time.

2026-07-2511

qiskit-framework

j4flmao/agent-skills

Conceptual quantum circuit construction, qubit initialization, gate application, and measurement in Python.

2026-07-2511

quantum-entanglement

j4flmao/agent-skills

Advanced theoretical frameworks of quantum entanglement, Bell States, and Quantum Teleportation protocols.

2026-07-2511

qubits-gates

j4flmao/agent-skills

Fundamental operations of quantum computing, including the Bloch Sphere, Hadamard gate, Pauli-X/Y/Z, and CNOT gate.

2026-07-2511

shor-s-algorithm

j4flmao/agent-skills

Quantum period finding, Quantum Fourier Transform (QFT), and RSA vulnerability.

2026-07-2511

name	Event Driven Architecture
description	Best practices for Kafka/RabbitMQ message brokering and event sourcing.

Event Driven Architecture

Core Concepts

Message Brokering: Decouples producers and consumers.
Event Sourcing: State is determined by a sequence of events.

Diagram

flowchart TD
    A[Producer] --> B(Message Broker)
    B --> C[Consumer 1]
    B --> D[Consumer 2]
    B --> E[(Event Store)]

Go Example (Kafka Producer)

package main

import (
    "github.com/confluentinc/confluent-kafka-go/kafka"
    "log"
)

func produceEvent(topic, message string) {
    p, _ := kafka.NewProducer(&kafka.ConfigMap{"bootstrap.servers": "localhost"})
    defer p.Close()

    p.Produce(&kafka.Message{
        TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny},
        Value:          []byte(message),
    }, nil)
    p.Flush(15 * 1000)
    log.Println("Event produced")
}