You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2025/01/13 11:13:17 UTC
(kafka) branch trunk updated: MINOR: Remove unnecessary < from Errant Record Reporter section (#18498)
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 <ki...@gmail.com>
AuthorDate: Mon Jan 13 19:13:10 2025 +0800
MINOR: Remove unnecessary < from Errant Record Reporter section (#18498)
Reviewers: Mickael Maison <mi...@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) {