My FastStream service 0.1.0

Description of my FastStream service

Servers

  • localhostkafka autodevelopment
    Security:
    security.protocol:PLAINTEXT

Operations

  • PUB names:OnNames

    Consumes messages from names topic and produces messages to greetings topic

    Operation IDsubscribe

    Available only on servers:

    object

    Accepts the following message:

    names:OnNames:Messagenames:OnNames:Message
    Message IDnames:OnNames:Message
    Correlation ID$message.header#/correlation_id
    object

    Examples

  • SUB greetings:Publisher

    Produces a message on greetings after receiving a meesage on names

    Operation IDpublish

    Available only on servers:

    object

    Accepts the following message:

    greetings:Publisher:Messagegreetings:Publisher:Message
    Message IDgreetings:Publisher:Message
    Correlation ID$message.header#/correlation_id
    Payload
    any

    Examples

Messages

  • #1names:OnNames:Messagenames:OnNames:Message
    Message IDnames:OnNames:Message
    Correlation ID$message.header#/correlation_id
    object
  • #2greetings:Publisher:Messagegreetings:Publisher:Message
    Message IDgreetings:Publisher:Message
    Correlation ID$message.header#/correlation_id
    Payload
    any

Schemas

  • object
  • greetings:PublisherPayload
    any