Skip to content

Commit c1c71bd

Browse files
computerscienceiscoolrtyler
authored andcommitted
Update DESIGN.md
Small spelling fix
1 parent 5c75b00 commit c1c71bd

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

doc/DESIGN.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ This section describes how end-to-end transactions that account for Kafka partit
9595

9696
On startup and after rebalance, each kafka-delta-ingest process must check its assigned partitions and re-seek the consumer when necessary. Each process must maintain an internal map of assigned partitions and current offsets. Kafka’s group management protocol guarantees that individual consumers within a group will be assigned a mutually exclusive set of partitions at any given time.
9797

98-
Upon startup or partition assignment (in case of rebalnce), to identify the last offset written to Delta Lake for each assigned partition, the kafka-delta-ingest process must locate the last txn action in the delta log for each of its assigned partitions and re-seek the consumer based on the txn.version attribute of the delta log.
98+
Upon startup or partition assignment (in case of rebalance), to identify the last offset written to Delta Lake for each assigned partition, the kafka-delta-ingest process must locate the last txn action in the delta log for each of its assigned partitions and re-seek the consumer based on the txn.version attribute of the delta log.
9999

100100
When performing a write, each process must commit the last offset of each partition within a txn action contained in the delta log entry.
101101

0 commit comments

Comments
 (0)