Skip to content

Commit b8bd50a

Browse files
authored
MINOR: Port RestoreIntegrationTest to the new protocol (#20347)
The test uses regular consumer to commit offsets. New protocol requires a streams consumer since we are using streams groups, otherwise we run into group ID conflicts. Followed the addition of the KafkaAdmin interface for setting offsets, a Kafka Admin client is created and used the interface in to set the committed offsets instead of instantiating a consumer. Also enable all tests for stream new protocol. Reviewers: Alieh Saeedi<[email protected]>, Kirk True <[email protected]>, Matthias Sax <[email protected]>, Bill Bejeck <[email protected]>
1 parent def5f16 commit b8bd50a

File tree

1 file changed

+204
-76
lines changed

1 file changed

+204
-76
lines changed

0 commit comments

Comments
 (0)