bulk-cdk-core-load/io.airbyte.cdk.load.message/ResourceReservingPartitionedQueue/publish

publish

open suspend override fun publish(value: T, partition: Int)