القائمة
Message-queue engines in DBClient: Kafka, Pulsar, RabbitMQ, and RocketMQ. Use this skill when adding, debugging, or modifying such a Tester.
التثبيت باستخدام Codex أو Claude انسخ هذا Prompt والصقه في Codex أو Claude أو مساعد آخر ليراجع صفحة Skill ويثبّتها لك.
استنادا إلى تصنيف SOC المهني
Practical guide for adding a new database or middleware engine to DBClient. Use this skill when you need to introduce a new dbType.
Cross-cutting core mechanisms of DBClient: CLI argument parsing, DBConfig, TesterFactory, TestExecutor, and the DatabaseTester interface. Use this skill when modifying generic flows or adding engine registration, validation, or dependencies.
KV / coordination engines in DBClient: Redis, RedisCluster, Redis Sentinel, Camellia-Proxy, Etcd, and Zookeeper. Use this skill when adding, debugging, or modifying such a Tester.
Relational / JDBC-protocol-compatible engines in DBClient. Covers MySQL-compatible, PostgreSQL-compatible, Oracle, SQLServer, domestic / regulated databases, and analytical databases such as StarRocks, Doris, and ClickHouse. Use this skill when adding, debugging, or modifying such a Tester.
Search / log-retrieval engines in DBClient: Elasticsearch 8.x and OpenSearch. Use this skill when adding, debugging, or modifying such a Tester.
Document / object / graph / big-data storage engines in DBClient: MongoDB, MinIO, Hadoop, Hive, Vault, and Nebula. Use this skill when adding, debugging, or modifying such a Tester.
| name | dbclient-engine-mq |
| description | Message-queue engines in DBClient: Kafka, Pulsar, RabbitMQ, and RocketMQ. Use this skill when adding, debugging, or modifying such a Tester. |
| Engine | Tester | Aliases |
|---|---|---|
| Kafka | KafkaTester.java | kafka |
| Pulsar | PulsarTester.java | pulsar |
| RabbitMQ | RabbitMQTester.java | rabbitmq |
| RocketMQ | RocketMQTester.java | rocketmq |
build.gradle)// Kafka
implementation 'org.apache.kafka:kafka-clients:2.8.0'
// Pulsar
implementation 'org.apache.pulsar:pulsar-client:2.10.0'
implementation 'org.apache.pulsar:pulsar-client-admin:2.10.0'
// RabbitMQ
implementation 'com.rabbitmq:amqp-client:5.23.0'
// RocketMQ
implementation 'org.apache.rocketmq:rocketmq-client:4.9.8'
implementation 'org.apache.rocketmq:rocketmq-tools:4.9.8'
| Parameter | Purpose |
|---|---|
-T / --topic | Topic for Kafka / Pulsar / RocketMQ |
-k / --key | Message key |
-C / --cluster | Cluster name for RocketMQ, etc. |
-B / --bucket | Used mainly for object storage; rarely used for MQ |
execute() of an MQ Tester usually means "produce/consume one message", not SQL semantics; the query parameter format is defined by each Tester.java -jar build/libs/oneclient-1.0-all.jar \
-h 127.0.0.1 -P 9092 -e kafka -t query \
-T my-topic -q "test-message"
KafkaTester is a good reference template.