Optional options: Partial<Options>Optional rackGenerated using TypeDoc
Optional options: Partial<Options>Optional rackGenerated using TypeDoc
const fluvio = new Fluvio({ host, port })
await fluvio.connect();
const admin = await fluvio.admin();
Creating an admin client will fail if you do not have admin authorization in the connected custer.
-Optional options: Partial<Options>Optional values inherited from top-level options;
-Private innerOptional optionsPrivate innerOptional optionsCreate a new custom Streaming Processing Unit (SPU)
Name of the custom spu;
Optional spec: CustomSpuSpecPass in a custom spec or use a default based on top-level options;
-Create a new custom Streaming Processing Unit (SPU)
+Create a new custom Streaming Processing Unit (SPU)
Name of the custom spu;
Optional spec: CustomSpuSpecPass in a custom spec or use a default based on top-level options;
-Create a new managed Streaming Processing Unit (SPU)
name of the managed spu group
Optional spec: SpuGroupSpecOptional specification for the SpuGroup. If no spec is provided, default settings will be used.
-Create a new managed Streaming Processing Unit (SPU)
+Create a new managed Streaming Processing Unit (SPU)
name of the managed spu group
Optional spec: SpuGroupSpecOptional specification for the SpuGroup. If no spec is provided, default settings will be used.
-Create a new topic with an optional topic specification;
+Create a new topic with an optional topic specification;
name of the topic
Optional spec: PartitionMaps | TopicReplicaParamTopic specification
-Create a new topic with an optional topic specification;
+Create a new topic with an optional topic specification;
name of the topic
Optional spec: PartitionMaps | TopicReplicaParamTopic specification
-Delete a custom SPU using either a string or number;
SPU key to target for deletion;
-Delete a custom SPU using either a string or number;
+Delete a custom SPU using either a string or number;
SPU key to target for deletion;
-Delete a managed SPU by name
Name of the managed SPU to delete;
-Delete a managed SPU by name
+Delete a managed SPU by name
Name of the managed SPU to delete;
-Delete a topic by name
Name of the topic to delete
-Delete a topic by name
+Delete a topic by name
Name of the topic to delete
-Find a partition by topic name;
+Find a partition by topic name;
topic name to search partition by
-Find a partition by topic name;
+Find a partition by topic name;
topic name to search partition by
-Find a topic by name
+Find a topic by name
Name of the topic to find;
-Find a topic by name
+Find a topic by name
Name of the topic to find;
-Generated using TypeDoc
The native FluvioAdmin module, must be the value returned from
await new Fluvio().admin();