Uses of Enum Class
com.helix.core.stream.kafka.CommitMode
Packages that use CommitMode
-
Uses of CommitMode in com.helix.core.stream.kafka
Methods in com.helix.core.stream.kafka that return CommitModeModifier and TypeMethodDescriptionKafkaStreamConfig.getCommitMode()static CommitModeReturns the enum constant of this class with the specified name.static CommitMode[]CommitMode.values()Returns an array containing the constants of this enum class, in the order they are declared.Methods in com.helix.core.stream.kafka with parameters of type CommitModeConstructors in com.helix.core.stream.kafka with parameters of type CommitModeModifierConstructorDescriptionKafkaStreamConfig(String bootstrapServers, String groupId, Set<String> inputTopics, String outputTopic, String autoOffsetReset, boolean enableAutoCommit, CommitMode commitMode, Duration pollTimeout, int maxPollRecords, int maxInFlightPerPartition, int lowWatermarkPerPartition, Map<String, Object> customConsumerProps, Map<String, Object> customProducerProps)