[jira] [Created] (KAFKA-9302) Allow custom partitioning in foreign-key joins

Matthias J. Sax created KAFKA-9302: -- Summary: Allow custom partitioning in foreign-key joins Key: KAFKA-9302 URL: https://issues.apache.org/jira/browse/KAFKA-9302 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-9302) Allow custom partitioning in table-table joins

[ https://issues.apache.org/jira/browse/KAFKA-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9302: --- Summary: Allow custom partitioning in table-table joins (was: Allow custom partitioning in f

[jira] [Updated] (KAFKA-9302) Allow custom partitioning in table-table joins

[ https://issues.apache.org/jira/browse/KAFKA-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9302: --- Description: For KTables, Kafka Streams assume that both input tables are partitions by thei

[jira] [Commented] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997520#comment-16997520 ] Matthias J. Sax commented on KAFKA-9243: Thanks for your interest [~miroswan]! I

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997527#comment-16997527 ] Matthias J. Sax commented on KAFKA-9148: [~adamretter] Thanks a lot for your resp

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997533#comment-16997533 ] Matthias J. Sax commented on KAFKA-9259: Consider KAFKA-9260, especially Guozhang

[jira] [Commented] (KAFKA-9304) Image on Kafka docs shows incorrect message ID segments

[ https://issues.apache.org/jira/browse/KAFKA-9304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997678#comment-16997678 ] Matthias J. Sax commented on KAFKA-9304: [~orangesnap] Each line in the left box,

[jira] [Commented] (KAFKA-8744) Add Support to Scala API for KIP-307 and KIP-479

[ https://issues.apache.org/jira/browse/KAFKA-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998437#comment-16998437 ] Matthias J. Sax commented on KAFKA-8744: [~fhussonnois] Do you have any plans to

[jira] [Updated] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

[ https://issues.apache.org/jira/browse/KAFKA-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9310: --- Component/s: streams > StreamThread may die from recoverable UnknownProducerId exception > --

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998700#comment-16998700 ] Matthias J. Sax commented on KAFKA-9146: If you use static group membership ([ht

[jira] [Commented] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998703#comment-16998703 ] Matthias J. Sax commented on KAFKA-9243: The KTable JavaDocs you mentioned should

[jira] [Commented] (KAFKA-9304) Image on Kafka docs shows incorrect message ID segments

[ https://issues.apache.org/jira/browse/KAFKA-9304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998705#comment-16998705 ] Matthias J. Sax commented on KAFKA-9304: I am frankly not entirely sure, and was

[jira] [Commented] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000233#comment-17000233 ] Matthias J. Sax commented on KAFKA-9321: The behavior you describe is know and do

[jira] [Resolved] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9321. Resolution: Duplicate > StreamsBuilder table method overwrites the materialized parameter >

[jira] [Commented] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000241#comment-17000241 ] Matthias J. Sax commented on KAFKA-9321: Btw: We plan to add `KStream#toTable()`

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000252#comment-17000252 ] Matthias J. Sax commented on KAFKA-7663: Don't think we need a new parameter – if

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000476#comment-17000476 ] Matthias J. Sax commented on KAFKA-7663: Well, there is no design yet, but I woul

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17001085#comment-17001085 ] Matthias J. Sax commented on KAFKA-9259: It's up to you – I see value to work on

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17001246#comment-17001246 ] Matthias J. Sax commented on KAFKA-9173: So should we close this as "not a proble

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002531#comment-17002531 ] Matthias J. Sax commented on KAFKA-9173: {quote}The second issue is that when 210

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002962#comment-17002962 ] Matthias J. Sax commented on KAFKA-9259: As described in the ticket. Don't set an

[jira] [Assigned] (KAFKA-9334) Add more unit tests for Materialized class

[ https://issues.apache.org/jira/browse/KAFKA-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9334: -- Assignee: Sainath Batthala > Add more unit tests for Materialized class >

[jira] [Commented] (KAFKA-9334) Add more unit tests for Materialized class

[ https://issues.apache.org/jira/browse/KAFKA-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003749#comment-17003749 ] Matthias J. Sax commented on KAFKA-9334: Thanks for the ticket and PR. I added yo

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Component/s: clients > Kafka Streams lag not zero when input topic transactional > --

[jira] [Updated] (KAFKA-6607) Consumer Client and Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Summary: Consumer Client and Kafka Streams lag not zero when input topic transactional (was:

[jira] [Updated] (KAFKA-6607) Consumer Client and Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Description: When an input topic for a Consumer or Kafka Streams application is written usin

[jira] [Updated] (KAFKA-6607) Consumer Client and Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Description: When an input topic for a Consumer or Kafka Streams application is written usin

[jira] [Commented] (KAFKA-9331) Add option to terminate application when StreamThread(s) die

[ https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004305#comment-17004305 ] Matthias J. Sax commented on KAFKA-9331: Well, if a thread dies, the assumption i

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004610#comment-17004610 ] Matthias J. Sax commented on KAFKA-7663: I don't think that option (2) is a good

[jira] [Commented] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004611#comment-17004611 ] Matthias J. Sax commented on KAFKA-9011: I think it's actually borderline to cher

[jira] [Created] (KAFKA-9341) Flaky Test TopicCommandWithAdminClientTest#testCreateWithReplicaAssignment

Matthias J. Sax created KAFKA-9341: -- Summary: Flaky Test TopicCommandWithAdminClientTest#testCreateWithReplicaAssignment Key: KAFKA-9341 URL: https://issues.apache.org/jira/browse/KAFKA-9341 Project:

[jira] [Resolved] (KAFKA-9331) Add option to terminate application when StreamThread(s) die

[ https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9331. Resolution: Duplicate > Add option to terminate application when StreamThread(s) die >

[jira] [Updated] (KAFKA-9294) Enhance DSL Naming Guide to Include All Naming Rules

[ https://issues.apache.org/jira/browse/KAFKA-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9294: --- Description: We already have a naming guide in the docs, but we should expand it to cover ho

[jira] [Assigned] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7994: -- Assignee: Richard Yu > Improve Stream-Time for rebalances and restarts > -

[jira] [Resolved] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7994. Resolution: Fixed > Improve Stream-Time for rebalances and restarts > -

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006224#comment-17006224 ] Matthias J. Sax commented on KAFKA-7994: This particular issue about stream time

[jira] [Resolved] (KAFKA-9334) Add more unit tests for Materialized class

[ https://issues.apache.org/jira/browse/KAFKA-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9334. Fix Version/s: 2.5.0 Resolution: Fixed > Add more unit tests for Materialized class

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006512#comment-17006512 ] Matthias J. Sax commented on KAFKA-7663: For (3), checking if our internal proces

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007697#comment-17007697 ] Matthias J. Sax commented on KAFKA-7994: Feel free to update the ticket – but we

[jira] [Updated] (KAFKA-9377) Refactor StreamsPartitionAssignor Repartition Count logic

[ https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9377: --- Component/s: streams > Refactor StreamsPartitionAssignor Repartition Count logic > --

[jira] [Updated] (KAFKA-9378) Revisit the sub-topology initialization logic

[ https://issues.apache.org/jira/browse/KAFKA-9378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9378: --- Component/s: streams > Revisit the sub-topology initialization logic > --

[jira] [Commented] (KAFKA-9290) Update IQ related JavaDocs

[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009922#comment-17009922 ] Matthias J. Sax commented on KAFKA-9290: Seems there is some overlap between both

[jira] [Commented] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009923#comment-17009923 ] Matthias J. Sax commented on KAFKA-9243: [~miroswan] – just rediscovered KAFKA-92

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010080#comment-17010080 ] Matthias J. Sax commented on KAFKA-8264: Failed again:  [https://builds.apache.or

[jira] [Created] (KAFKA-9379) Flaky Test TopicCommandWithAdminClientTest.testCreateAlterTopicWithRackAware

Matthias J. Sax created KAFKA-9379: -- Summary: Flaky Test TopicCommandWithAdminClientTest.testCreateAlterTopicWithRackAware Key: KAFKA-9379 URL: https://issues.apache.org/jira/browse/KAFKA-9379 Projec

[jira] [Resolved] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6614. Fix Version/s: 2.5.0 Resolution: Fixed > kafka-streams to configure internal topics

[jira] [Assigned] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6614: -- Assignee: Sophie Blee-Goldman (was: Meghana Gupta) > kafka-streams to configure inter

[jira] [Updated] (KAFKA-8869) Map taskConfigs in KafkaConfigBackingStore grows monotonically despite of task removals

[ https://issues.apache.org/jira/browse/KAFKA-8869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8869: --- Fix Version/s: (was: 2.50) 2.5.0 > Map taskConfigs in KafkaConfigBacki

[jira] [Assigned] (KAFKA-8744) Add Support to Scala API for KIP-307 and KIP-479

[ https://issues.apache.org/jira/browse/KAFKA-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8744: -- Assignee: Matthias J. Sax (was: Florian Hussonnois) > Add Support to Scala API for KI

[jira] [Assigned] (KAFKA-9176) Flaky test failure: OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore

[ https://issues.apache.org/jira/browse/KAFKA-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9176: -- Assignee: (was: Matthias J. Sax) > Flaky test failure: > OptimizedKTableIntegrat

[jira] [Assigned] (KAFKA-9182) Flaky Test org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled

[ https://issues.apache.org/jira/browse/KAFKA-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9182: -- Assignee: (was: Matthias J. Sax) > Flaky Test > org.apache.kafka.streams.integrat

[jira] [Created] (KAFKA-9388) Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables

Matthias J. Sax created KAFKA-9388: -- Summary: Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables Key: KAFKA-9388 URL: https://issues.apache.org/jira/brow

[jira] [Resolved] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6049. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams: Add Cogroup in the DSL > ---

[jira] [Commented] (KAFKA-9290) Update IQ related JavaDocs

[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011309#comment-17011309 ] Matthias J. Sax commented on KAFKA-9290: Sure. Note that there is some overlap wi

[jira] [Commented] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011311#comment-17011311 ] Matthias J. Sax commented on KAFKA-9075: Feel free to pick it up :) > Extend doc

[jira] [Commented] (KAFKA-9176) Flaky test failure: OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore

[ https://issues.apache.org/jira/browse/KAFKA-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011351#comment-17011351 ] Matthias J. Sax commented on KAFKA-9176: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9341) Flaky Test TopicCommandWithAdminClientTest#testCreateWithReplicaAssignment

[ https://issues.apache.org/jira/browse/KAFKA-9341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011354#comment-17011354 ] Matthias J. Sax commented on KAFKA-9341: [https://builds.apache.org/job/kafka-pr-

[jira] [Resolved] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

[ https://issues.apache.org/jira/browse/KAFKA-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9068. Fix Version/s: 2.4.1 2.3.2 2.5.0 Resolution: Fi

[jira] [Resolved] (KAFKA-9383) Expose Consumer Group Metadata for Transactional Producer

[ https://issues.apache.org/jira/browse/KAFKA-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9383. Fix Version/s: 2.5.0 Resolution: Fixed > Expose Consumer Group Metadata for Transact

[jira] [Assigned] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

[ https://issues.apache.org/jira/browse/KAFKA-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9068: -- Assignee: David Kim > Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)` > -

[jira] [Commented] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

[ https://issues.apache.org/jira/browse/KAFKA-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012079#comment-17012079 ] Matthias J. Sax commented on KAFKA-9068: [~zealiard] I added you to the list on c

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013108#comment-17013108 ] Matthias J. Sax commented on KAFKA-9398: The root cause seems to be https://issue

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013109#comment-17013109 ] Matthias J. Sax commented on KAFKA-9398: Other related issue: https://issues.apac

[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013111#comment-17013111 ] Matthias J. Sax commented on KAFKA-3539: Seems KAFKA-3450 is a duplicate? > Kafk

[jira] [Commented] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013110#comment-17013110 ] Matthias J. Sax commented on KAFKA-3450: Seem KAFKA-3539 is a duplicate? > Produ

[jira] [Resolved] (KAFKA-6571) KafkaProducer.close(0) should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6571. Resolution: Duplicate KIP-367 add `close(Duration)` with new non-blocking semantics:  [http

[jira] [Commented] (KAFKA-8178) KafkaProducer#send(ProducerRecord,Callback) may block for up to 60 seconds

[ https://issues.apache.org/jira/browse/KAFKA-8178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013117#comment-17013117 ] Matthias J. Sax commented on KAFKA-8178: KAFKA-3450 is also related > KafkaProdu

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013115#comment-17013115 ] Matthias J. Sax commented on KAFKA-9398: Other one: https://issues.apache.org/jir

[jira] [Created] (KAFKA-9399) Flaky Test BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild

Matthias J. Sax created KAFKA-9399: -- Summary: Flaky Test BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild Key: KAFKA-9399 URL: https://issues.apache.org/jira/browse/KAFKA-9399 Pro

[jira] [Commented] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013208#comment-17013208 ] Matthias J. Sax commented on KAFKA-6078: [https://builds.apache.org/job/kafka-pr-

[jira] [Updated] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8377: --- Description: Kafka Streams uses an optimization to not materialize every result KTable. If a

[jira] [Updated] (KAFKA-9427) StateRestoreListener.onRestoreEnd should report actual message count

[ https://issues.apache.org/jira/browse/KAFKA-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9427: --- Component/s: streams > StateRestoreListener.onRestoreEnd should report actual message count >

[jira] [Updated] (KAFKA-9417) Add extension to the TransactionsTest.transactions_test for new EOS model

[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9417: --- Component/s: streams > Add extension to the TransactionsTest.transactions_test for new EOS mo

[jira] [Updated] (KAFKA-9418) Add new sendOffsets API to include consumer group metadata

[ https://issues.apache.org/jira/browse/KAFKA-9418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9418: --- Component/s: streams > Add new sendOffsets API to include consumer group metadata > -

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015405#comment-17015405 ] Matthias J. Sax commented on KAFKA-9042: Thanks for the PR [~high.lee] – note tha

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015406#comment-17015406 ] Matthias J. Sax commented on KAFKA-8770: [~Yohan123] – just a heads up – I am swa

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015428#comment-17015428 ] Matthias J. Sax commented on KAFKA-9013: [https://builds.apache.org/job/kafka-pr-

[jira] [Reopened] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8677: Reopening this ticket. Test failed again:  [https://builds.apache.org/job/kafka-pr-jdk11-scala2

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8677: --- Affects Version/s: 2.5.0 > Flakey test > GroupEndToEndAuthorizationTest#testNoDescribeProduc

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8677: --- Fix Version/s: (was: 2.4.0) > Flakey test > GroupEndToEndAuthorizationTest#testNoDescrib

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8677: --- Priority: Critical (was: Blocker) > Flakey test > GroupEndToEndAuthorizationTest#testNoDesc

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8677: --- Affects Version/s: (was: 2.4.0) > Flakey test > GroupEndToEndAuthorizationTest#testNoDes

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015502#comment-17015502 ] Matthias J. Sax commented on KAFKA-7591: {quote}Shouldn't you need to reset the a

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015630#comment-17015630 ] Matthias J. Sax commented on KAFKA-9042: Sure. Done. :)  > Auto infer external t

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015631#comment-17015631 ] Matthias J. Sax commented on KAFKA-7591: Yes, it would be a semantic issue. The i

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016352#comment-17016352 ] Matthias J. Sax commented on KAFKA-7591: Personally, I don't see why updating the

[jira] [Commented] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016358#comment-17016358 ] Matthias J. Sax commented on KAFKA-3596: I don't think that the behavior changed

[jira] [Assigned] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9441: -- Assignee: Matthias J. Sax > Refactor commit logic > - > >

[jira] [Created] (KAFKA-9441) Refactor commit logic

Matthias J. Sax created KAFKA-9441: -- Summary: Refactor commit logic Key: KAFKA-9441 URL: https://issues.apache.org/jira/browse/KAFKA-9441 Project: Kafka Issue Type: Sub-task Compon

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016395#comment-17016395 ] Matthias J. Sax commented on KAFKA-7591: SGTM. > Changelog retention period does

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017370#comment-17017370 ] Matthias J. Sax commented on KAFKA-9259: Could KAFKA-8317 be a duplicate? > supp

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017385#comment-17017385 ] Matthias J. Sax commented on KAFKA-9042: Did you read how the KIP process works?

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017388#comment-17017388 ] Matthias J. Sax commented on KAFKA-7658: Not sure what your question is? > Add K

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017575#comment-17017575 ] Matthias J. Sax commented on KAFKA-9042: All good :) Nothing to worry about. We a

[jira] [Created] (KAFKA-9451) Pass consumer group metadata to producer on commit

Matthias J. Sax created KAFKA-9451: -- Summary: Pass consumer group metadata to producer on commit Key: KAFKA-9451 URL: https://issues.apache.org/jira/browse/KAFKA-9451 Project: Kafka Issue Ty

[jira] [Assigned] (KAFKA-9451) Pass consumer group metadata to producer on commit

[ https://issues.apache.org/jira/browse/KAFKA-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9451: -- Assignee: Matthias J. Sax > Pass consumer group metadata to producer on commit > -

[jira] [Updated] (KAFKA-9451) Pass consumer group metadata to producer on commit

[ https://issues.apache.org/jira/browse/KAFKA-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9451: --- Description: Using producer per thread EOS design, we need to pass the consumer group metadat

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018460#comment-17018460 ] Matthias J. Sax commented on KAFKA-7658: Yes, it's ok to pick this up and assign

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018750#comment-17018750 ] Matthias J. Sax commented on KAFKA-9450: [~vvcephei] Your comment seem to be an o

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020489#comment-17020489 ] Matthias J. Sax commented on KAFKA-9450: For EOS, we don't write a checkpoint fil

<    1   2   3   4   5   6   7   8   9   10   >