Class KafkaNewTopics

java.lang.Object

io.micronaut.configuration.kafka.admin.KafkaNewTopics

@Context
@Requires(bean=AdminClient.class) @Requires(bean=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 Object

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

Constructor Details

KafkaNewTopics

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

Parameters:

adminClient - The Kafka admin client.

options - Optional CreateTopicsOptions.

topics - The list of NewTopic beans to create.

Method Details

getResult

public @NonNull CreateTopicsResult getResult()

Returns:

The CreateTopicsResult.