Package io.micronaut.configuration.kafka.admin

Class KafkaNewTopics

java.lang.Object

io.micronaut.configuration.kafka.admin.KafkaNewTopics

@Context
@Requires(bean=org.apache.kafka.clients.admin.AdminClient.class) @Requires(bean=org.apache.kafka.clients.admin.NewTopic.class)
public class KafkaNewTopics
extends Object

Creates Kafka topics via AdminClient.

Since:

5.2

Author:

Guillermo Calvo

Constructor Summary

Constructors

Constructor	Description
KafkaNewTopics(@NonNull AdminClient adminClient, @Nullable CreateTopicsOptions options, @NonNull List<NewTopic> topics)

Method Summary

Modifier and Type	Method	Description
@NonNull CreateTopicsResult	getResult()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaNewTopics

public KafkaNewTopics(@NonNull
 @NonNull AdminClient adminClient,
 @Nullable
 @Nullable CreateTopicsOptions options,
 @NonNull
 @NonNull List<NewTopic> topics)

Parameters:

adminClient - The Kafka admin client.

options - Optional CreateTopicsOptions.

topics - The list of NewTopic beans to create.

Method Details

getResult

@NonNull
public @NonNull CreateTopicsResult getResult()

Returns:

The CreateTopicsResult.