fraudtwin.consume_kafka_once#
- fraudtwin.consume_kafka_once(*, environment, lakehouse, max_messages=100, timeout_seconds=5.0)[source][source]#
Consume a bounded Kafka batch into immutable Bronze and Silver tables.
- Return type:
int- Parameters:
environment (LakehouseEnvironment)
lakehouse (IcebergLakehouse)
max_messages (int)
timeout_seconds (float)