Module coord::timestamp

Structs

Metrics

RtFileConnector

Data consumer stub for File source with RT consistency

RtKafkaConnector

Data consumer for Kafka source with RT consistency

RtKinesisConnector

Data consumer stub for Kinesis source with RT consistency

RtS3Connector

Data consumer stub for S3 source with RT consistency

RtTimestampConsumer

Timestamp consumer: wrapper around source consumers that stores necessary information about topics and offset for real-time consistency

Timestamper

TimestampingState

Coordination structure for individual timestamping threads

Enums

RtTimestampConnector

TimestampMessage

Constants

CONF_DENYLIST

Functions

get_kafka_partitions

Return the list of partition ids associated with a specific topic

rt_kafka_metadata_fetch_loop