[jira] [Assigned] (KAFKA-16965) Add a "root cause" exception as a nested exception to TimeoutException for Producer
[ https://issues.apache.org/jira/browse/KAFKA-16965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi reassigned KAFKA-16965: Assignee: Alieh Saeedi > Add a "root cause" exception as a nested exception to TimeoutException for > Producer > --- > > Key: KAFKA-16965 > URL: https://issues.apache.org/jira/browse/KAFKA-16965 > Project: Kafka > Issue Type: Bug > Components: producer >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Minor > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16965) Add a "root cause" exception as a nested exception to TimeoutException for Producer
Alieh Saeedi created KAFKA-16965: Summary: Add a "root cause" exception as a nested exception to TimeoutException for Producer Key: KAFKA-16965 URL: https://issues.apache.org/jira/browse/KAFKA-16965 Project: Kafka Issue Type: Bug Reporter: Alieh Saeedi -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-15309) Add custom error handler to Producer
[ https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi reassigned KAFKA-15309: Assignee: Alieh Saeedi > Add custom error handler to Producer > > > Key: KAFKA-15309 > URL: https://issues.apache.org/jira/browse/KAFKA-15309 > Project: Kafka > Issue Type: New Feature > Components: producer >Reporter: Matthias J. Sax >Assignee: Alieh Saeedi >Priority: Major > Labels: needs-kip > Attachments: KafkaProducerReproducer.java, app.log > > > The producer collects multiple records into batches, and a single record > specific error might fail the whole batch (eg, `RecordTooLargeException`). > This ticket suggests to add a per-record error handler, that allows user to > opt into skipping bad records without failing the whole batch (similar to > Kafka Streams `ProductionExceptionHandler`). > The fix of https://issues.apache.org/jira/browse/KAFKA-9279 caused > https://issues.apache.org/jira/browse/KAFKA-15259 which inspired this ticket. > Another example for which a production exception handler could be useful, if > a user tries to write into a non-existing topic, which returns a retryable > error code; with infinite retries the producer would hang retrying forever. A > handler could help to break the infinite retry loop. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-15309) Add custom error handler to Producer
[ https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi reassigned KAFKA-15309: Assignee: (was: Alieh Saeedi) > Add custom error handler to Producer > > > Key: KAFKA-15309 > URL: https://issues.apache.org/jira/browse/KAFKA-15309 > Project: Kafka > Issue Type: New Feature > Components: producer >Reporter: Matthias J. Sax >Priority: Major > Labels: needs-kip > Attachments: KafkaProducerReproducer.java, app.log > > > The producer collects multiple records into batches, and a single record > specific error might fail the whole batch (eg, `RecordTooLargeException`). > This ticket suggests to add a per-record error handler, that allows user to > opt into skipping bad records without failing the whole batch (similar to > Kafka Streams `ProductionExceptionHandler`). > The fix of https://issues.apache.org/jira/browse/KAFKA-9279 caused > https://issues.apache.org/jira/browse/KAFKA-15259 which inspired this ticket. > Another example for which a production exception handler could be useful, if > a user tries to write into a non-existing topic, which returns a retryable > error code; with infinite retries the producer would hang retrying forever. A > handler could help to break the infinite retry loop. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-15309) Add custom error handler to Producer
[ https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi reassigned KAFKA-15309: Assignee: Alieh Saeedi > Add custom error handler to Producer > > > Key: KAFKA-15309 > URL: https://issues.apache.org/jira/browse/KAFKA-15309 > Project: Kafka > Issue Type: New Feature > Components: producer >Reporter: Matthias J. Sax >Assignee: Alieh Saeedi >Priority: Major > Labels: needs-kip > Attachments: KafkaProducerReproducer.java, app.log > > > The producer collects multiple records into batches, and a single record > specific error might fail the whole batch (eg, `RecordTooLargeException`). > This ticket suggests to add a per-record error handler, that allows user to > opt into skipping bad records without failing the whole batch (similar to > Kafka Streams `ProductionExceptionHandler`). > The fix of https://issues.apache.org/jira/browse/KAFKA-9279 caused > https://issues.apache.org/jira/browse/KAFKA-15259 which inspired this ticket. > Another example for which a production exception handler could be useful, if > a user tries to write into a non-existing topic, which returns a retryable > error code; with infinite retries the producer would hang retrying forever. A > handler could help to break the infinite retry loop. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-15257) Support interactive queries (IQv2) with versioned state store
[ https://issues.apache.org/jira/browse/KAFKA-15257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi updated KAFKA-15257: - Description: Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query was: KIP-960: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+interactive+queries+%28IQv2%29+for+versioned+state+stores] Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query > Support interactive queries (IQv2) with versioned state store > - > > Key: KAFKA-15257 > URL: https://issues.apache.org/jira/browse/KAFKA-15257 > Project: Kafka > Issue Type: New Feature > Components: streams >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > Labels: kip > > Query types to consider include: > * single-key latest-value lookup > * single-key lookup with timestamp bound > * single-key query with timestamp range > * single-key all versions query > * key-range latest-value query > * key-range query with timestamp bound > * key-range query with timestamp range > * key-range all versions query > * all-keys latest-value query > * all-keys all versions (i.e., entire store) query > > > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-15347) Single-Key_multi-timestamp IQs with versioned state stores
[ https://issues.apache.org/jira/browse/KAFKA-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi reassigned KAFKA-15347: Assignee: Alieh Saeedi > Single-Key_multi-timestamp IQs with versioned state stores > -- > > Key: KAFKA-15347 > URL: https://issues.apache.org/jira/browse/KAFKA-15347 > Project: Kafka > Issue Type: Sub-task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > [KIP-968|https://cwiki.apache.org/confluence/display/KAFKA/KIP-968%3A+Support+single-key_multi-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores] > This ticket covers just four query types: > *Key Queries with multiple timestamps:* > # single-key query with upper bound timestamp > # single-key query with lower bound timestamp > # single-key query with timestamp range > # single-key all versions query -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15348) Range IQs with versioned state stores
Alieh Saeedi created KAFKA-15348: Summary: Range IQs with versioned state stores Key: KAFKA-15348 URL: https://issues.apache.org/jira/browse/KAFKA-15348 Project: Kafka Issue Type: Sub-task Reporter: Alieh Saeedi [KIP-969|https://cwiki.apache.org/confluence/display/KAFKA/KIP-969%3A+Support+range+interactive+queries+%28IQv2%29+for+versioned+state+stores] This ticket covers all types of range queries: *Range Queries* # key-range latest-value query # key-range with lower bound latest-value query # key-range with upper bound latest-value query # all-keys (no bound) latest-value query # key-range query with timestamp (upper) bound # key-range with lower bound with timestamp (upper) bound # key-range with upper bound with timestamp (upper) bound # all-keys (no bound) with timestamp (upper) bound # key-range query with timestamp range # key-range query with lower bound with timestamp range # key-range query with upper bound with timestamp range # all-keys (no bound) with timestamp range # key-range query all-versions # key-range query with lower bound all-versions # key-range query with upper bond all-versions # all-keys query (no bound) all-versions (entire store) -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-15348) Range IQs with versioned state stores
[ https://issues.apache.org/jira/browse/KAFKA-15348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi reassigned KAFKA-15348: Assignee: Alieh Saeedi > Range IQs with versioned state stores > - > > Key: KAFKA-15348 > URL: https://issues.apache.org/jira/browse/KAFKA-15348 > Project: Kafka > Issue Type: Sub-task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > [KIP-969|https://cwiki.apache.org/confluence/display/KAFKA/KIP-969%3A+Support+range+interactive+queries+%28IQv2%29+for+versioned+state+stores] > This ticket covers all types of range queries: > *Range Queries* > # key-range latest-value query > # key-range with lower bound latest-value query > # key-range with upper bound latest-value query > # all-keys (no bound) latest-value query > # key-range query with timestamp (upper) bound > # key-range with lower bound with timestamp (upper) bound > # key-range with upper bound with timestamp (upper) bound > # all-keys (no bound) with timestamp (upper) bound > # key-range query with timestamp range > # key-range query with lower bound with timestamp range > # key-range query with upper bound with timestamp range > # all-keys (no bound) with timestamp range > # key-range query all-versions > # key-range query with lower bound all-versions > # key-range query with upper bond all-versions > # all-keys query (no bound) all-versions (entire store) -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15347) Single-Key_multi-timestamp IQs with versioned state stores
Alieh Saeedi created KAFKA-15347: Summary: Single-Key_multi-timestamp IQs with versioned state stores Key: KAFKA-15347 URL: https://issues.apache.org/jira/browse/KAFKA-15347 Project: Kafka Issue Type: Sub-task Reporter: Alieh Saeedi [KIP-968|https://cwiki.apache.org/confluence/display/KAFKA/KIP-968%3A+Support+single-key_multi-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores] This ticket covers just four query types: *Key Queries with multiple timestamps:* # single-key query with upper bound timestamp # single-key query with lower bound timestamp # single-key query with timestamp range # single-key all versions query -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-15346) Single-Key_single-timestamp IQs with versioned state stores
[ https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi updated KAFKA-15346: - Summary: Single-Key_single-timestamp IQs with versioned state stores (was: Single-Key_single-multi-timestamp IQs with versioned state stores) > Single-Key_single-timestamp IQs with versioned state stores > --- > > Key: KAFKA-15346 > URL: https://issues.apache.org/jira/browse/KAFKA-15346 > Project: Kafka > Issue Type: Sub-task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > [KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores] > This ticket covers just two query types: > *Key Queries with single timestamp:* > # single-key latest-value lookup > # single-key lookup with timestamp (upper) bound -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-15346) Single-Key_single-multi-timestamp IQs with versioned state stores
[ https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi updated KAFKA-15346: - Description: [KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores] This ticket covers just two query types: *Key Queries with single timestamp:* # single-key latest-value lookup # single-key lookup with timestamp (upper) bound was: [KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores]] This ticket covers just two query types: *Key Queries with single timestamp:* # single-key latest-value lookup # single-key lookup with timestamp (upper) bound > Single-Key_single-multi-timestamp IQs with versioned state stores > - > > Key: KAFKA-15346 > URL: https://issues.apache.org/jira/browse/KAFKA-15346 > Project: Kafka > Issue Type: Sub-task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > [KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores] > This ticket covers just two query types: > *Key Queries with single timestamp:* > # single-key latest-value lookup > # single-key lookup with timestamp (upper) bound -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-15346) Single-Key_single-multi-timestamp IQs with versioned state stores
[ https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi updated KAFKA-15346: - Description: [KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores]] This ticket covers just two query types: *Key Queries with single timestamp:* # single-key latest-value lookup # single-key lookup with timestamp (upper) bound was: [[KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores]] This ticket covers just two query types: *Key Queries with single timestamp:* # single-key latest-value lookup # single-key lookup with timestamp (upper) bound > Single-Key_single-multi-timestamp IQs with versioned state stores > - > > Key: KAFKA-15346 > URL: https://issues.apache.org/jira/browse/KAFKA-15346 > Project: Kafka > Issue Type: Sub-task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > [KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores]] > > This ticket covers just two query types: > *Key Queries with single timestamp:* > # single-key latest-value lookup > # single-key lookup with timestamp (upper) bound -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Assigned] (KAFKA-15346) Single-Key_single-multi-timestamp IQs with versioned state stores
[ https://issues.apache.org/jira/browse/KAFKA-15346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi reassigned KAFKA-15346: Assignee: Alieh Saeedi > Single-Key_single-multi-timestamp IQs with versioned state stores > - > > Key: KAFKA-15346 > URL: https://issues.apache.org/jira/browse/KAFKA-15346 > Project: Kafka > Issue Type: Sub-task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > [[KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores]] > > This ticket covers just two query types: > *Key Queries with single timestamp:* > # single-key latest-value lookup > # single-key lookup with timestamp (upper) bound -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15346) Single-Key_single-multi-timestamp IQs with versioned state stores
Alieh Saeedi created KAFKA-15346: Summary: Single-Key_single-multi-timestamp IQs with versioned state stores Key: KAFKA-15346 URL: https://issues.apache.org/jira/browse/KAFKA-15346 Project: Kafka Issue Type: Sub-task Reporter: Alieh Saeedi [[KIP-960|https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3A+Support+single-key_single-timestamp+interactive+queries+%28IQv2%29+for+versioned+state+stores]] This ticket covers just two query types: *Key Queries with single timestamp:* # single-key latest-value lookup # single-key lookup with timestamp (upper) bound -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-15257) Support interactive queries (IQv2) with versioned state store
[ https://issues.apache.org/jira/browse/KAFKA-15257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi updated KAFKA-15257: - Description: Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query was: Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query > Support interactive queries (IQv2) with versioned state store > - > > Key: KAFKA-15257 > URL: https://issues.apache.org/jira/browse/KAFKA-15257 > Project: Kafka > Issue Type: Task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > Query types to consider include: > * single-key latest-value lookup > * single-key lookup with timestamp bound > * single-key query with timestamp range > * single-key all versions query > * key-range latest-value query > * key-range query with timestamp bound > * key-range query with timestamp range > * key-range all versions query > * all-keys latest-value query > * all-keys all versions (i.e., entire store) query > > > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-15257) Support interactive queries (IQv2) with versioned state store
[ https://issues.apache.org/jira/browse/KAFKA-15257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi updated KAFKA-15257: - Description: Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query was: Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query > Support interactive queries (IQv2) with versioned state store > - > > Key: KAFKA-15257 > URL: https://issues.apache.org/jira/browse/KAFKA-15257 > Project: Kafka > Issue Type: Task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > Query types to consider include: > * single-key latest-value lookup > * single-key lookup with timestamp bound > * single-key query with timestamp range > * single-key all versions query > * key-range latest-value query > * key-range query with timestamp bound > * key-range query with timestamp range > * key-range all versions query > * all-keys latest-value query > * all-keys all versions (i.e., entire store) query > > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-15257) Support interactive queries (IQv2) with versioned state store
[ https://issues.apache.org/jira/browse/KAFKA-15257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alieh Saeedi updated KAFKA-15257: - Description: Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query was: Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query > Support interactive queries (IQv2) with versioned state store > - > > Key: KAFKA-15257 > URL: https://issues.apache.org/jira/browse/KAFKA-15257 > Project: Kafka > Issue Type: Task >Reporter: Alieh Saeedi >Assignee: Alieh Saeedi >Priority: Major > > Query types to consider include: > * single-key latest-value lookup > * single-key lookup with timestamp bound > * single-key query with timestamp range > * single-key all versions query > * key-range latest-value query > * key-range query with timestamp bound > * key-range query with timestamp range > * key-range all versions query > * all-keys latest-value query > * all-keys all versions (i.e., entire store) query > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15257) Support interactive queries (IQv2) with versioned state store
Alieh Saeedi created KAFKA-15257: Summary: Support interactive queries (IQv2) with versioned state store Key: KAFKA-15257 URL: https://issues.apache.org/jira/browse/KAFKA-15257 Project: Kafka Issue Type: Task Reporter: Alieh Saeedi Assignee: Alieh Saeedi Query types to consider include: * single-key latest-value lookup * single-key lookup with timestamp bound * single-key query with timestamp range * single-key all versions query * key-range latest-value query * key-range query with timestamp bound * key-range query with timestamp range * key-range all versions query * all-keys latest-value query * all-keys all versions (i.e., entire store) query -- This message was sent by Atlassian Jira (v8.20.10#820010)
