diff --git a/guides/examples/introduction.md b/guides/examples/introduction.md index 828af7b..94f7b02 100644 --- a/guides/examples/introduction.md +++ b/guides/examples/introduction.md @@ -34,9 +34,9 @@ The following Off-Broadway libraries are available (feel free to send a PR addin * [off_broadway_elasticsearch](https://github.com/jonlunsford/off_broadway_elasticsearch): [Guide](https://hexdocs.pm/off_broadway_elasticsearch/) * [off_broadway_emqtt](https://github.com/intility/off_broadway_emqtt): [Guide](https://hexdocs.pm/off_broadway_emqtt/) * [off_broadway_kafka](https://github.com/bbalser/off_broadway_kafka): [Guide](https://hexdocs.pm/off_broadway_kafka/) + * [off_broadway_klife (kafka)](https://github.com/oliveigah/off_broadway_klife): [Guide](https://hexdocs.pm/off_broadway_klife/) * [off_broadway_memory](https://github.com/elliotekj/off_broadway_memory): [Guide](https://hexdocs.pm/off_broadway_memory/) * [off_broadway_pulsar](https://github.com/efcasado/off_broadway_pulsar): [Guide](https://hexdocs.pm/off_broadway_pulsar/) * [off_broadway_redis](https://github.com/amokan/off_broadway_redis): [Guide](https://hexdocs.pm/off_broadway_redis/) * [off_broadway_redis_stream](https://github.com/akash-akya/off_broadway_redis_stream): [Guide](https://hexdocs.pm/off_broadway_redis_stream/) * [off_broadway_splunk](https://github.com/intility/off_broadway_splunk): [Guide](https://hexdocs.pm/off_broadway_splunk/) - * [off_broadway_klife (kafka)](https://github.com/oliveigah/off_broadway_klife): [Guide](https://hexdocs.pm/off_broadway_klife/) diff --git a/lib/broadway.ex b/lib/broadway.ex index 610abfa..2cfbe69 100644 --- a/lib/broadway.ex +++ b/lib/broadway.ex @@ -871,14 +871,14 @@ defmodule Broadway do * Measurement: `%{duration: native_time}` * Metadata: - ``` + ``` %{ topology_name: atom, name: atom, batcher_key: atom, telemetry_span_context: reference } - ``` + ``` Most of the events follow the `:telemetry.span/3` convention for measurements. This means that "start" events have a `:system_time` representing the start of diff --git a/lib/broadway/config_storage/persistent_term.ex b/lib/broadway/config_storage/persistent_term.ex index 097e6c2..e2f25ba 100644 --- a/lib/broadway/config_storage/persistent_term.ex +++ b/lib/broadway/config_storage/persistent_term.ex @@ -34,7 +34,7 @@ defmodule Broadway.ConfigStorage.PersistentTerm do def delete(_server) do # We don't delete from persistent term on purpose. Since the process is # named, we can assume it does not start dynamically, so it will either - # restart or the amount of memory it uses is negligibla to justify the + # restart or the amount of memory it uses is negligible to justify the # process purging done by persistent_term. If the repo is restarted and # stores the same metadata, then no purging happens either. # :persistent_term.erase({Broadway, server})