V1.0.0 api migration #6
Annotations
11 errors
|
|
|
Run Tests:
test/integration/kayrock/compatibility_test.exs#L60
test describe_groups/1 with old client - returns group metadata (KafkaEx.KayrockCompatibilityTest)
|
|
Run Tests:
test/integration/kayrock/compatibility_test.exs#L289
test earliest_offset retrieves offset of 0 (KafkaEx.KayrockCompatibilityTest)
|
|
Run Tests:
test/integration/kayrock/compatibility_test.exs#L309
test latest_offset retrieves offset of 0 for non-existing topic (KafkaEx.KayrockCompatibilityTest)
|
|
Run Tests:
test/integration/kayrock/compatibility_test.exs#L332
test latest_offset retrieves a non-zero offset for a topic published to (KafkaEx.KayrockCompatibilityTest)
|
|
Run Tests:
test/integration/kayrock/compatibility_test.exs#L100
test list offsets (KafkaEx.KayrockCompatibilityTest)
|
|
Run Tests:
test/integration/integration_test.exs#L258
test fetch does not blow up with incomplete bytes (KafkaEx.Integration.Test)
|
|
Run Tests:
test/integration/kayrock/compatibility_streaming_test.exs#L78
test streams doesn't skip first message, with an initially empty log (KafkaEx.KayrockCompatibilityStreamingTest)
|
|
Run Tests:
test/integration/kayrock/compatibility_streaming_test.exs#L20
test stream with kafka offset storage and timestamps (KafkaEx.KayrockCompatibilityStreamingTest)
|
|
Run Tests:
test/integration/new_client_test.exs#L116
test list_offsets/1 lists past based offset for topic with existing messages (KafkaEx.New.Client.Test)
|
|
Run Tests:
test/integration/new_client_test.exs#L101
test list_offsets/1 lists earliest offsets for topic with existing messages (KafkaEx.New.Client.Test)
|
Loading