Skip to content

Conversation

tbearma1
Copy link

No description provided.

topic_names_map[it->first.as<std::string>()] = it->second.as<std::string>();
}
} else if (debug_general)
if (topic_names_map.find(it->first.as<std::string>()) != topic_names_map.end())
Copy link
Contributor

Choose a reason for hiding this comment

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

I don't believe you intended to change this. This can happen if your fork isn't up-to-date with the master. In order to maintain your fork, you need to periodically sync it to the master/upstream. See this link for details on how to do that: https://help.github.com/articles/syncing-a-fork/

For now, I can fix this on merge.

@TimEvens
Copy link
Contributor

I'll merge this soon.. Just will run a couple tests.

@SeryioGonzalez
Copy link

Is it possible to implement kafka client authentication?

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