Skip to content

Conversation

@yaojiefeng
Copy link
Contributor

No description provided.


// If the offset directory is provided, try to load the file
if (config.getOffsetDir() != null) {
if (!context.isPreviewEnabled() && config.getOffsetDir() != null) {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

should we return before getting partitionOffsets?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

There is still following steps that need to be done to generate kafka request.

Copy link
Member

@CuriousVini CuriousVini left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm 👍

@yaojiefeng yaojiefeng merged commit 9e3d4eb into develop Mar 22, 2019
@yaojiefeng yaojiefeng deleted the bugfix/CDAP-15105-do-not-create-external-resources-kafka branch March 22, 2019 23:08
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants