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&lt;SourceRecord&gt; 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&lt;String, String&gt; props) {

Reply via email to