Package io.streamthoughts.azkarra.api.annotations

Annotation Type AtLeastOnce

@Documented
@Inherited
@Target({TYPE,METHOD})
@Retention(RUNTIME)
@ConfValue(key="streams.processing.guarantee",
           value="at_least_once")
public @interface AtLeastOnce

This annotation can be used to automatically set the streams property processing.guarantee to at_least_once.

See Also:

StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.AT_LEAST_ONCE