Type alias ReadFromKafkaOptions
ReadFromKafkaOptions: {
commitOffsetInFinalize?: boolean;
keyDeserializer?: string;
maxNumRecords?: number;
maxReadTime?: number;
startReadTime?: number;
timestampPolicy?: "ProcessingTime" | "CreateTime" | "LogAppendTime";
valueDeserializer?: string;
}
Type declaration
-
Optional commitOffsetInFinalize?: boolean
-
Optional keyDeserializer?: string
-
Optional maxNumRecords?: number
-
Optional maxReadTime?: number
-
Optional startReadTime?: number
-
Optional timestampPolicy?: "ProcessingTime" | "CreateTime" | "LogAppendTime"
-
Optional valueDeserializer?: string