You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@fluss.apache.org by "gyang94 (via GitHub)" <gi...@apache.org> on 2026/09/10 12:32:09 UTC

[I] [kafka] Integrate Produce with native Fluss append [fluss]

gyang94 opened a new issue, #4283:
URL: https://github.com/apache/fluss/issues/4283

   ### Purpose
   
   Part of #4185. PR07 of the Kafka compatibility sequence.
   
   Wire the Produce handler and raw/string transcoder to the TabletServer append gateway. Apply the same table admission contract as Metadata, isolate conversion and append errors per partition, map acknowledgements and offsets, and register Produce v3-v11.
   
   ### Acceptance criteria
   
   - [ ] Only compatible pre-created tables and valid bucket IDs reach append.
   - [ ] One invalid table or partition does not suppress independent valid writes.
   - [ ] Gateway acks/timeout and partition offsets/replication errors map correctly.
   - [ ] Kafka calls tryCompleteActions immediately after synchronous produceLog invocation, including throws, without waiting for async acknowledgements.
   - [ ] A real Kafka producer discovers native DDL tables and writes raw/string records with acks=0/1/all; native Fluss readback verifies data and metadata.
   
   ### Dependencies
   
   PR06 raw/string conversion (#4282) and independent core PR #3412 / #3455. Core changes remain owned by #3412.
   
   ### Scope boundary
   
   No new core implementation, Kafka table creation, JSON, authentication, idempotence or transactions.
   
   ### Implementation
   
   Draft PR link will be added after publication.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@fluss.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [kafka] Integrate Produce with native Fluss append [fluss]

Posted by "wuchong (via GitHub)" <gi...@apache.org>.
wuchong closed issue #4283: [kafka] Integrate Produce with native Fluss append
URL: https://github.com/apache/fluss/issues/4283


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@fluss.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org