pypz.plugins.kafka_io package

Submodules

• pypz.plugins.kafka_io.channels module
  • KafkaChannelReader
    • KafkaChannelReader.DataConsumerTimeoutInMs
    • KafkaChannelReader.InitialDataConsumerTimeoutInMs
    • KafkaChannelReader.StatusConsumerTimeoutInMs
    • KafkaChannelReader._abc_impl
    • KafkaChannelReader._admin_client
    • KafkaChannelReader._aggregated_record_count
    • KafkaChannelReader._aggregated_time_between_reads
    • KafkaChannelReader._channel_name
    • KafkaChannelReader._channel_opened
    • KafkaChannelReader._channel_started
    • KafkaChannelReader._channel_stopped
    • KafkaChannelReader._close_channel()
    • KafkaChannelReader._commit_offset()
    • KafkaChannelReader._configuration
    • KafkaChannelReader._configure_channel()
    • KafkaChannelReader._consumer_timeout_ms
    • KafkaChannelReader._context
    • KafkaChannelReader._control_loop_exception_timer
    • KafkaChannelReader._create_resources()
    • KafkaChannelReader._current_read_record_count
    • KafkaChannelReader._current_read_timestamp
    • KafkaChannelReader._data_consumer
    • KafkaChannelReader._data_consumer_properties
    • KafkaChannelReader._data_topic_name
    • KafkaChannelReader._delete_resources()
    • KafkaChannelReader._executor
    • KafkaChannelReader._executor_started
    • KafkaChannelReader._executor_stopped
    • KafkaChannelReader._generic_datum_reader
    • KafkaChannelReader._health_check_payload
    • KafkaChannelReader._initial_input_record_offset
    • KafkaChannelReader._last_offset_committed
    • KafkaChannelReader._load_input_record_offset()
    • KafkaChannelReader._location
    • KafkaChannelReader._log_level
    • KafkaChannelReader._logger
    • KafkaChannelReader._metrics_buffer
    • KafkaChannelReader._metrics_enabled
    • KafkaChannelReader._on_status_message_received_callbacks
    • KafkaChannelReader._open_channel()
    • KafkaChannelReader._partition_count
    • KafkaChannelReader._read_record_count
    • KafkaChannelReader._read_record_offset
    • KafkaChannelReader._read_records()
    • KafkaChannelReader._reader_status_producer
    • KafkaChannelReader._reader_status_producer_properties
    • KafkaChannelReader._reader_status_topic_name
    • KafkaChannelReader._resources_created
    • KafkaChannelReader._resources_deleted
    • KafkaChannelReader._retrieve_status_messages()
    • KafkaChannelReader._send_status_message()
    • KafkaChannelReader._silent_mode
    • KafkaChannelReader._status_map
    • KafkaChannelReader._stopping_executor
    • KafkaChannelReader._target_partition
    • KafkaChannelReader._unique_name
    • KafkaChannelReader._writer_status_consumer
    • KafkaChannelReader._writer_status_consumer_properties
    • KafkaChannelReader._writer_status_topic_name
    • KafkaChannelReader.can_close()
    • KafkaChannelReader.get_consumer_lag()
    • KafkaChannelReader.has_records()
    • KafkaChannelReader.set_location()
    • KafkaChannelReader.start_channel()
    • KafkaChannelReader.stop_channel()
  • KafkaChannelWriter
    • KafkaChannelWriter._abc_impl
    • KafkaChannelWriter._admin_client
    • KafkaChannelWriter._aggregated_record_count
    • KafkaChannelWriter._aggregated_time_between_outputs
    • KafkaChannelWriter._channel_name
    • KafkaChannelWriter._channel_opened
    • KafkaChannelWriter._channel_started
    • KafkaChannelWriter._channel_stopped
    • KafkaChannelWriter._close_channel()
    • KafkaChannelWriter._configuration
    • KafkaChannelWriter._configure_channel()
    • KafkaChannelWriter._consumer_timeout_ms
    • KafkaChannelWriter._context
    • KafkaChannelWriter._control_loop_exception_timer
    • KafkaChannelWriter._create_resources()
    • KafkaChannelWriter._current_output_record_count
    • KafkaChannelWriter._current_output_timestamp
    • KafkaChannelWriter._data_producer
    • KafkaChannelWriter._data_producer_properties
    • KafkaChannelWriter._data_topic_name
    • KafkaChannelWriter._delete_resources()
    • KafkaChannelWriter._executor
    • KafkaChannelWriter._executor_started
    • KafkaChannelWriter._executor_stopped
    • KafkaChannelWriter._generic_datum_writer
    • KafkaChannelWriter._health_check_payload
    • KafkaChannelWriter._location
    • KafkaChannelWriter._log_level
    • KafkaChannelWriter._logger
    • KafkaChannelWriter._metrics_buffer
    • KafkaChannelWriter._metrics_enabled
    • KafkaChannelWriter._on_status_message_received_callbacks
    • KafkaChannelWriter._open_channel()
    • KafkaChannelWriter._reader_status_consumer
    • KafkaChannelWriter._reader_status_consumer_properties
    • KafkaChannelWriter._reader_status_topic_name
    • KafkaChannelWriter._resources_created
    • KafkaChannelWriter._resources_deleted
    • KafkaChannelWriter._retrieve_status_messages()
    • KafkaChannelWriter._round_robin_partition_idx
    • KafkaChannelWriter._send_status_message()
    • KafkaChannelWriter._silent_mode
    • KafkaChannelWriter._status_map
    • KafkaChannelWriter._stopping_executor
    • KafkaChannelWriter._target_partition_count
    • KafkaChannelWriter._unique_name
    • KafkaChannelWriter._write_records()
    • KafkaChannelWriter._writer_status_producer
    • KafkaChannelWriter._writer_status_producer_properties
    • KafkaChannelWriter._writer_status_topic_name
    • KafkaChannelWriter._written_record_count
    • KafkaChannelWriter.can_close()
    • KafkaChannelWriter.set_location()
    • KafkaChannelWriter.start_channel()
    • KafkaChannelWriter.stop_channel()
• pypz.plugins.kafka_io.ports module
  • KafkaChannelInputPort
    • KafkaChannelInputPort.__connected_ports
    • KafkaChannelInputPort.__context
    • KafkaChannelInputPort.__depends_on
    • KafkaChannelInputPort.__expected_parameters
    • KafkaChannelInputPort.__full_name
    • KafkaChannelInputPort.__logger
    • KafkaChannelInputPort.__nested_instance_type
    • KafkaChannelInputPort.__nested_instances
    • KafkaChannelInputPort.__parameters
    • KafkaChannelInputPort.__schema
    • KafkaChannelInputPort.__simple_name
    • KafkaChannelInputPort.__spec_classes
    • KafkaChannelInputPort.__spec_name
    • KafkaChannelInputPort._abc_impl
    • KafkaChannelInputPort._channel_reader
    • KafkaChannelInputPort._delete_resources
    • KafkaChannelInputPort._expected_output_count
    • KafkaChannelInputPort._group_mode
    • KafkaChannelInputPort._interrupted
    • KafkaChannelInputPort._need_to_check_connections_opened
    • KafkaChannelInputPort.channel_reader_type
  • KafkaChannelOutputPort
    • KafkaChannelOutputPort.__connected_ports
    • KafkaChannelOutputPort.__context
    • KafkaChannelOutputPort.__depends_on
    • KafkaChannelOutputPort.__expected_parameters
    • KafkaChannelOutputPort.__full_name
    • KafkaChannelOutputPort.__logger
    • KafkaChannelOutputPort.__nested_instance_type
    • KafkaChannelOutputPort.__nested_instances
    • KafkaChannelOutputPort.__parameters
    • KafkaChannelOutputPort.__schema
    • KafkaChannelOutputPort.__simple_name
    • KafkaChannelOutputPort.__spec_classes
    • KafkaChannelOutputPort.__spec_name
    • KafkaChannelOutputPort._abc_impl
    • KafkaChannelOutputPort._channel_writers
    • KafkaChannelOutputPort._delete_resources
    • KafkaChannelOutputPort._interrupted
    • KafkaChannelOutputPort._port_close_errors
    • KafkaChannelOutputPort._resource_deletion_errors
    • KafkaChannelOutputPort.channel_writer_type

Module contents