Skip to content

hopsworks.kafka_topic #

[source] KafkaTopic #

Configuration for a Kafka topic.

For backwards compatibility hopsworks.kafka_topic.KafkaTopic is still available as hsml.kafka_topic.KafkaTopic. The use of this alias is discouraged as it is to be deprecated.

Returned by

[source] name property writable #

Name of the Kafka topic.

[source] replicas property #

Number of replicas of the Kafka topic.

[source] num_replicas property writable #

Number of replicas of the Kafka topic.

[source] partitions property #

Number of partitions of the Kafka topic.

[source] num_partitions property #

Number of partitions of the Kafka topic.

[source] schema property #

Schema for the topic.

[source] describe #

describe()

Print a JSON description of the Kafka topic.

[source] delete #

delete()

Delete the topic.

Potentially dangerous operation

This operation deletes the topic.

RAISES DESCRIPTION
hopsworks.client.exceptions.RestAPIError

If the backend encounters an error when handling the request