My FastStream service 0.1.0

Description of my FastStream service

Servers

  • localhost:9092kafka autodevelopment
    Security:
    security.protocol:PLAINTEXT

Operations

  • SUB OnNames

    Consumes messages from names topic and produces messages to greetings topic

    Available only on servers:

    Accepts the following message:

    OnNamesMessageOnNamesMessage
    Correlation ID$message.header#/correlation_id
    object
    uid: Name

    Examples

  • PUB GreetingsPublisher

    Produces a message on greetings after receiving a message on names

    Available only on servers:

    Accepts the following message:

    GreetingsPublisherMessageGreetingsPublisherMessage
    Correlation ID$message.header#/correlation_id
    Payload
    any
    uid: GreetingsPublisherPayload

    Examples

Messages

  • #1OnNamesMessageOnNamesMessage
    Correlation ID$message.header#/correlation_id
    object
    uid: Name
  • #2GreetingsPublisherMessageGreetingsPublisherMessage
    Correlation ID$message.header#/correlation_id
    Payload
    any
    uid: GreetingsPublisherPayload

Schemas

  • object
    uid: Name
  • GreetingsPublisherPayload
    any
    uid: GreetingsPublisherPayload