kafka_admin_class | R Documentation |
R6 Class for Kafka Admin
R6 Class for Kafka Admin
java_admin
reference to the underlying Java object Initialize
new()
Create a new admin object.
Instead of kafka_admin_class$new()
one can use kafka_admin()
kafka_admin_class$new()
self
for method chaining
finalize()
Code run when object is removed from session
kafka_admin_class$finalize()
start()
Spin up admin and connect it to Kafka cluster
kafka_admin_class$start()
self
for method chaining
end()
Disconnect admin from Kafka cluster
kafka_admin_class$end()
self
for method chaining
restart()
Disconnect and reconnect admin from Kafka cluster
kafka_admin_class$restart()
self
for method chaining
running()
Whether or not admin is active (has been started or not)
kafka_admin_class$running()
TRUE/FALSE
props()
Retrieving current current set of properties. If properties are supplied via props parameter thos properties will be set.
kafka_admin_class$props(..., .properties = NULL)
...
a series of properties provided as key = "values"
.properties
a list of properties provided as .properties = list(key = "values", ...)
returns a list of properties
topics_list()
Query and return list of topics.
kafka_admin_class$topics_list()
returns a character vector of topics
topics_create()
Create new topics
kafka_admin_class$topics_create(topic, partition = 1, replication_factor = 1)
topic
the topic names to create
partition
the topics number of partitions
replication_factor
the topics replication factor
returns a character vector of topics
topics_delete()
Delete topics
kafka_admin_class$topics_delete(topic)
topic
returns a character vector of topics
clone()
The objects of this class are cloneable with this method.
kafka_admin_class$clone(deep = FALSE)
deep
Whether to make a deep clone.
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.