Jason Gustafson created KAFKA-4172: -------------------------------------- Summary: Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled Key: KAFKA-4172 URL: https://issues.apache.org/jira/browse/KAFKA-4172 Project: Kafka Issue Type: Bug Components: consumer, unit tests Reporter: Jason Gustafson Assignee: Jason Gustafson Fix For: 0.10.1.0
This test case has an incorrectly matched mock fetch response, which was silently raising an NPE, which was caught in NetworkClient. In general, aside from fixing the test, we are probably missing a null check in the FetchRespose to verify that the partitions included in the fetch response were actually requested. This is usually not a problem because the broker doesn't send us invalid fetch responses, but it's probably better to be a little more defensive when handling responses. -- This message was sent by Atlassian JIRA (v6.3.4#6332)