Skip to content

hopsworks.kafka_topic #

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

name property writable #

Name of the Kafka topic.

replicas property #

Number of replicas of the Kafka topic.

num_replicas property writable #

Number of replicas of the Kafka topic.

partitions property #

Number of partitions of the Kafka topic.

num_partitions property #

Number of partitions of the Kafka topic.

schema property #

Schema for the topic.

describe #

describe()

Print a JSON description of the Kafka topic.

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