UladzislauBlok commented on code in PR #22570:
URL: https://github.com/apache/kafka/pull/22570#discussion_r3532242605
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java:
##########
@@ -239,13 +244,15 @@ public synchronized <K> KeyQueryMetadata
keyQueryMetadataForKey(final String sto
*
* @param storeName Name of the store
* @param key Key to use
+ * @param headers the record headers
* @param partitioner partitioner to use to find correct partition for key
* @param <K> key type
* @return The {@link KeyQueryMetadata} for the storeName and key or
{@link KeyQueryMetadata#NOT_AVAILABLE}
* if streams is (re-)initializing, or {@code null} if no matching
metadata could be found.
*/
public synchronized <K> KeyQueryMetadata keyQueryMetadataForKey(final
String storeName,
final K
key,
Review Comment:
This is actually good catch. Thank you!
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
