Module kflow_kafka_test_helper

check_committed_offsets(GroupId, Offsets) -> any()

common_end_per_testcase(Case, Config) -> any()

common_init_per_testcase(Module, Case, Config) -> any()

consumer_config() -> any()

create_topic(Name, NumPartitions) -> any()

dump_topic(Topic, Partition) -> any()

get_acked_offsets(GroupId::brod:group_id()) -> #{brod:partition() => brod:offset()}

init_per_suite(Config) -> any()

produce(TopicPartition, Value) -> any()

produce(TopicPartition, Key, Value) -> any()

produce(X1, Key, Value, Headers) -> any()

wait_for_port(Host::string(), Port::non_neg_integer()) -> ok

wait_n_messages(TestGroupId, NMessages) -> any()

wait_n_messages(TestGroupId, Expected, NRetries) -> any()