Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
3.0.0.RC2, 3.x
-
None
-
Unknown
Description
Slight problem encountered with the recent hdfs component refactoring.
hasMatchingOwner used as a filter in this lambda expression always returns false and hence the count of polled messages is always 0. It's simple to reproduce by running HdfsConsumerTest.
I think the revised implementation of hasMatchingOwner is wrong. It should return false when the owner does not match. I think that's more in line with the previous implementation.
Attachments
Issue Links
- links to