Get started with the Apache Kafka integration

Apache Kafka is a distributed streaming platform that enables you to build real-time data pipelines and streaming applications. The Aspire Apache Kafka integration enables you to connect to existing Kafka instances or create new instances from Aspire with the confluentinc/confluent-local container image.

In this introduction, you’ll see how to install and use the Aspire Apache Kafka integrations in a simple configuration. If you already have this knowledge, see Apache Kafka hosting integration for full reference details.

टिप्पणी

To follow this guide, you must have created an Aspire solution to work with. To learn how to do that, see Build your first Aspire app.

Set up hosting integration

To begin, install the Aspire Kafka hosting integration in your Aspire AppHost project:

Aspire CLI

Aspire CLI — Aspire.Hosting.Kafka पैकेज जोड़ें

aspire add kafka

Aspire CLI इंटरैक्टिव है; प्रॉम्प्ट पर उपयुक्त परिणाम चुनें:

Aspire CLI — उदाहरण आउटपुट

Select an integration to add:

> kafka (Aspire.Hosting.Kafka)
> Other results listed as selectable options...

टिप्पणी

यदि केवल एक परिणाम है तो वह स्वचालित रूप से चुना जाएगा। संस्करण की पुष्टि अभी भी करनी होगी।

apphost.cs (C# file-based app)

C# — AppHost.cs

#:package Aspire.Hosting.Kafka@*

PackageReference (*.csproj)

XML — Aspire.Hosting.Kafka पैकेज संदर्भ जोड़ें

<PackageReference Include="Aspire.Hosting.Kafka" Version="*" />

Next, in the AppHost project, create instances of Kafka resources and pass them to the consuming client projects:

C# — AppHost.cs

var builder = DistributedApplication.CreateBuilder(args);

var kafka = builder.AddKafka("kafka");

builder.AddProject<Projects.ExampleProject>()
       .WithReference(kafka);

builder.Build().Run();

When Aspire adds a container image to the AppHost, it creates a new Kafka server instance on your local machine.

संकेत

If you’d rather connect to an existing Kafka server, call AddConnectionString instead. For more information on how to use WithReference, see Resource dependencies and Configuration injection.

Set up client integration

To get started with the Aspire Apache Kafka client integration, install the package:

.NET CLI

.NET CLI — Add Aspire.Confluent.Kafka package

dotnet add package Aspire.Confluent.Kafka

Program.cs (C# file-based app)

Program.cs

#:package Aspire.Confluent.Kafka@*

PackageReference (*.csproj)

XML — Add Aspire.Confluent.Kafka package reference

<PackageReference Include="Aspire.Confluent.Kafka" Version="*" />

In the Program.cs file of your client-consuming project, call the AddKafkaProducer extension method to register an IProducer<TKey, TValue> for use via the dependency injection container:

builder.AddKafkaProducer<string, string>("kafka");

संकेत

The connectionName parameter must match the name used when adding the Kafka resource in the AppHost project.

You can then retrieve the IProducer<TKey, TValue> instance using dependency injection:

internal sealed class Worker(IProducer<string, string> producer) : BackgroundService
{
    // Use producer...
}

See also

• Apache Kafka hosting integration
• Apache Kafka client integration