from verta.endpoint.update import DirectUpdateStrategy
from verta.endpoint import KafkaSettings
kafka_settings = KafkaSettings(
input_topic="my_input_topic",
output_topic="my_output_topic",
error_topic="my_error_topic",
endpoint = client.create_endpoint(path="/some-path", kafka_settings=kafka_settings)
print(endpoint.kafka_settings)