Kafka Transport Usage

Component: Kafka Transport
NuGet Package NServiceBus.Transports.Kafka (1-pre)
This is a community run project
This page targets a pre-release version and is subject to change prior to the final release.

Prerequisites

Ensure an instance of Kafka is installed and accessible in '127.0.0.1:9092'.

Useful links:

Running the project

  1. Start both the Sender and Receiver projects.
  2. At startup Sender will send a message to Receiver.
  3. Receiver will handle the message.

Code Walk-through

Configure the Kafka

var transport = endpointConfiguration.UseTransport<KafkaTransport>();
transport.ConnectionString("127.0.0.1:9092");

Related Articles


Last modified