Re: [PR] MINOR: Kafka Streams doc updates for 4.0 release [kafka]

Fri, 10 Jan 2025 17:14:04 -0800 


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&lt;String, Long&gt; context = new 
MockProcessorContext&lt;&gt;();
+final MockProcessorContext&lt;String, Long&gt; context = new 
MockProcessorContext<&gt;();
 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(&quot;some.other.config&quot;, &quot;some config value&quot;);
-final MockProcessorContext&lt;String, Long&gt; context = new 
MockProcessorContext&lt;&gt;(props);
+final MockProcessorContext&lt;String, Long&gt; context = new 
MockProcessorContext&lt;&gt;(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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to