KafkaBuilderExtensions
Class static net8.0
Provides extension methods for adding Kafka resources to the application model.
namespace Aspire.Hosting;
public static class KafkaBuilderExtensions{ // ...} 5 members
Methods5
Section titled MethodsAddKafka(IDistributedApplicationBuilder, string, int?)extensionats exportIResourceBuilder<KafkaServerResource> Adds a Kafka resource to the application. A container is used for local development.
WithDataBindMount(IResourceBuilder<KafkaServerResource>, string, bool)extensionats exportIResourceBuilder<KafkaServerResource> Adds a bind mount for the data folder to a Kafka container resource.
WithDataVolume(IResourceBuilder<KafkaServerResource>, string?, bool)extensionats exportIResourceBuilder<KafkaServerResource> Adds a named volume for the data folder to a Kafka container resource.
WithHostPort(IResourceBuilder<KafkaUIContainerResource>, int?)extensionats exportIResourceBuilder<KafkaUIContainerResource> Configures the host port that the KafkaUI resource is exposed on instead of using randomly assigned port.
WithKafkaUI(IResourceBuilder<KafkaServerResource>, Action<IResourceBuilder<KafkaUIContainerResource>>, string?)extensionats exportIResourceBuilder<KafkaServerResource> Adds a Kafka UI container to the application.