This is an automated email from the ASF dual-hosted git repository. mimaison pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new cbbeccad632 MINOR: Remove unnecessary < from Errant Record Reporter section (#18498) cbbeccad632 is described below commit cbbeccad632d37c131bfa494fdb2eabc5df7610d Author: TengYao Chi <kiting...@gmail.com> AuthorDate: Mon Jan 13 19:13:10 2025 +0800 MINOR: Remove unnecessary < from Errant Record Reporter section (#18498) Reviewers: Mickael Maison <mickael.mai...@gmail.com> --- docs/connect.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/connect.html b/docs/connect.html index 16cbf0f39ea..f77e21bdf54 100644 --- a/docs/connect.html +++ b/docs/connect.html @@ -766,7 +766,7 @@ public List<SourceRecord> poll() throws InterruptedException { <p>When <a href="#connect_errorreporting">error reporting</a> is enabled for a connector, the connector can use an <code>ErrantRecordReporter</code> to report problems with individual records sent to a sink connector. The following example shows how a connector's <code>SinkTask</code> subclass might obtain and use the <code>ErrantRecordReporter</code>, safely handling a null reporter when the DLQ is not enabled or when the connector is installed in an older Connect runtime that doesn [...] - <<pre class="line-numbers"><code class="language-java">private ErrantRecordReporter reporter; + <pre class="line-numbers"><code class="language-java">private ErrantRecordReporter reporter; @Override public void start(Map<String, String> props) {