Skip to content

feat(insepction): add inspection design#3290

Closed
superhx wants to merge 5 commits into
1.6from
cluster_events
Closed

feat(insepction): add inspection design#3290
superhx wants to merge 5 commits into
1.6from
cluster_events

Conversation

@superhx

@superhx superhx commented Apr 7, 2026

Copy link
Copy Markdown
Collaborator

No description provided.

Gezi-lzq added 2 commits April 9, 2026 09:26
* build: align opensource dependency versions

* build: skip legacy netty alias in alignment rule

* build: revert guava baseline bump

* build: remove duplicate oshi version and lib definitions

The oshi key was defined twice in both versions and libs blocks,
with the later definition silently overriding the earlier one.
Remove the stale oshi-core-java11:6.4.7 entries (deprecated since
oshi 6.5) and keep oshi-core:6.8.1 which was already the effective
resolution. No behavioral change.

* Revert "build: remove duplicate oshi version and lib definitions"

This reverts commit b47e964.

* build: remove shadowed oshi version and lib entries

versions.oshi and libs.oshi were each defined twice in the Groovy map.
The earlier entries (oshi-core-java11:6.4.7) were silently overridden
by the later ones (oshi-core:6.8.1) since commit 1119acc. Remove the
shadowed entries to eliminate ambiguity. No behavioral change.
…) (#3298)

* feat(devkit): add namespace support for multi-instance isolation

* docs(devkit): add namespace section to README

* refactor(devkit): simplify namespace implementation

- Remove container_name from docker-compose.yml (COMPOSE_PROJECT_NAME handles isolation)
- Remove DEVKIT_PREFIX variable from set-ns and compose.env
- Replace repetitive port variable assignments with PORT_DEFS array loop
- Simplify PORT_OFFSET reading with grep instead of source
- Simplify chaos-status minio check with case statement
- Fix _node-list exit code when no containers running

* feat(devkit): add python3 and uv to container image
@superhx
superhx force-pushed the cluster_events branch 2 times, most recently from 00956e9 to da733cd Compare April 13, 2026 03:36
@superhx
superhx force-pushed the cluster_events branch 4 times, most recently from 5d7f2dc to c6e714e Compare April 14, 2026 06:36
Introduce a cluster-level event system that publishes structured events
to the __automq_cluster_events internal topic using CloudEvents + protobuf.

Core infrastructure:
- ClusterEventPublisher: async, best-effort producer that wraps events
  as CloudEvents and writes them to the internal topic
- ClusterEventsReader: consumer-based reader for retrieving events
- ClusterEventsCommand: CLI tool (kafka-cluster-events.sh) for reading
  and displaying cluster events

RequestErrorEvent pipeline:
- Detects sustained request error patterns (e.g. auth failures,
  authorization errors) on the broker and publishes them as events,
  enabling the control plane to surface risky or misconfigured clients
- Integrated into RequestChannel and KafkaApis to capture errors on the
  broker request path
- ResourceErrorExtractor parses per-resource error codes from Kafka API
  responses (Produce, Fetch, Metadata, etc.)
- RequestErrorAccumulator aggregates errors in-memory by
  (apiKey, errorCode, resource) with client IP/ID tracking, then
  periodically flushes accumulated buckets as RequestErrorEvent records
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants