Skip to content

Latest commit

 

History

History
70 lines (60 loc) · 2.37 KB

README.md

File metadata and controls

70 lines (60 loc) · 2.37 KB
Raw

Small utility used to produce and consume messages over a messaging provider.

Endpoints available:

path: /v1/messaging/produce

body:

{
  "properties": {
    "bootstrap": "localhost:9092",
    "topic":"test"
  },
  "provider": "KAFKA",
  "quantity": 10,
  "sizeFrom": 2000,
  "sizeTo": 3000
}

For production the following options are available:

  • provider: One of the supported providers. Details below
  • properties: Provider specific properties
  • quantity: number of messages to send
  • sizeFrom: minimum size for the randomly generated message
  • sizeTo: maximum size for the randomly generated message.

Path: /v1/messaging/consume

body:

{
   "properties": {
     "bootstrap": "localhost:9092",
     "topic": "test",
     "groupId": "group1"
 
   },
   "provider": "KAFKA"
 }

For consumption the consumer type and properties are the options allowed to be set.

Supported consumers/producers

ZEROMQ

Properties:

  • Producer:
    • host: Hostname/ip where the consumer is listening
    • port: Port where the consumer is listeing
  • Consumer:
    • port: Port where the consumer should listen
KAFKA

Properties:

  • Producer:
    • bootstrap: Server url to connect to (ex: localhost:9092)
    • topic: Name of the topic where the messages will be published
    • kafka.*: Properties starting with kafka will be passed without the kafka. prefix, for example using kafka.ssl.key.password will set the property ssl.key.password to the kafka client.
    • truststoreEntry: a base64 encoded certificate to be added to the trust store of the kafka client
    • keystoreKey: a base64 encoded key to be added to the key store of the kafka client
    • keystoreChain: A base64 encoded certificate chain to be added to the key store of the kafka client
  • Consumer:
    • bootstrap: Server url to connect to (ex: localhost:9092)
    • topic: Name of the topic to consume
    • groupId: Group id for the consumer
    • kafka.*: Properties starting with kafka will be passed without the kafka. prefix, for example using kafka.ssl.key.password will set the property ssl.key.password to the kafka client.
    • truststoreEntry: a base64 encoded certificate to be added to the trust store of the kafka client
    • keystoreKey: a base64 encoded key to be added to the key store of the kafka client
    • keystoreChain: A base64 encoded certificate chain to be added to the key store of the kafka client