Index

A

add_arguments() (edx_event_bus_kafka.management.commands.produce_event.Command method)

assert_signal_sent_with() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method)

C

Command (class in edx_event_bus_kafka.management.commands.produce_event) consume_indefinitely() (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer method)

consumer (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer attribute) create_producer() (in module edx_event_bus_kafka.internal.producer)

D

descend_avro_schema() (in module edx_event_bus_kafka.internal.producer)

determine_signal() (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer method)

E

edx_event_bus_kafka module edx_event_bus_kafka.apps module edx_event_bus_kafka.internal module edx_event_bus_kafka.internal.config module edx_event_bus_kafka.internal.consumer module edx_event_bus_kafka.internal.producer module edx_event_bus_kafka.internal.tests module edx_event_bus_kafka.internal.tests.test_config module edx_event_bus_kafka.internal.tests.test_consumer module edx_event_bus_kafka.internal.tests.test_producer module

edx_event_bus_kafka.internal.tests.test_utils module edx_event_bus_kafka.internal.utils module edx_event_bus_kafka.management module edx_event_bus_kafka.management.commands module edx_event_bus_kafka.management.commands.produce_event module edx_event_bus_kafka.models module edx_event_bus_kafka.urls module EdxEventBusKafkaConfig (class in edx_event_bus_kafka.apps) emit_signals_from_message() (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer method) error() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method) EventConsumptionException EventProductionException extract_event_key() (in module edx_event_bus_kafka.internal.producer) extract_key_schema() (in module edx_event_bus_kafka.internal.producer)

F

fake_receiver_raises_error() (in module edx_event_bus_kafka.internal.tests.test_consumer)

fake_receiver_returns_quietly() (in module edx_event_bus_kafka.internal.tests.test_consumer) FakeMessage (class in edx_event_bus_kafka.internal.tests.test_utils)

G

get_deserializer() (in module edx_event_bus_kafka.internal.consumer) get_full_topic() (in module edx_event_bus_kafka.internal.config) get_message_header_values() (in module edx_event_bus_kafka.internal.utils)

get_schema_registry_client() (in module edx_event_bus_kafka.internal.config) get_serializers() (in module edx_event_bus_kafka.internal.producer) get_signal_serializer() (in module edx_event_bus_kafka.internal.producer) group_id (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer attribute)

H

handle() (edx_event_bus_kafka.management.commands.produce_event.Command method)

headers() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method) help (edx_event_bus_kafka.management.commands.produce_event.Command attribute)

I

instances (edx_event_bus_kafka.internal.utils.MessageHeader attribute)

K

KafkaEventConsumer (class in edx_event_bus_kafka.internal.consumer)

KafkaEventProducer (class in edx_event_bus_kafka.internal.producer) key() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method)

L

last_message_header_value() (in module edx_event_bus_kafka.internal.utils)

load_common_settings() (in module edx_event_bus_kafka.internal.config)

M

MessageHeader (class in edx_event_bus_kafka.internal.utils) module edx_event_bus_kafka edx_event_bus_kafka.apps edx_event_bus_kafka.internal edx_event_bus_kafka.internal.config edx_event_bus_kafka.internal.consumer edx_event_bus_kafka.internal.producer edx_event_bus_kafka.internal.tests edx_event_bus_kafka.internal.tests.test_config edx_event_bus_kafka.internal.tests.test_consumer edx_event_bus_kafka.internal.tests.test_producer edx_event_bus_kafka.internal.tests.test_utils edx_event_bus_kafka.internal.utils edx_event_bus_kafka.management edx_event_bus_kafka.management.commands edx_event_bus_kafka.management.commands.produce_event edx_event_bus_kafka.models edx_event_bus_kafka.urls

N

name (edx_event_bus_kafka.apps.EdxEventBusKafkaConfig attribute)

O

offset() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method)

offset_time (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer attribute) on_event_deliver() (edx_event_bus_kafka.internal.producer.ProducingContext method)

P

partition() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method) poll_indefinitely() (in module edx_event_bus_kafka.internal.producer)

prepare_for_shutdown() (edx_event_bus_kafka.internal.producer.KafkaEventProducer method) ProducingContext (class in edx_event_bus_kafka.internal.producer)

R

ReceiverError record_event_consuming_error() (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer method)

record_producing_error() (in module edx_event_bus_kafka.internal.producer) reset_offsets_and_sleep_indefinitely() (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer method)

S

send() (edx_event_bus_kafka.internal.producer.KafkaEventProducer method) set_value() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method)

setUp() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) side_effects() (in module edx_event_bus_kafka.internal.tests.test_utils)

T

tearDown() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_bad_headers() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_check_event_error() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_command() (edx_event_bus_kafka.internal.tests.test_producer.TestCommand method) test_configured() (edx_event_bus_kafka.internal.tests.test_config.TestSchemaRegistryClient method) test_connection_reset_1__False__False__False_() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_connection_reset_2__True__False__True_() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_connection_reset_3__False__True__False_() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_consecutive_error_limit() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) TEST_CONSUME_ERROR_FATAL (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals attribute) TEST_CONSUME_ERROR_NO_MESSAGE (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals attribute) TEST_CONSUME_ERROR_WITH_MESSAGE (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals attribute) test_consume_loop() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_consume_loop_disabled() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_create_producer_configured() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_create_producer_unconfigured() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_descend_avro_schema() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_deserialize_type_mismatch() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_determine_signal_success() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_emit() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_emit_success_1_True() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_emit_success_2_False() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_emit_success_tolerates_missing_timestamp() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_emit_type_mismatch() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_empty_string_prefix() (edx_event_bus_kafka.internal.tests.test_config.TestTopicPrefixing method) test_extract_event_key() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_extract_key_schema() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) TEST_FAILED_MESSAGE (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals attribute) test_full() (edx_event_bus_kafka.internal.tests.test_config.TestCommonSettings method) test_full_event_data_present_in_kafka_error() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_full_event_data_present_in_key_extraction_error() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_generate_metadata_fails_with_duplicate_headers() (edx_event_bus_kafka.internal.tests.test_utils.TestUtils method) test_generate_metadata_from_missing_or_bad_headers_1() (edx_event_bus_kafka.internal.tests.test_utils.TestUtils method) test_generate_metadata_from_missing_or_bad_headers_2() (edx_event_bus_kafka.internal.tests.test_utils.TestUtils method) test_generate_metadata_from_missing_or_bad_headers_3() (edx_event_bus_kafka.internal.tests.test_utils.TestUtils method) test_generate_metadata_from_missing_or_bad_headers_4() (edx_event_bus_kafka.internal.tests.test_utils.TestUtils method) test_generate_metadata_from_missing_or_bad_headers_5__None__None__None__True_() (edx_event_bus_kafka.internal.tests.test_utils.TestUtils method) test_headers_from_event_metadata() (edx_event_bus_kafka.internal.tests.test_utils.TestUtils method) TEST_KAFKA_ERROR (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals attribute) TEST_KAFKA_EXCEPTION (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals attribute) TEST_KAFKA_FATAL_ERROR (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals attribute) test_malformed_receiver_errors() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method)

test_metadata_from_headers() (edx_event_bus_kafka.internal.tests.test_utils.TestUtils method) test_minimal() (edx_event_bus_kafka.internal.tests.test_config.TestCommonSettings method) test_multiple_types() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_no_commit_if_no_error_logged() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_no_consume_with_bad_offset_timestamp() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_no_consume_with_offsets() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_no_deserializer_if_no_registry_client() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_no_prefix() (edx_event_bus_kafka.internal.tests.test_config.TestTopicPrefixing method) test_no_type() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_non_consecutive_errors() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_on_event_deliver_1_True() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_on_event_deliver_2_False() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_polling_loop_robust() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_polling_loop_terminates() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_record_error_for_various_errors_1() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_record_error_for_various_errors_2() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_record_error_for_various_errors_3() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_record_error_for_various_errors_4() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_record_error_for_various_errors_5() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_regular_prefix() (edx_event_bus_kafka.internal.tests.test_config.TestTopicPrefixing method) test_reset_offsets_and_sleep_indefinitely() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_reset_offsets_and_sleep_indefinitely_with_none_offset() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) test_send_to_event_bus() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_serialize_and_produce_to_same_topic() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_serializers_configured() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_serializers_unconfigured() (edx_event_bus_kafka.internal.tests.test_producer.TestEventProducer method) test_side_effects() (edx_event_bus_kafka.internal.tests.test_utils.TestTestHelpers method) test_unconfigured() (edx_event_bus_kafka.internal.tests.test_config.TestCommonSettings method) (edx_event_bus_kafka.internal.tests.test_config.TestSchemaRegistryClient method) test_unexpected_signal_type_in_header() (edx_event_bus_kafka.internal.tests.test_consumer.TestEmitSignals method) TEST_UUID_BYTES (edx_event_bus_kafka.internal.tests.test_utils.TestUtils attribute) TestCommand (class in edx_event_bus_kafka.internal.tests.test_producer) TestCommonSettings (class in edx_event_bus_kafka.internal.tests.test_config) TestEmitSignals (class in edx_event_bus_kafka.internal.tests.test_consumer) TestEventProducer (class in edx_event_bus_kafka.internal.tests.test_producer) TestSchemaRegistryClient (class in edx_event_bus_kafka.internal.tests.test_config) TestTestHelpers (class in edx_event_bus_kafka.internal.tests.test_utils) TestTopicPrefixing (class in edx_event_bus_kafka.internal.tests.test_config) TestUtils (class in edx_event_bus_kafka.internal.tests.test_utils) timestamp() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method) topic (edx_event_bus_kafka.internal.consumer.KafkaEventConsumer attribute) topic() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method)

U

UnusableMessageError

V

value() (edx_event_bus_kafka.internal.tests.test_utils.FakeMessage method)