[ 
https://issues.apache.org/jira/browse/KAFKA-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16356836#comment-16356836
 ] 

Filipe Agapito commented on KAFKA-6424:
---------------------------------------

This happens because {{createCountStream}} is usingĀ 
{{value.toLowerCase(Locale.getDefault())}} so an uppercase word never shows up 
in the stream and {{verifyAllKVKeys}} timeouts. I fixed it by removing the 
{{.toLowerCase}} from {{createCountStream}}.

In order to comply with the last requirement in the description I've also added 
a method that reads a file in the test resources and generates the inputValue 
list.

I'll be creating a pull request shortly.

> QueryableStateIntegrationTest#queryOnRebalance should accept raw text
> ---------------------------------------------------------------------
>
>                 Key: KAFKA-6424
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6424
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Ted Yu
>            Assignee: Filipe Agapito
>            Priority: Minor
>              Labels: newbie, unit-test
>
> I was using QueryableStateIntegrationTest#queryOnRebalance for some 
> performance test by adding more sentences to inputValues.
> I found that when the sentence contains upper case letter, the test would 
> timeout.
> I get around this limitation by calling {{sentence.toLowerCase(Locale.ROOT)}} 
> before the split.
> Ideally we can specify the path to text file which contains the text. The 
> test can read the text file and generate the input array.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to