KafkaBatcher.Collector.Implementation (kafka_batcher v1.1.1)

Part of the KafkaBatcher.Collector implementation not related to GenServer behavior.

Summary

Functions

choose_partition(arg1, topic_name, config, partitions_count)
start_accumulators(state)
store_partition_count(state)
store_partitions_count(state)

Functions

choose_partition(arg1, topic_name, config, partitions_count)

start_accumulators(state)

store_partition_count(state)

@spec store_partition_count(KafkaBatcher.Collector.State.t()) ::
  KafkaBatcher.Collector.State.t()

store_partitions_count(state)