wang.bigbird.domain.framework.data.kafka.service.impl

类 KafkaAdminServiceImpl

java.lang.Object

wang.bigbird.domain.framework.data.kafka.service.impl.KafkaAdminServiceImpl

所有已实现的接口:

KafkaAdminService

@Service
public class KafkaAdminServiceImpl
extends Object
implements KafkaAdminService

kafka管理者服务

作者:

Bigbird

构造器概要

构造器

构造器和说明
KafkaAdminServiceImpl()

方法概要

限定符和类型	方法和说明
void	createTopic(String name, int numPartitions, short replicationFactor) 创建主体，如果kafka开启了自动创建topic配置， 那么，当生产者向一个不存在的topic发送数据时，会自动创建一个分区数为1，副本数为1的topic， 但这样会影响topic的管理和维护，因此建议采用该方法，在发送数据前，主动创建topic

从类继承的方法 java.lang.Object

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

构造器详细资料

KafkaAdminServiceImpl

public KafkaAdminServiceImpl()

方法详细资料

createTopic

public void createTopic(String name,
                        int numPartitions,
                        short replicationFactor)
                 throws ExecutionException,
                        InterruptedException

从接口复制的说明: KafkaAdminService

创建主体，如果kafka开启了自动创建topic配置， 那么，当生产者向一个不存在的topic发送数据时，会自动创建一个分区数为1，副本数为1的topic， 但这样会影响topic的管理和维护，因此建议采用该方法，在发送数据前，主动创建topic

指定者:

createTopic 在接口中 KafkaAdminService

参数:

name - 主题名称

numPartitions - 分区数

replicationFactor - 副本数

抛出:

ExecutionException

InterruptedException