mjsax commented on code in PR #18488: URL: https://github.com/apache/kafka/pull/18488#discussion_r1911785250
########## docs/streams/developer-guide/testing.html: ########## @@ -276,15 +276,15 @@ <h2> <p> To begin with, instantiate your processor and initialize it with the mock context: <pre class="line-numbers"><code class="language-java">final Processor processorUnderTest = ...; -final MockProcessorContext<String, Long> context = new MockProcessorContext<>(); +final MockProcessorContext<String, Long> context = new MockProcessorContext<>(); processorUnderTest.init(context);</code></pre> If you need to pass configuration to your processor or set the default serdes, you can create the mock with config: <pre class="line-numbers"><code class="language-java">final Properties props = new Properties(); props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass()); props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.Long().getClass()); props.put("some.other.config", "some config value"); -final MockProcessorContext<String, Long> context = new MockProcessorContext<>(props); +final MockProcessorContext<String, Long> context = new MockProcessorContext<>(props);</code></pre> Review Comment: adding missing closing tags -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org