Class KafkaNewTopics

java.lang.Object

io.micronaut.configuration.kafka.admin.KafkaNewTopics

@Context
@Requires(bean=Admin.class) @Requires(bean=NewTopic.class)
public class KafkaNewTopics
extends Object

Creates Kafka topics via Admin.

Since:

5.2

Author:

Guillermo Calvo

Constructor Summary

Constructors

Constructor	Description
KafkaNewTopics(@NonNull AdminClient adminClient, @Nullable CreateTopicsOptions options, @NonNull List<NewTopic> topics)	Deprecated, for removal: This API element is subject to removal in a future version. Use KafkaNewTopics(Admin, CreateTopicsOptions, List) instead.
KafkaNewTopics(@NonNull Admin admin, @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

@Deprecated(since="6.3.0",
            forRemoval=true)
public KafkaNewTopics(@NonNull AdminClient adminClient,
 @Nullable CreateTopicsOptions options,
 @NonNull List<NewTopic> topics)

Deprecated, for removal: This API element is subject to removal in a future version.

Use KafkaNewTopics(Admin, CreateTopicsOptions, List) instead.

Parameters:

adminClient - The Kafka admin client.

options - Optional CreateTopicsOptions.

topics - The list of NewTopic beans to create.

KafkaNewTopics

@Inject
public KafkaNewTopics(@NonNull Admin admin,
 @Nullable CreateTopicsOptions options,
 @NonNull List<NewTopic> topics)

Parameters:

admin - The Kafka admin client.

options - Optional CreateTopicsOptions.

topics - The list of NewTopic beans to create.

Since:

6.3.0

Method Details

getResult

public @NonNull CreateTopicsResult getResult()

Returns:

The CreateTopicsResult.