I am running into a curious problem with auto creation of topics and would appreciate any insight into what could be causing it.
Some context first: We are using Confluent 2.0 platform and I have an integration test where the following happens: 1. A worker thread is spun up and it creates a kafka consumer that subscribes to two topics: Topic A and Topic B. Both of these topics do not exist at this time. 2. The kafka consumer polls the two topics periodically. 3. A kafka producer sends an event into Topic A (and hence creates the topic through auto topic creation) 4. The kafka consumer created previously is assigned a partition from Topic A (no assignment for Topic B since it does not exist yet). 5. worker polls and receives the event from Topic A partition. It processes the event and produces an event into Topic B (and hence the topic B is created at this time) 6. I am expected to see a partition from Topic B getting assigned to the consumer next time a poll happens but nothing happens. Note that the same integration test works fine if I pre-create the two topics before running the test. ________________________________ DISCLAIMER: The information transmitted is intended only for the person or entity to which it is addressed and may contain confidential and/or privileged material. Any review, re-transmission, dissemination or other use of, or taking of any action in reliance upon this information by persons or entities other than the intended recipient is prohibited. If you received this in error, please contact the sender and destroy any copies of this document and any attachments.
