Package org.voltdb.stream.api.kafka
package org.voltdb.stream.api.kafka
-
ClassDescriptionRecordBuilder for Headers instances.KafkaRequest<K,
V> this interface exposes key, value and headers of kafka message consumed from broker.This handler handles only errors of the poll step, this can be any of consumer misconfiguration, timeout exception, deserialization exception.this configurator can be autoconfigured using helm's values under streaming.pipeline.configuration.this configurator can be autoconfigured using helm's values under streaming.pipeline.configuration.