Kayrock migrate offset functions #30
Annotations
10 errors and 1 warning
|
Run Integration Tests:
test/integration/kafka_ex_api_test.exs#L281
test commit_offset/5 supports generation_id and member_id options (v1) (KafkaEx.New.KafkaExAPITest)
|
|
Run Integration Tests:
test/integration/new_client_test.exs#L424
test offset_commit supports generation_id and member_id options (v1) (KafkaEx.New.Client.Test)
|
|
Run Integration Tests:
test/integration/kayrock/compatibility_test.exs#L711
test offset_commit compatibility commit via new API and verify via legacy API (KafkaEx.KayrockCompatibilityTest)
|
|
Run Integration Tests:
test/integration/kayrock/compatibility_test.exs#L640
test offset_fetch compatibility fetch committed offset via legacy API (KafkaEx.KayrockCompatibilityTest)
|
|
Run Integration Tests:
test/integration/kayrock/compatibility_test.exs#L733
test offset_commit compatibility round trip commit-then-fetch with mixed APIs (KafkaEx.KayrockCompatibilityTest)
|
|
Run Integration Tests:
test/integration/kayrock/compatibility_test.exs#L664
test offset_fetch compatibility fetch via new API what was committed via legacy API (KafkaEx.KayrockCompatibilityTest)
|
|
Run Integration Tests:
test/integration/kafka_ex_api_test.exs#L19
test latest_offset/3 returns latest offset for given topic, partition pair (KafkaEx.New.KafkaExAPITest)
|
|
Run Integration Tests:
test/integration/kafka_ex_api_test.exs#L281
test commit_offset/5 supports generation_id and member_id options (v1) (KafkaEx.New.KafkaExAPITest)
|
|
Run Integration Tests:
test/integration/kafka_ex_api_test.exs#L31
test latest_offset/4 returns latest offset for given topic, partition pair (KafkaEx.New.KafkaExAPITest)
|
|
Run Integration Tests:
test/integration/kafka_ex_api_test.exs#L107
test list_offsets/3 returns latest offset for given topic, partitions (KafkaEx.New.KafkaExAPITest)
|
|
Install dependencies
low..high inside guards requires an explicit step, please write low..high//1 or low..high//-1 instead
|
Loading