DBZ-6235 Remove incubation notice from Debezium Server page

This commit is contained in:
harveyyue 2023-03-22 10:33:21 +08:00 committed by Jiri Pechanec
parent 1c5f14f7fd
commit cd7da5723d
13 changed files with 1 additions and 36 deletions

View File

@ -8,15 +8,12 @@
import java.util.Collections;
import java.util.List;
import io.debezium.common.annotation.Incubating;
/**
* A data change event with key, value, and headers.
*
* @param <K>
* @param <V>
*/
@Incubating
public interface ChangeEvent<K, V> {
K key();

View File

@ -19,7 +19,6 @@
import org.slf4j.LoggerFactory;
import io.debezium.DebeziumException;
import io.debezium.common.annotation.Incubating;
import io.debezium.engine.format.ChangeEventFormat;
import io.debezium.engine.format.KeyValueChangeEventFormat;
import io.debezium.engine.format.KeyValueHeaderChangeEventFormat;
@ -43,7 +42,6 @@
*
* @author Randall Hauch
*/
@Incubating
public interface DebeziumEngine<R> extends Runnable, Closeable {
String OFFSET_FLUSH_INTERVAL_MS_PROP = "offset.flush.interval.ms";

View File

@ -5,14 +5,11 @@
*/
package io.debezium.engine;
import io.debezium.common.annotation.Incubating;
/**
* A data change event described as a single object.
*
* @param <V>
*/
@Incubating
public interface RecordChangeEvent<V> {
V record();

View File

@ -5,11 +5,8 @@
*/
package io.debezium.engine.format;
import io.debezium.common.annotation.Incubating;
/**
* A {@link SerializationFormat} defining the Avro format serialized as byte[].
*/
@Incubating
public class Avro implements SerializationFormat<byte[]> {
}

View File

@ -5,12 +5,9 @@
*/
package io.debezium.engine.format;
import io.debezium.common.annotation.Incubating;
/**
* Describes a change event output format comprising just of a single value.
*/
@Incubating
public interface ChangeEventFormat<V extends SerializationFormat<?>> {
/**

View File

@ -5,11 +5,8 @@
*/
package io.debezium.engine.format;
import io.debezium.common.annotation.Incubating;
/**
* A {@link SerializationFormat} defining the CloudEvents format serialized as String.
*/
@Incubating
public class CloudEvents implements SerializationFormat<String> {
}

View File

@ -5,11 +5,8 @@
*/
package io.debezium.engine.format;
import io.debezium.common.annotation.Incubating;
/**
* A {@link SerializationFormat} defining the JSON format serialized as String.
*/
@Incubating
public class Json implements SerializationFormat<String> {
}

View File

@ -5,12 +5,9 @@
*/
package io.debezium.engine.format;
import io.debezium.common.annotation.Incubating;
/**
* Describes a change event output format comprising a key and a value.
*/
@Incubating
public interface KeyValueChangeEventFormat<K extends SerializationFormat<?>, V extends SerializationFormat<?>> {
/**

View File

@ -5,12 +5,9 @@
*/
package io.debezium.engine.format;
import io.debezium.common.annotation.Incubating;
/**
* Describes a change event output format comprising a key, value, and a header.
*/
@Incubating
public interface KeyValueHeaderChangeEventFormat<K extends SerializationFormat<?>, V extends SerializationFormat<?>, H extends SerializationFormat<?>>
extends KeyValueChangeEventFormat<K, V> {
static <K extends SerializationFormat<?>, V extends SerializationFormat<?>, H extends SerializationFormat<?>> KeyValueHeaderChangeEventFormat<K, V, H> of(

View File

@ -5,11 +5,8 @@
*/
package io.debezium.engine.format;
import io.debezium.common.annotation.Incubating;
/**
* A {@link SerializationFormat} defining the Protobuf format serialized as byte[].
*/
@Incubating
public class Protobuf implements SerializationFormat<byte[]> {
}

View File

@ -5,12 +5,10 @@
*/
package io.debezium.engine.format;
import io.debezium.common.annotation.Incubating;
import io.debezium.engine.DebeziumEngine;
/**
* The logical description of the output format used by the given instance of {@link DebeziumEngine}.
*/
@Incubating
public interface SerializationFormat<T> {
}

View File

@ -8,7 +8,6 @@
import java.time.Duration;
import java.util.Properties;
import io.debezium.common.annotation.Incubating;
import io.debezium.engine.DebeziumEngine;
/**
@ -16,7 +15,6 @@
*
* @author Randall Hauch
*/
@Incubating
@FunctionalInterface
public interface OffsetCommitPolicy {
@ -35,7 +33,7 @@ public boolean performCommit(long numberOfMessagesSinceLastCommit, Duration time
/**
* An {@link OffsetCommitPolicy} that will commit offsets no more than the specified time period. If the specified
* time is less than {@code 0} then the policy will behave as {@link AlwaysCommitOffsetPolicy}.
* @see io.debezium.engine.DebeziumEngine.OFFSET_FLUSH_INTERVAL_MS
* @see io.debezium.engine.DebeziumEngine#OFFSET_FLUSH_INTERVAL_MS_PROP
*/
class PeriodicCommitOffsetPolicy implements OffsetCommitPolicy {

View File

@ -11,8 +11,6 @@ toc::[]
[NOTE]
====
This feature is currently in incubating state, i.e. exact semantics, configuration options etc. may change in future revisions, based on the feedback we receive.
Please let us know if you encounter any problems while using this feature.
Also please reach out if you have requirements for specific sinks to be supported by {prodname} Server or even would be interested in contributing the required implementation.
====