Index

_

__init__() (flowodm.connection.KafkaConnection method) (flowodm.consumer.AsyncConsumerLoop method) (flowodm.consumer.ConsumerLoop method) (flowodm.exceptions.SchemaCompatibilityError method) (flowodm.exceptions.SchemaValidationError method) (flowodm.schema.CompatibilityResult method) (flowodm.schema.ValidationResult method) (flowodm.settings.BaseSettings method) (flowodm.settings.BatchSettings method) (flowodm.settings.HighThroughputSettings method) (flowodm.settings.LongRunningSettings method) (flowodm.settings.RealTimeSettings method) (flowodm.settings.ReliableSettings method)

__new__() (flowodm.connection.KafkaConnection static method)

A

aconsume_batch() (flowodm.model.FlowBaseModel class method) aconsume_iter() (flowodm.model.FlowBaseModel class method) aconsume_one() (flowodm.model.FlowBaseModel class method) aproduce() (flowodm.model.FlowBaseModel method) aproduce_many() (flowodm.model.FlowBaseModel class method) async_consumer_loop() (in module flowodm.consumer)

AsyncConsumerLoop (class in flowodm.consumer) auto_offset_reset (flowodm.settings.BaseSettings attribute) (flowodm.settings.BatchSettings attribute) (flowodm.settings.HighThroughputSettings attribute) (flowodm.settings.LongRunningSettings attribute) (flowodm.settings.RealTimeSettings attribute) (flowodm.settings.ReliableSettings attribute)

B

BaseSettings (class in flowodm.settings)

BatchSettings (class in flowodm.settings)

C

check_compatibility() (in module flowodm.schema) close_connection() (flowodm.connection.KafkaConnection method) cmd_check_compatibility() (in module flowodm.cli) cmd_get_schema() (in module flowodm.cli) cmd_list_subjects() (in module flowodm.cli) cmd_upload_schema() (in module flowodm.cli) cmd_validate() (in module flowodm.cli) compatibility_level (flowodm.schema.CompatibilityResult attribute) CompatibilityResult (class in flowodm.schema) ConfigurationError

configure() (flowodm.connection.KafkaConnection method) confluent_wire_format (flowodm.model.FlowBaseModel.Settings attribute) connect() (in module flowodm.connection) ConnectionError consume_batch() (flowodm.model.FlowBaseModel class method) consume_iter() (flowodm.model.FlowBaseModel class method) consume_one() (flowodm.model.FlowBaseModel class method) consumer_group (flowodm.model.FlowBaseModel.Settings attribute) consumer_loop() (in module flowodm.consumer) ConsumerError ConsumerLoop (class in flowodm.consumer)

D

delete_subject() (in module flowodm.schema)

DeserializationError

E

enable_auto_commit (flowodm.settings.BaseSettings attribute) (flowodm.settings.BatchSettings attribute) (flowodm.settings.HighThroughputSettings attribute) (flowodm.settings.LongRunningSettings attribute) (flowodm.settings.RealTimeSettings attribute) (flowodm.settings.ReliableSettings attribute)

errors (flowodm.schema.ValidationResult attribute) extra_config (flowodm.settings.BaseSettings attribute)

F

FlowBaseModel (class in flowodm.model) FlowBaseModel.Settings (class in flowodm.model) flowodm.cli module flowodm.connection module flowodm.consumer module

flowodm.exceptions module flowodm.model module flowodm.schema module flowodm.settings module FlowODMError

G

generate_model_from_registry() (in module flowodm.schema) generate_model_from_schema() (in module flowodm.schema) get_async_consumer() (flowodm.connection.KafkaConnection method) (flowodm.model.FlowBaseModel class method) (in module flowodm.connection) get_async_producer() (flowodm.connection.KafkaConnection method) (flowodm.model.FlowBaseModel class method) (in module flowodm.connection)

get_consumer() (flowodm.connection.KafkaConnection method) (flowodm.model.FlowBaseModel class method) (in module flowodm.connection) get_kafka_connection() (in module flowodm.connection) get_producer() (flowodm.model.FlowBaseModel class method) (in module flowodm.connection) get_schema_registry() (in module flowodm.connection) get_schema_versions() (in module flowodm.schema)

H

heartbeat_interval_ms (flowodm.settings.BaseSettings attribute) (flowodm.settings.BatchSettings attribute) (flowodm.settings.HighThroughputSettings attribute) (flowodm.settings.LongRunningSettings attribute) (flowodm.settings.RealTimeSettings attribute) (flowodm.settings.ReliableSettings attribute)

HighThroughputSettings (class in flowodm.settings)

I

is_compatible (flowodm.schema.CompatibilityResult attribute)

is_valid (flowodm.schema.ValidationResult attribute)

K

KafkaConnection (class in flowodm.connection)

key_field (flowodm.model.FlowBaseModel.Settings attribute) key_serializer (flowodm.model.FlowBaseModel.Settings attribute)

L

list_subjects() (in module flowodm.schema) load_schema_from_file() (in module flowodm.schema)

load_schema_from_registry() (in module flowodm.schema) LongRunningSettings (class in flowodm.settings)

M

main() (in module flowodm.cli) max_poll_interval_ms (flowodm.settings.BaseSettings attribute) (flowodm.settings.BatchSettings attribute) (flowodm.settings.HighThroughputSettings attribute) (flowodm.settings.LongRunningSettings attribute) (flowodm.settings.RealTimeSettings attribute) (flowodm.settings.ReliableSettings attribute) max_poll_records (flowodm.settings.BaseSettings attribute) (flowodm.settings.BatchSettings attribute) (flowodm.settings.HighThroughputSettings attribute) (flowodm.settings.LongRunningSettings attribute) (flowodm.settings.RealTimeSettings attribute) (flowodm.settings.ReliableSettings attribute)

message (flowodm.schema.CompatibilityResult attribute) model_config (flowodm.model.FlowBaseModel attribute) module flowodm.cli flowodm.connection flowodm.consumer flowodm.exceptions flowodm.model flowodm.schema flowodm.settings

P

produce() (flowodm.model.FlowBaseModel method) produce_many() (flowodm.model.FlowBaseModel class method)

produce_nowait() (flowodm.model.FlowBaseModel method) producer (flowodm.connection.KafkaConnection property) ProducerError

R

RealTimeSettings (class in flowodm.settings) register_schema() (flowodm.model.FlowBaseModel class method)

ReliableSettings (class in flowodm.settings) run() (flowodm.consumer.AsyncConsumerLoop method) (flowodm.consumer.ConsumerLoop method)

S

schema_path (flowodm.model.FlowBaseModel.Settings attribute) schema_registry (flowodm.connection.KafkaConnection property) schema_subject (flowodm.model.FlowBaseModel.Settings attribute) SchemaCompatibilityError SchemaError SchemaRegistryError SchemaValidationError SerializationError

session_timeout_ms (flowodm.settings.BaseSettings attribute) (flowodm.settings.BatchSettings attribute) (flowodm.settings.HighThroughputSettings attribute) (flowodm.settings.LongRunningSettings attribute) (flowodm.settings.RealTimeSettings attribute) (flowodm.settings.ReliableSettings attribute) SettingsError stop() (flowodm.consumer.AsyncConsumerLoop method) (flowodm.consumer.ConsumerLoop method)

T

to_consumer_config() (flowodm.settings.BaseSettings method) to_producer_config() (flowodm.settings.BaseSettings method) (flowodm.settings.HighThroughputSettings method) (flowodm.settings.ReliableSettings method)

topic (flowodm.model.FlowBaseModel.Settings attribute) TopicError

U

upload_schema() (in module flowodm.schema)

V

validate_against_file() (in module flowodm.schema) validate_against_registry() (in module flowodm.schema)

ValidationResult (class in flowodm.schema) value_serializer (flowodm.model.FlowBaseModel.Settings attribute)

W

warnings (flowodm.schema.ValidationResult attribute)