THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state: Accepted
Under Discussion thread: here
Discussion Vote thread: here
JIRA: here
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
Code Block | ||||
---|---|---|---|---|
| ||||
package org.apache.kafka.connect.source; // imports public abstract class SourceTask implements Task { protected SourceTaskContext context; // ... /** * .... * @deprecated Use {@link #commitRecord(SourceRecord, RecordMetadata)} instead. */ @Deprecated public void commitRecord(SourceRecord record) throws InterruptedException { } // ... |
...