chore: sync files with stordco/common-config-elixir #115
Annotations
10 errors
|
Test:
test/kafee/producer_integration_test.exs#L29
test large messages logs and continues (Kafee.ProducerIntegrationTest)
|
|
Test:
test/kafee/producer/sync_adapter_test.exs#L45
test produce/2 sends messages via :brod.produce_sync_offset/5 (Kafee.Producer.SyncAdapterTest)
|
|
Test:
test/kafee/producer/sync_adapter_test.exs#L86
test produce/2 calls Data Streams track_produce/3 with current produce offset (Kafee.Producer.SyncAdapterTest)
|
|
Test:
test/kafee/producer/sync_adapter_test.exs#L37
test partitions/2 returns a list of valid partitions (Kafee.Producer.SyncAdapterTest)
|
|
Test:
test/kafee/producer/sync_adapter_test.exs#L54
test produce/2 returns errors from brod (Kafee.Producer.SyncAdapterTest)
|
|
Test:
test/kafee/producer/sync_adapter_test.exs#L72
test produce/2 ran the message normalization pipeline (Kafee.Producer.SyncAdapterTest)
|
|
Test:
test/kafee/producer/async_worker_test.exs#L70
test handle_info :send does nothing on an empty queue (Kafee.Producer.AsyncWorkerTest)
|
|
Test:
test/kafee/producer/async_worker_test.exs#L100
test handle_info task_ref :ok removes sent messages from the queue (Kafee.Producer.AsyncWorkerTest)
|
|
Test:
test/kafee/producer/async_worker_test.exs#L217
test handle_info :DOWN unknown processes log and do nothing (Kafee.Producer.AsyncWorkerTest)
|
|
Test:
test/kafee/producer/async_worker_test.exs#L380
test build_message_batch/1 always returns one message if the queue exists (Kafee.Producer.AsyncWorkerTest)
|
The logs for this run have expired and are no longer available.
Loading