FkafkaAdminClient class

kafka admin client

Constructors

FkafkaAdminClient({required FkafkaConf conf})

Properties

hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

fillOffsets(FkafkaTopic topic) → void
fill FkafkaPartition low and high offsets
findGroups({String? group}) List<FkafkaGroup>
find group
findGroupTopicPartitionOffsets(String group, FkafkaTopic topic) List<FkafkaPartition>
find topic partition offsets of group's committed
findTopics({List<String> topics = const []}) List<FkafkaTopic>
find topics
newTopic(String topic) FkafkaTopic
create topic
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
release() → dynamic
release native handle
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited