Closed bryanck closed 11 months ago
This PR allows the specified kafka config auto.offset.reset to take precedence for the control topic consumer. Also tests were updated to set this to earliest to ensure the data files written are committed in the integration tests.
auto.offset.reset
earliest
This PR allows the specified kafka config
auto.offset.reset
to take precedence for the control topic consumer. Also tests were updated to set this toearliest
to ensure the data files written are committed in the integration tests.