mjsax commented on pull request #10548:
URL: https://github.com/apache/kafka/pull/10548#issuecomment-825070459


   > They do? Since 2017 according to annotations? Might be that we're talking 
different classes?
   
   The input parameter is `Windowed<K> sessionKey` and the check is if 
`sessionKey != null` -- however, `sessionKey` wraps a `key` object, and my ask 
was to also check if the wrapped key is not null, ie, to add `sessionKey.key() 
!= null` check (note the `.get()` call that extract the wrapped `key` from 
`sessionKey` parameter). Sorry for the confusion.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to