[KAFKA-16764] New consumer should throw InvalidTopicException on poll when invalid topic in metadata - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Blocker
Resolution: Fixed
Affects Version/s: 3.7.0
Fix Version/s: 3.8.0
Component/s: clients, consumer
Labels:
- kip-848-client-support

Description

A call to consumer.poll should throw InvalidTopicException if an invalid topic is discovered in metadata. This can be easily reproduced by calling subscribe("invalid topic") and then poll, for example.The new consumer does not throw the expected InvalidTopicException like the LegacyKafkaConsumer does.

The legacy consumer achieves this by checking for metadata exceptions on every iteration of the ConsumerNetworkClient (see here)

This is probably what makes that testSubscriptionOnInvalidTopic fails for the new consumer. Once this bug is fixed, we should be able to enable that test for the new consumer.