Skip to content

Latest commit

 

History

History

samples

README.md

Silverback Samples

This solution contains a set of samples based on Silverback.

Prerequisites

Start the docker compose file in the repository root.

cd ..
docker-compose up -d

Kafka

Basic

Produce and consume basic messages.

  1. Run the two applications
    1. dotnet run -p ./samples/Kafka/Basic.Producer/.
    2. dotnet run -p ./samples/Kafka/Basic.Consumer/.
  2. Observe the console output while the messages are produced and consumed

Batch Processing

Process consumed messages in batch.

  1. Run the two applications
    1. dotnet run -p ./samples/Kafka/Batch.Producer/.
    2. dotnet run -p ./samples/Kafka/Batch.Consumer/.
  2. Observe the console output while the messages are produced and consumed

Binary Files Streaming

Binary file streaming through Kafka.

  1. Run the two applications
    1. dotnet run -p ./samples/Kafka/BinaryFileStreaming.Producer/.
    2. dotnet run -p ./samples/Kafka/BinaryFileStreaming.Consumer/.
  2. Browse the producer Swagger UI to fire the sample requests
    1. http://localhost:10001/swagger
  3. The consumed files will be saved in samples/temp

Avro

Produce and consume messages serialized as Avro using the schema registry.

  1. Run the two applications
    1. dotnet run -p ./samples/Kafka/Avro.Producer/.
    2. dotnet run -p ./samples/Kafka/Avro.Consumer/.
  2. Observe the console output while the messages are produced and consumed

MQTT

Basic

Produce and consume basic messages.

  1. Run the two applications
    1. dotnet run -p ./samples/MQTT/Basic.Producer/.
    2. dotnet run -p ./samples/MQTT/Basic.Consumer/.
  2. Observe the console output while the messages are produced and consumed

Basic but using protocol version 3.1.0

Produce and consume basic messages.

  1. Run the two applications
    1. dotnet run -p ./samples/MQTT/Basic.ProducerV3/.
    2. dotnet run -p ./samples/MQTT/Basic.ConsumerV3/.
  2. Observe the console output while the messages are produced and consumed

Binary Files Streaming

Binary file streaming over MQTT.

  1. Run the two applications
    1. dotnet run -p ./samples/MQTT/BinaryFileStreaming.Producer/.
    2. dotnet run -p ./samples/MQTT/BinaryFileStreaming.Consumer/.
  2. Browse the producer Swagger UI to fire the sample requests
    1. http://localhost:10001/swagger
  3. The consumed files will be saved in samples/temp