You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Sue Wilson <sw...@tivo.com> on 2015/08/13 19:47:47 UTC
Re: Create topic programmatically
What exactly should be checked to determine that the topic has been
successfully created since it is async?
I see a few different things in the code, in TestUtils.createTopic it
requires a list of Brokers to check, and checks for both
TestUtils.waitUntilMetadataIsPropagated() to each broker, and also
TestUtils.waitUntilLeaderIsElectedOrChanged().
Do we need to do both of these things - basically copy all this code
from TestUtils into our app?
Thanks
Sue
________________________________
This email and any attachments may contain confidential and privileged material for the sole use of the intended recipient. Any review, copying, or distribution of this email (or any attachments) by others is prohibited. If you are not the intended recipient, please contact the sender immediately and permanently delete this email and any attachments. No employee or agent of TiVo Inc. is authorized to conclude any binding agreement on behalf of TiVo Inc. by email. Binding agreements with TiVo Inc. may only be made by a signed written agreement.