[jira] [Reopened] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4106: > Consumer / add configure method to PartitionAssignor interface >

[jira] [Reopened] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3117: > Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance >

[jira] [Resolved] (KAFKA-5452) Aggressive log compaction ratio appears to have no negative effect on log-compacted topics

[ https://issues.apache.org/jira/browse/KAFKA-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5452. Resolution: Fixed > Aggressive log compaction ratio appears to have no negative effect on

[jira] [Resolved] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4106. Resolution: Fixed > Consumer / add configure method to PartitionAssignor interface >

[jira] [Resolved] (KAFKA-8177) Allow for separate connect instances to have sink connectors with the same name

[ https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8177. Resolution: Fixed > Allow for separate connect instances to have sink connectors with the

[jira] [Reopened] (KAFKA-8177) Allow for separate connect instances to have sink connectors with the same name

[ https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8177: > Allow for separate connect instances to have sink connectors with the same > name >

[jira] [Reopened] (KAFKA-4187) Adding a flag to prefix topics with mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4187: > Adding a flag to prefix topics with mirror maker >

[jira] [Resolved] (KAFKA-4187) Adding a flag to prefix topics with mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4187. Resolution: Fixed > Adding a flag to prefix topics with mirror maker >

[jira] [Resolved] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3117. Resolution: Fixed > Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance >

[jira] [Reopened] (KAFKA-5452) Aggressive log compaction ratio appears to have no negative effect on log-compacted topics

[ https://issues.apache.org/jira/browse/KAFKA-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5452: > Aggressive log compaction ratio appears to have no negative effect on > log-compacted

[jira] [Resolved] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

[ https://issues.apache.org/jira/browse/KAFKA-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6014. Resolution: Fixed > new consumer mirror maker halts after committing offsets to a deleted

[jira] [Reopened] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

[ https://issues.apache.org/jira/browse/KAFKA-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6014: > new consumer mirror maker halts after committing offsets to a deleted topic >

[jira] [Reopened] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3410: > Unclean leader election and "Halting because log truncation is not allowed" >

[jira] [Reopened] (KAFKA-8255) Replica fetcher thread exits with OffsetOutOfRangeException

[ https://issues.apache.org/jira/browse/KAFKA-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8255: > Replica fetcher thread exits with OffsetOutOfRangeException >

[jira] [Reopened] (KAFKA-7698) Kafka Broker fail to start: ProducerFencedException thrown from producerstatemanager.scala!checkProducerEpoch

[ https://issues.apache.org/jira/browse/KAFKA-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7698: > Kafka Broker fail to start: ProducerFencedException thrown from >

[jira] [Resolved] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3410. Resolution: Fixed > Unclean leader election and "Halting because log truncation is not

[jira] [Resolved] (KAFKA-949) Integrate kafka into YARN

[ https://issues.apache.org/jira/browse/KAFKA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-949. --- Resolution: Fixed > Integrate kafka into YARN > - > >

[jira] [Resolved] (KAFKA-5734) Heap (Old generation space) gradually increase

[ https://issues.apache.org/jira/browse/KAFKA-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5734. Resolution: Fixed > Heap (Old generation space) gradually increase >

[jira] [Reopened] (KAFKA-5734) Heap (Old generation space) gradually increase

[ https://issues.apache.org/jira/browse/KAFKA-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5734: > Heap (Old generation space) gradually increase >

[jira] [Resolved] (KAFKA-8622) Snappy Compression Not Working

[ https://issues.apache.org/jira/browse/KAFKA-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8622. Resolution: Fixed > Snappy Compression Not Working > -- > >

[jira] [Reopened] (KAFKA-949) Integrate kafka into YARN

[ https://issues.apache.org/jira/browse/KAFKA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-949: --- > Integrate kafka into YARN > - > > Key: KAFKA-949 >

[jira] [Resolved] (KAFKA-8255) Replica fetcher thread exits with OffsetOutOfRangeException

[ https://issues.apache.org/jira/browse/KAFKA-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8255. Resolution: Fixed > Replica fetcher thread exits with OffsetOutOfRangeException >

[jira] [Reopened] (KAFKA-8622) Snappy Compression Not Working

[ https://issues.apache.org/jira/browse/KAFKA-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8622: > Snappy Compression Not Working > -- > > Key:

[jira] [Resolved] (KAFKA-7698) Kafka Broker fail to start: ProducerFencedException thrown from producerstatemanager.scala!checkProducerEpoch

[ https://issues.apache.org/jira/browse/KAFKA-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7698. Resolution: Fixed > Kafka Broker fail to start: ProducerFencedException thrown from >

[jira] [Reopened] (KAFKA-12563) Something wrong with MM2 metrics

[ https://issues.apache.org/jira/browse/KAFKA-12563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-12563: - > Something wrong with MM2 metrics > > >

[jira] [Resolved] (KAFKA-12563) Something wrong with MM2 metrics

[ https://issues.apache.org/jira/browse/KAFKA-12563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12563. - Resolution: Fixed > Something wrong with MM2 metrics >

[jira] [Resolved] (KAFKA-13372) failed authentication due to: SSL handshake failed

[ https://issues.apache.org/jira/browse/KAFKA-13372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13372. - Resolution: Fixed > failed authentication due to: SSL handshake failed >

[jira] [Reopened] (KAFKA-4329) The order of the parameters for creating the ZkUtils object is reversed

[ https://issues.apache.org/jira/browse/KAFKA-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4329: > The order of the parameters for creating the ZkUtils object is reversed >

[jira] [Reopened] (KAFKA-10352) Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint (kafka.server.LogDirFailureChannel)

[ https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10352: - > Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint >

[jira] [Resolved] (KAFKA-10352) Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint (kafka.server.LogDirFailureChannel)

[ https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10352. - Resolution: Fixed > Error while reading checkpoint file

[jira] [Resolved] (KAFKA-14398) Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT quorum servers

[ https://issues.apache.org/jira/browse/KAFKA-14398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14398. - Resolution: Fixed > Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT

[jira] [Resolved] (KAFKA-4329) The order of the parameters for creating the ZkUtils object is reversed

[ https://issues.apache.org/jira/browse/KAFKA-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4329. Resolution: Fixed > The order of the parameters for creating the ZkUtils object is

[jira] [Reopened] (KAFKA-14398) Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT quorum servers

[ https://issues.apache.org/jira/browse/KAFKA-14398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14398: - > Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT quorum servers >

[jira] [Reopened] (KAFKA-13372) failed authentication due to: SSL handshake failed

[ https://issues.apache.org/jira/browse/KAFKA-13372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-13372: - > failed authentication due to: SSL handshake failed >

[jira] [Resolved] (KAFKA-10704) Mirror maker with TLS at target

[ https://issues.apache.org/jira/browse/KAFKA-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10704. - Resolution: Fixed > Mirror maker with TLS at target > --- >

[jira] [Reopened] (KAFKA-10704) Mirror maker with TLS at target

[ https://issues.apache.org/jira/browse/KAFKA-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10704: - > Mirror maker with TLS at target > --- > >

[jira] [Assigned] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

[ https://issues.apache.org/jira/browse/KAFKA-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5870: -- Assignee: (was: Apurva Mehta) > Idempotent producer: a producerId reset causes

[jira] [Assigned] (KAFKA-5543) We don't remove the LastStableOffsetLag metric when a partition is moved away from a broker

[ https://issues.apache.org/jira/browse/KAFKA-5543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5543: -- Assignee: (was: Apurva Mehta) > We don't remove the LastStableOffsetLag metric

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-2939: -- Assignee: (was: Mani Jindal) > Make AbstractConfig.logUnused() tunable for

[jira] [Assigned] (KAFKA-5053) Send Error messages along with FindCoordinatorResponse

[ https://issues.apache.org/jira/browse/KAFKA-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5053: -- Assignee: (was: Apurva Mehta) > Send Error messages along with

[jira] [Resolved] (KAFKA-14717) KafkaStreams can' get running if the rebalance happens before StreamThread gets shutdown completely

[ https://issues.apache.org/jira/browse/KAFKA-14717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14717. - Resolution: Fixed > KafkaStreams can' get running if the rebalance happens before

[jira] [Resolved] (KAFKA-14442) GlobalKTable restoration waits requestTimeout during application restart

[ https://issues.apache.org/jira/browse/KAFKA-14442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14442. - Resolution: Fixed > GlobalKTable restoration waits requestTimeout during application

[jira] [Reopened] (KAFKA-14442) GlobalKTable restoration waits requestTimeout during application restart

[ https://issues.apache.org/jira/browse/KAFKA-14442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14442: - > GlobalKTable restoration waits requestTimeout during application restart >

[jira] [Reopened] (KAFKA-9250) Kafka streams stuck in rebalancing state after UnknownHostException

[ https://issues.apache.org/jira/browse/KAFKA-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9250: > Kafka streams stuck in rebalancing state after UnknownHostException >

[jira] [Resolved] (KAFKA-4706) Unify StreamsKafkaClient instances

[ https://issues.apache.org/jira/browse/KAFKA-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4706. Resolution: Fixed > Unify StreamsKafkaClient instances >

[jira] [Reopened] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3576: > Unify KStream and KTable API > > > Key:

[jira] [Resolved] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3576. Resolution: Fixed > Unify KStream and KTable API > > >

[jira] [Resolved] (KAFKA-13599) Upgrade RocksDB to 6.27.3

[ https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13599. - Resolution: Fixed > Upgrade RocksDB to 6.27.3 > - > >

[jira] [Reopened] (KAFKA-4706) Unify StreamsKafkaClient instances

[ https://issues.apache.org/jira/browse/KAFKA-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4706: > Unify StreamsKafkaClient instances > -- > >

[jira] [Reopened] (KAFKA-13599) Upgrade RocksDB to 6.27.3

[ https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-13599: - > Upgrade RocksDB to 6.27.3 > - > > Key:

[jira] [Resolved] (KAFKA-9250) Kafka streams stuck in rebalancing state after UnknownHostException

[ https://issues.apache.org/jira/browse/KAFKA-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9250. Resolution: Fixed > Kafka streams stuck in rebalancing state after UnknownHostException >

[jira] [Commented] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693312#comment-17693312 ] Matthias J. Sax commented on KAFKA-14747: - Talking to [~guozhang] it seem we don't need a KIP :)

[jira] [Updated] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14747: Labels: beginner newbie (was: beginner needs-kip newbie) > FK join should record

[jira] [Commented] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693060#comment-17693060 ] Matthias J. Sax commented on KAFKA-14747: - Sure. Not sure if we need a KIP or not. [~guozhang]

[jira] [Assigned] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14747: --- Assignee: Koma Zhang > FK join should record discarded subscription responses >

[jira] [Created] (KAFKA-14748) Relax non-null FK left-join requirement

Matthias J. Sax created KAFKA-14748: --- Summary: Relax non-null FK left-join requirement Key: KAFKA-14748 URL: https://issues.apache.org/jira/browse/KAFKA-14748 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14747: Description: FK-joins are subject to a race condition: If the left-hand side record is

[jira] [Created] (KAFKA-14747) FK join should record discarded subscription responses

Matthias J. Sax created KAFKA-14747: --- Summary: FK join should record discarded subscription responses Key: KAFKA-14747 URL: https://issues.apache.org/jira/browse/KAFKA-14747 Project: Kafka

[jira] [Resolved] (KAFKA-14128) Kafka Streams terminates on topic check

[ https://issues.apache.org/jira/browse/KAFKA-14128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14128. - Fix Version/s: 3.5.0 3.4.1 Resolution: Fixed > Kafka Streams

[jira] [Assigned] (KAFKA-12549) Allow state stores to opt-in transactional support

[ https://issues.apache.org/jira/browse/KAFKA-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12549: --- Assignee: (was: Alex Sorokoumov) > Allow state stores to opt-in transactional

[jira] [Assigned] (KAFKA-13024) Kafka Streams is dropping messages with null key during repartition

[ https://issues.apache.org/jira/browse/KAFKA-13024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13024: --- Assignee: (was: Alex Sorokoumov) > Kafka Streams is dropping messages with

[jira] [Assigned] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9803: -- Assignee: (was: Boyang Chen) > Allow producers to recover gracefully from

[jira] [Resolved] (KAFKA-14530) Check state updater more than once in process loops

[ https://issues.apache.org/jira/browse/KAFKA-14530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14530. - Fix Version/s: 3.5.0 Resolution: Fixed > Check state updater more than once in

[jira] [Commented] (KAFKA-14442) GlobalKTable restoration waits requestTimeout during application restart

[ https://issues.apache.org/jira/browse/KAFKA-14442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690563#comment-17690563 ] Matthias J. Sax commented on KAFKA-14442: - Just learned about

[jira] [Resolved] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14713. - Resolution: Fixed > Kafka Streams global table startup takes too long >

[jira] [Commented] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690560#comment-17690560 ] Matthias J. Sax commented on KAFKA-14713: - Ah. Thanks. That makes sense. Did not look into the

[jira] [Reopened] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14713: - > Kafka Streams global table startup takes too long >

[jira] [Updated] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14713: Fix Version/s: 3.2.0 (was: 3.4.0) > Kafka Streams global table

[jira] [Comment Edited] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690055#comment-17690055 ] Matthias J. Sax edited comment on KAFKA-14713 at 2/16/23 11:52 PM: ---

[jira] [Commented] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690055#comment-17690055 ] Matthias J. Sax commented on KAFKA-14713: - Thanks for getting back. Glad it's resolved. I am not

[jira] [Updated] (KAFKA-14722) Make BooleanSerde public

[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14722: Description: We introduce a "BooleanSerde" via

[jira] [Commented] (KAFKA-14722) Make BooleanSerde public

[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689401#comment-17689401 ] Matthias J. Sax commented on KAFKA-14722: - Thanks for you interest. We will need a KIP for this

[jira] [Comment Edited] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689356#comment-17689356 ] Matthias J. Sax edited comment on KAFKA-14713 at 2/15/23 9:44 PM: -- What

[jira] [Commented] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689356#comment-17689356 ] Matthias J. Sax commented on KAFKA-14713: - What version are you using? – Also, can you point me

[jira] [Created] (KAFKA-14722) Make BooleanSerde public

Matthias J. Sax created KAFKA-14722: --- Summary: Make BooleanSerde public Key: KAFKA-14722 URL: https://issues.apache.org/jira/browse/KAFKA-14722 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-14717) KafkaStreams can' get running if the rebalance happens before StreamThread gets shutdown completely

[ https://issues.apache.org/jira/browse/KAFKA-14717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14717: Component/s: streams > KafkaStreams can' get running if the rebalance happens before

[jira] [Commented] (KAFKA-14713) Kafka Streams global table startup takes too long

[ https://issues.apache.org/jira/browse/KAFKA-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688679#comment-17688679 ] Matthias J. Sax commented on KAFKA-14713: - Sounds like a duplicate to

[jira] [Updated] (KAFKA-14660) Divide by zero security vulnerability (sonatype-2019-0422)

[ https://issues.apache.org/jira/browse/KAFKA-14660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14660: Fix Version/s: 3.4.1 > Divide by zero security vulnerability (sonatype-2019-0422) >

[jira] [Commented] (KAFKA-14660) Divide by zero security vulnerability (sonatype-2019-0422)

[ https://issues.apache.org/jira/browse/KAFKA-14660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684958#comment-17684958 ] Matthias J. Sax commented on KAFKA-14660: - Correct. 3.4.0 is already voted and should be

[jira] [Comment Edited] (KAFKA-14660) Divide by zero security vulnerability (sonatype-2019-0422)

[ https://issues.apache.org/jira/browse/KAFKA-14660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683951#comment-17683951 ] Matthias J. Sax edited comment on KAFKA-14660 at 2/3/23 4:52 PM: - Not

[jira] [Commented] (KAFKA-14660) Divide by zero security vulnerability (sonatype-2019-0422)

[ https://issues.apache.org/jira/browse/KAFKA-14660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683951#comment-17683951 ] Matthias J. Sax commented on KAFKA-14660: - Not sure why the PR was not auto-linked... Fixed.

[jira] [Commented] (KAFKA-14660) Divide by zero security vulnerability (sonatype-2019-0422)

[ https://issues.apache.org/jira/browse/KAFKA-14660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682648#comment-17682648 ] Matthias J. Sax commented on KAFKA-14660: - The original PR did not make sense, as if

[jira] [Assigned] (KAFKA-14650) IQv2 can throw ConcurrentModificationException when accessing Tasks

[ https://issues.apache.org/jira/browse/KAFKA-14650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14650: --- Assignee: Guozhang Wang > IQv2 can throw ConcurrentModificationException when

[jira] [Commented] (KAFKA-14646) SubscriptionWrapper is of an incompatible version (Kafka Streams 3.2.3 -> 3.3.2)

[ https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682401#comment-17682401 ] Matthias J. Sax commented on KAFKA-14646: - I was thinking about this issue, and I think the only

[jira] [Commented] (KAFKA-14660) Divide by zero security vulnerability (sonatype-2019-0422)

[ https://issues.apache.org/jira/browse/KAFKA-14660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682291#comment-17682291 ] Matthias J. Sax commented on KAFKA-14660: - Hey Andy – thanks for the ticket. We would have

[jira] [Assigned] (KAFKA-14660) Divide by zero security vulnerability (sonatype-2019-0422)

[ https://issues.apache.org/jira/browse/KAFKA-14660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14660: --- Assignee: Matthias J. Sax > Divide by zero security vulnerability

[jira] [Resolved] (KAFKA-14646) SubscriptionWrapper is of an incompatible version (Kafka Streams 3.2.3 -> 3.3.2)

[ https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14646. - Fix Version/s: 3.4.0 3.3.3 Resolution: Fixed >

[jira] [Commented] (KAFKA-13769) KTable FK join can miss records if an upstream non-key-changing operation changes key serializer

[ https://issues.apache.org/jira/browse/KAFKA-13769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680858#comment-17680858 ] Matthias J. Sax commented on KAFKA-13769: - I just updated fixed version from 3.0.0 to 3.3.3 and

[jira] [Updated] (KAFKA-13769) KTable FK join can miss records if an upstream non-key-changing operation changes key serializer

[ https://issues.apache.org/jira/browse/KAFKA-13769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13769: Fix Version/s: 3.4.0 3.3.3 (was: 3.3.0) >

[jira] [Updated] (KAFKA-14646) SubscriptionWrapper is of an incompatible version (Kafka Streams 3.2.3 -> 3.3.2)

[ https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14646: Affects Version/s: 3.3.1 3.3.0 > SubscriptionWrapper is of an

[jira] [Commented] (KAFKA-14646) SubscriptionWrapper is of an incompatible version (Kafka Streams 3.2.3 -> 3.3.2)

[ https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680857#comment-17680857 ] Matthias J. Sax commented on KAFKA-14646: - Ok. Talked to Alex and he quickly figured it out –

[jira] [Commented] (KAFKA-14646) SubscriptionWrapper is of an incompatible version (Kafka Streams 3.2.3 -> 3.3.2)

[ https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680840#comment-17680840 ] Matthias J. Sax commented on KAFKA-14646: - Could be – let me sync with Alex who worked on the

[jira] [Commented] (KAFKA-14646) SubscriptionWrapper is of an incompatible version (Kafka Streams 3.2.3 -> 3.3.2)

[ https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680042#comment-17680042 ] Matthias J. Sax commented on KAFKA-14646: - Thanks for following up – glad to hear that it's in

[jira] [Comment Edited] (KAFKA-14646) SubscriptionWrapper is of an incompatible version (Kafka Streams 3.2.3 -> 3.3.2)

[ https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679991#comment-17679991 ] Matthias J. Sax edited comment on KAFKA-14646 at 1/23/23 7:21 PM: -- Did

[jira] [Commented] (KAFKA-14646) SubscriptionWrapper is of an incompatible version (Kafka Streams 3.2.3 -> 3.3.2)

[ https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679991#comment-17679991 ] Matthias J. Sax commented on KAFKA-14646: - Did you upgrade with two rolling bounced leveraging

[jira] [Resolved] (KAFKA-14638) Documentation for transaction.timeout.ms should be more precise

[ https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14638. - Fix Version/s: 3.5.0 Resolution: Fixed > Documentation for

[jira] [Updated] (KAFKA-14638) Documentation for transaction.timeout.ms should be more precise

[ https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14638: Issue Type: Improvement (was: Bug) > Documentation for transaction.timeout.ms should be

[jira] [Updated] (KAFKA-14638) Documentation for transaction.timeout.ms should be more precise

[ https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14638: Component/s: docs > Documentation for transaction.timeout.ms should be more precise >

[jira] [Updated] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14302: Priority: Critical (was: Major) > Infinite probing rebalance if a changelog topic got

[jira] [Commented] (KAFKA-14624) State restoration is broken with standby tasks and cache-enabled stores in processor API

[ https://issues.apache.org/jira/browse/KAFKA-14624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676934#comment-17676934 ] Matthias J. Sax commented on KAFKA-14624: - Thanks for reporting this issue – will need to think

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