Kafka transport for NServiceBus
Switch branches/tags
Nothing to show
Clone or download
Latest commit f2b2e2d Mar 22, 2017
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
src BUG: messages are not committed when stopping Mar 22, 2017
.gitattributes solution Dec 1, 2016
.gitignore Default Server modified for executing tests. Dec 23, 2016
LICENSE Initial commit Dec 1, 2016
README.md Update README.md Feb 15, 2017

README.md

Kafka transport for NServiceBus. Part of: https://pablocastilla.wordpress.com/2017/01/03/my-proposal-for-joining-net-and-the-hadoop-ecosystem/

The nuget package NuGet Status

https://www.nuget.org/packages/NServiceBus.Transports.Kafka/

PM> Install-Package NServiceBus.Transports.Kafka

Documentation

https://docs.particular.net/nservicebus/kafka/

Usage

Example of configuring the consumer:

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

Example of configuring the sender:

   static async Task<IEndpointInstance> GetInstance()
    {
        var endpointConfiguration = new EndpointConfiguration("EndpointName");
        endpointConfiguration.UseTransport<KafkaTransport>().ConnectionString("127.0.0.1:9092"); ;
        endpointConfiguration.SendOnly();
        return await Endpoint.Start(endpointConfiguration)
            .ConfigureAwait(false);
    }