Skip to content

Latest commit

 

History

History
13 lines (11 loc) · 858 Bytes

README.md

File metadata and controls

13 lines (11 loc) · 858 Bytes

pulsar-tests

This repo is test cases for pulsar, you may run this test cases for survey purpose. Main code is copied from apache/pulsar.

Quick Start

  1. clone this repo git clone https://github.com/xiaozongyang/pulsar-tests
  2. build runnable jar cd pulsar-tests && ./gradlew fatJar
  3. run test command which produces 10k messages with 100B body filled with 0-9 java -jar build/libs/pulsar-tests-0.0.1-all.jar produce -t test-topic

Available Commands

  • produce: produce messages to pulsar, delayed message supported
  • produce-alternately: produce two kinds of messages, e.g. a, b, a, b, a,b, ...
  • consume: consume messages from specified topic, readCompacted option supported
  • ack: acknowledge instead of consume message by message id fields, i.e., ledgerId, entryId and patitionIndex