[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367795#comment-17367795 ] A. Sophie Blee-Goldman commented on KAFKA-12960: +1 on pushing this responsibility to

[jira] [Commented] (KAFKA-8295) Optimize count() using RocksDB merge operator

[ https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363356#comment-17363356 ] A. Sophie Blee-Goldman commented on KAFKA-8295: --- Yes, any of the count DSL operators. It

[jira] [Commented] (KAFKA-12844) KIP-740 follow up: clean up TaskId

[ https://issues.apache.org/jira/browse/KAFKA-12844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363355#comment-17363355 ] A. Sophie Blee-Goldman commented on KAFKA-12844: As mentioned elsewhere, this ticket is

[jira] [Commented] (KAFKA-12843) KIP-740 follow up: clean up TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363354#comment-17363354 ] A. Sophie Blee-Goldman commented on KAFKA-12843: This was pointed out on the PR, but

[jira] [Commented] (KAFKA-12690) Remove deprecated Producer#sendOffsetsToTransaction

[ https://issues.apache.org/jira/browse/KAFKA-12690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363343#comment-17363343 ] A. Sophie Blee-Goldman commented on KAFKA-12690: Hey [~loboxu], as pointed out elsewhere

[jira] [Commented] (KAFKA-12689) Remove deprecated EOS configs

[ https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363342#comment-17363342 ] A. Sophie Blee-Goldman commented on KAFKA-12689: Hey [~loboxu], this ticket is marked

[jira] [Commented] (KAFKA-12935) Flaky Test RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore

[ https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361374#comment-17361374 ] A. Sophie Blee-Goldman commented on KAFKA-12935: Filed 

[jira] [Created] (KAFKA-12936) In-memory stores are always restored from scratch after dropping out of the group

A. Sophie Blee-Goldman created KAFKA-12936: -- Summary: In-memory stores are always restored from scratch after dropping out of the group Key: KAFKA-12936 URL:

[jira] [Commented] (KAFKA-12935) Flaky Test RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore

[ https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361367#comment-17361367 ] A. Sophie Blee-Goldman commented on KAFKA-12935: Hm, actually, I guess that could be

[jira] [Commented] (KAFKA-12935) Flaky Test RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore

[ https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361359#comment-17361359 ] A. Sophie Blee-Goldman commented on KAFKA-12935: Hm, yeah I think I've seen this fail

[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361196#comment-17361196 ] A. Sophie Blee-Goldman commented on KAFKA-8940: --- Hey [~mjsax] [~josep.prat] (and others),

[jira] [Resolved] (KAFKA-12920) Consumer's cooperative sticky assignor need to clear generation / assignment data upon `onPartitionsLost`

[ https://issues.apache.org/jira/browse/KAFKA-12920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12920. Resolution: Not A Bug > Consumer's cooperative sticky assignor need to

[jira] [Commented] (KAFKA-12920) Consumer's cooperative sticky assignor need to clear generation / assignment data upon `onPartitionsLost`

[ https://issues.apache.org/jira/browse/KAFKA-12920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360480#comment-17360480 ] A. Sophie Blee-Goldman commented on KAFKA-12920: I believe we've found the real issue,

[jira] [Comment Edited] (KAFKA-12925) prefixScan missing from intermediate interfaces

[ https://issues.apache.org/jira/browse/KAFKA-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360472#comment-17360472 ] A. Sophie Blee-Goldman edited comment on KAFKA-12925 at 6/10/21, 12:51 AM:

[jira] [Commented] (KAFKA-12925) prefixScan missing from intermediate interfaces

[ https://issues.apache.org/jira/browse/KAFKA-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360472#comment-17360472 ] A. Sophie Blee-Goldman commented on KAFKA-12925: [~sagarrao] do you think you'll be able

[jira] [Updated] (KAFKA-12925) prefixScan missing from intermediate interfaces

[ https://issues.apache.org/jira/browse/KAFKA-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12925: --- Fix Version/s: 2.8.1 3.0.0 > prefixScan missing from

[jira] [Commented] (KAFKA-12920) Consumer's cooperative sticky assignor need to clear generation / assignment data upon `onPartitionsLost`

[ https://issues.apache.org/jira/browse/KAFKA-12920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360328#comment-17360328 ] A. Sophie Blee-Goldman commented on KAFKA-12920: While there does seem to be a possible

[jira] [Updated] (KAFKA-12898) Owned partitions in the subscription must be sorted

[ https://issues.apache.org/jira/browse/KAFKA-12898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12898: --- Fix Version/s: 3.0.0 > Owned partitions in the subscription must be sorted

[jira] [Updated] (KAFKA-12883) Adress KIP-100 type constraints now that Java 7 support is dropped

[ https://issues.apache.org/jira/browse/KAFKA-12883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12883: --- Labels: StarterProject newbie++ (was: StarterProject streams) > Adress

[jira] [Updated] (KAFKA-12883) Adress KIP-100 type constraints now that Java 7 support is dropped

[ https://issues.apache.org/jira/browse/KAFKA-12883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12883: --- Component/s: streams > Adress KIP-100 type constraints now that Java 7

[jira] [Commented] (KAFKA-8295) Optimize count() using RocksDB merge operator

[ https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352731#comment-17352731 ] A. Sophie Blee-Goldman commented on KAFKA-8295: --- Thanks for the initial results – I think

[jira] [Updated] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-5876: -- Description: Currently, IQ does only throws {{InvalidStateStoreException}} for

[jira] [Updated] (KAFKA-12550) Introduce RESTORING state to the KafkaStreams FSM

[ https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12550: --- Fix Version/s: (was: 3.0.0) 4.0.0 > Introduce

[jira] [Updated] (KAFKA-12550) Introduce RESTORING state to the KafkaStreams FSM

[ https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12550: --- Priority: Major (was: Blocker) > Introduce RESTORING state to the

[jira] [Assigned] (KAFKA-12550) Introduce RESTORING state to the KafkaStreams FSM

[ https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12550: -- Assignee: (was: A. Sophie Blee-Goldman) > Introduce RESTORING

[jira] [Commented] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351970#comment-17351970 ] A. Sophie Blee-Goldman commented on KAFKA-12849: That's something we'll need to consider

[jira] [Created] (KAFKA-12851) Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable

A. Sophie Blee-Goldman created KAFKA-12851: -- Summary: Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable Key: KAFKA-12851 URL: https://issues.apache.org/jira/browse/KAFKA-12851

[jira] [Commented] (KAFKA-12848) Add some basic benchmarks for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351948#comment-17351948 ] A. Sophie Blee-Goldman commented on KAFKA-12848: [~sagarrao] John actually started to

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351946#comment-17351946 ] A. Sophie Blee-Goldman commented on KAFKA-9168: --- Sounds good! This shouldn't need a KIP

[jira] [Commented] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351940#comment-17351940 ] A. Sophie Blee-Goldman commented on KAFKA-12849: Yep – it _should_ be relatively

[jira] [Updated] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12849: --- Labels: needs-kip newbie newbie++ (was: ) > Consider migrating

[jira] [Commented] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351440#comment-17351440 ] A. Sophie Blee-Goldman commented on KAFKA-12849: Though we went through a similar

[jira] [Created] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

A. Sophie Blee-Goldman created KAFKA-12849: -- Summary: Consider migrating TaskMetadata to interface with internal implementation Key: KAFKA-12849 URL: https://issues.apache.org/jira/browse/KAFKA-12849

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351377#comment-17351377 ] A. Sophie Blee-Goldman commented on KAFKA-9168: --- There's nothing available at the moment in

[jira] [Created] (KAFKA-12848) Add some basic benchmarks for Kafka Streams

A. Sophie Blee-Goldman created KAFKA-12848: -- Summary: Add some basic benchmarks for Kafka Streams Key: KAFKA-12848 URL: https://issues.apache.org/jira/browse/KAFKA-12848 Project: Kafka

[jira] [Reopened] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-9295: --- Guess there is still something else going on here yet. At this point I think we

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351238#comment-17351238 ] A. Sophie Blee-Goldman commented on KAFKA-9168: --- Yep, I think that's exactly what we want

[jira] [Created] (KAFKA-12844) KIP-740 follow up: clean up TaskId

A. Sophie Blee-Goldman created KAFKA-12844: -- Summary: KIP-740 follow up: clean up TaskId Key: KAFKA-12844 URL: https://issues.apache.org/jira/browse/KAFKA-12844 Project: Kafka Issue

[jira] [Created] (KAFKA-12843) KIP-740 follow up: clean up TaskMetadata

A. Sophie Blee-Goldman created KAFKA-12843: -- Summary: KIP-740 follow up: clean up TaskMetadata Key: KAFKA-12843 URL: https://issues.apache.org/jira/browse/KAFKA-12843 Project: Kafka

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350650#comment-17350650 ] A. Sophie Blee-Goldman commented on KAFKA-9168: --- Yep, all the rocksdb work waiting on more

[jira] [Resolved] (KAFKA-12779) TaskMetadata should return actual TaskId rather than plain String

[ https://issues.apache.org/jira/browse/KAFKA-12779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12779. Resolution: Fixed > TaskMetadata should return actual TaskId rather than

[jira] [Commented] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

[ https://issues.apache.org/jira/browse/KAFKA-12815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348646#comment-17348646 ] A. Sophie Blee-Goldman commented on KAFKA-12815: Ack, sorry I made a bad assumption

[jira] [Commented] (KAFKA-12817) Make Task ID an Implementation Detail

[ https://issues.apache.org/jira/browse/KAFKA-12817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348619#comment-17348619 ] A. Sophie Blee-Goldman commented on KAFKA-12817: Thanks for filing this Bruno. I still

[jira] [Commented] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

[ https://issues.apache.org/jira/browse/KAFKA-12815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347887#comment-17347887 ] A. Sophie Blee-Goldman commented on KAFKA-12815: [~mjsax] should we fix back to 2.8 at

[jira] [Resolved] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-9295. --- Resolution: Fixed >

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347259#comment-17347259 ] A. Sophie Blee-Goldman commented on KAFKA-12776: [~neeraj.vaidya] although the ongoing  

[jira] [Commented] (KAFKA-12812) Consider refactoring state store registration path

[ https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347153#comment-17347153 ] A. Sophie Blee-Goldman commented on KAFKA-12812: 100% agree. Imo the old way of passing

[jira] [Commented] (KAFKA-12804) In-Memory state store backed by InMemoryKeyValueStore is slow due to synchronizing reads/writes using a single lock.

[ https://issues.apache.org/jira/browse/KAFKA-12804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346554#comment-17346554 ] A. Sophie Blee-Goldman commented on KAFKA-12804: Hey [~gorsonw] thanks for the ticket,

[jira] [Updated] (KAFKA-12781) Improve the endOffsets accuracy in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12781: --- Affects Version/s: (was: 2.8.0) > Improve the endOffsets accuracy in

[jira] [Commented] (KAFKA-12781) Improve the endOffsets accuracy in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346423#comment-17346423 ] A. Sophie Blee-Goldman commented on KAFKA-12781: Ah, that's my bad – I was discussing

[jira] [Updated] (KAFKA-12781) Improve the endOffsets accuracy in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12781: --- Fix Version/s: 3.0.0 > Improve the endOffsets accuracy in TaskMetadata >

[jira] [Commented] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346297#comment-17346297 ] A. Sophie Blee-Goldman commented on KAFKA-12796: Awesome, thanks for picking this up.

[jira] [Comment Edited] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346277#comment-17346277 ] A. Sophie Blee-Goldman edited comment on KAFKA-12419 at 5/17/21, 5:08 PM:

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346277#comment-17346277 ] A. Sophie Blee-Goldman commented on KAFKA-12419: [~josep.prat] as Bruno said, only APIs

[jira] [Commented] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346272#comment-17346272 ] A. Sophie Blee-Goldman commented on KAFKA-12796: [~josep.prat] can you track down when

[jira] [Commented] (KAFKA-12754) TaskMetadata endOffsets does not update when the offsets are read

[ https://issues.apache.org/jira/browse/KAFKA-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344863#comment-17344863 ] A. Sophie Blee-Goldman commented on KAFKA-12754: [~wcarlson5] are you sure? I tried to

[jira] [Resolved] (KAFKA-12754) TaskMetadata endOffsets does not update when the offsets are read

[ https://issues.apache.org/jira/browse/KAFKA-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12754. Fix Version/s: 3.0.0 Resolution: Fixed > TaskMetadata endOffsets

[jira] [Commented] (KAFKA-12754) TaskMetadata endOffsets does not update when the offsets are read

[ https://issues.apache.org/jira/browse/KAFKA-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344835#comment-17344835 ] A. Sophie Blee-Goldman commented on KAFKA-12754: [~wcarlson5] was this feature released

[jira] [Created] (KAFKA-12782) Javadocs search sends you to a non-existent URL

A. Sophie Blee-Goldman created KAFKA-12782: -- Summary: Javadocs search sends you to a non-existent URL Key: KAFKA-12782 URL: https://issues.apache.org/jira/browse/KAFKA-12782 Project: Kafka

[jira] [Updated] (KAFKA-12779) TaskMetadata should return actual TaskId rather than plain String

[ https://issues.apache.org/jira/browse/KAFKA-12779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12779: --- Summary: TaskMetadata should return actual TaskId rather than plain String

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344212#comment-17344212 ] A. Sophie Blee-Goldman commented on KAFKA-12776: Here we go: 

[jira] [Updated] (KAFKA-12781) Improve the endOffsets accuracy in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12781: --- Affects Version/s: 2.8.0 > Improve the endOffsets accuracy in TaskMetadata

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344206#comment-17344206 ] A. Sophie Blee-Goldman commented on KAFKA-12776: The docs for enable.idempotence just

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344186#comment-17344186 ] A. Sophie Blee-Goldman commented on KAFKA-12776: Oh. Should the docs for the config be

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344184#comment-17344184 ] A. Sophie Blee-Goldman commented on KAFKA-12776: I think the messages should be ordered

[jira] [Resolved] (KAFKA-8326) Add Serde> support

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-8326. --- Fix Version/s: 3.0.0 Resolution: Fixed > Add Serde> support >

[jira] [Reopened] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-9295: --- Unfortunately it seems to still be failing :/ 

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344150#comment-17344150 ] A. Sophie Blee-Goldman commented on KAFKA-12776: I don't think there's any way to

[jira] [Commented] (KAFKA-12780) java.lang.IllegalStateException: Tried to lookup lag for unknown task 2_0

[ https://issues.apache.org/jira/browse/KAFKA-12780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344131#comment-17344131 ] A. Sophie Blee-Goldman commented on KAFKA-12780: Hey [~iirekm2] This exception means

[jira] [Updated] (KAFKA-12779) Use TaskId instead of String for the taskId field in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12779: --- Description: Not sure why this was encoded as a String field instead of

[jira] [Updated] (KAFKA-12779) Use TaskId instead of String for the taskId field in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12779: --- Description: Not sure why this was encoded as a String field instead of

[jira] [Created] (KAFKA-12779) Use TaskId instead of String for the taskId field in TaskMetadata

A. Sophie Blee-Goldman created KAFKA-12779: -- Summary: Use TaskId instead of String for the taskId field in TaskMetadata Key: KAFKA-12779 URL: https://issues.apache.org/jira/browse/KAFKA-12779

[jira] [Updated] (KAFKA-12779) Use TaskId instead of String for the taskId field in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12779: --- Fix Version/s: 3.0.0 > Use TaskId instead of String for the taskId field in

[jira] [Assigned] (KAFKA-12779) Use TaskId instead of String for the taskId field in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12779: -- Assignee: A. Sophie Blee-Goldman > Use TaskId instead of String for

[jira] [Updated] (KAFKA-12779) Use TaskId instead of String for the taskId field in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12779: --- Labels: needs-kip (was: ) > Use TaskId instead of String for the taskId

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344042#comment-17344042 ] A. Sophie Blee-Goldman commented on KAFKA-12776: Actually it turns out a KIP was just

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344038#comment-17344038 ] A. Sophie Blee-Goldman commented on KAFKA-12776: Hey [~neeraj.vaidya], You need to set

[jira] [Updated] (KAFKA-12774) kafka-streams 2.8: logging in uncaught-exceptionhandler doesn't go through log4j

[ https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12774: --- Fix Version/s: 2.8.1 3.0.0 > kafka-streams 2.8: logging

[jira] [Commented] (KAFKA-12775) StreamsPartitionAssignor / ClientState throws an exception when a new Task gets added to a KStreams Application in a Backwards-Compatible Topology Change

[ https://issues.apache.org/jira/browse/KAFKA-12775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343588#comment-17343588 ] A. Sophie Blee-Goldman commented on KAFKA-12775: If it's any consolation, I just so

[jira] [Commented] (KAFKA-12775) StreamsPartitionAssignor / ClientState throws an exception when a new Task gets added to a KStreams Application in a Backwards-Compatible Topology Change

[ https://issues.apache.org/jira/browse/KAFKA-12775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343508#comment-17343508 ] A. Sophie Blee-Goldman commented on KAFKA-12775: [~nhab] while Bruno is correct that

[jira] [Commented] (KAFKA-12774) kafka-streams 2.8: logging in uncaught-exceptionhandler doesn't go through log4j

[ https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343505#comment-17343505 ] A. Sophie Blee-Goldman commented on KAFKA-12774: Thanks for the report – regarding how

[jira] [Updated] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12766: --- Labels: newbie newbie++ (was: ) > Consider Disabling WAL-related Options

[jira] [Updated] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12766: --- Fix Version/s: 3.0.0 > Consider Disabling WAL-related Options in RocksDB >

[jira] [Commented] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342123#comment-17342123 ] A. Sophie Blee-Goldman commented on KAFKA-12766: Personally I agree that throwing an

[jira] [Commented] (KAFKA-12749) Changelog topic config on suppressed KTable lost

[ https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342120#comment-17342120 ] A. Sophie Blee-Goldman commented on KAFKA-12749: Thanks [~vishranganathan], assigned the

[jira] [Assigned] (KAFKA-12749) Changelog topic config on suppressed KTable lost

[ https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12749: -- Assignee: Viswanathan Ranganathan > Changelog topic config on

[jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress

[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341434#comment-17341434 ] A. Sophie Blee-Goldman commented on KAFKA-8147: --- [~philbour] thanks for filing the ticket.

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339825#comment-17339825 ] A. Sophie Blee-Goldman commented on KAFKA-9295: --- [~showuon] are you interested in

[jira] [Updated] (KAFKA-12749) Changelog topic config on suppressed KTable lost

[ https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12749: --- Affects Version/s: (was: 2.6.2) (was: 2.6.1)

[jira] [Commented] (KAFKA-12749) Changelog topic config on suppressed KTable lost

[ https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339355#comment-17339355 ] A. Sophie Blee-Goldman commented on KAFKA-12749: Thanks for filing a ticket – we should

[jira] [Updated] (KAFKA-12749) Changelog topic config on suppressed KTable lost

[ https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12749: --- Fix Version/s: 3.0.0 > Changelog topic config on suppressed KTable lost >

[jira] [Updated] (KAFKA-12749) Changelog topic config on suppressed KTable lost

[ https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12749: --- Fix Version/s: 2.8.1 > Changelog topic config on suppressed KTable lost >

[jira] [Updated] (KAFKA-12749) Changelog topic config on suppressed KTable lost

[ https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12749: --- Labels: newbie newbie++ (was: ) > Changelog topic config on suppressed

[jira] [Updated] (KAFKA-12748) Explore new RocksDB options to consider enabling by default

[ https://issues.apache.org/jira/browse/KAFKA-12748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12748: --- Description: With the rocksdb version bump comes a lot of new options, some

[jira] [Created] (KAFKA-12748) Explore new RocksDB options to consider enabling by default

A. Sophie Blee-Goldman created KAFKA-12748: -- Summary: Explore new RocksDB options to consider enabling by default Key: KAFKA-12748 URL: https://issues.apache.org/jira/browse/KAFKA-12748

[jira] [Commented] (KAFKA-12747) Flaky Test RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix

[ https://issues.apache.org/jira/browse/KAFKA-12747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338612#comment-17338612 ] A. Sophie Blee-Goldman commented on KAFKA-12747: Looks like this test is flaky because

[jira] [Updated] (KAFKA-12747) Flaky Test RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix

[ https://issues.apache.org/jira/browse/KAFKA-12747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12747: --- Labels: flaky-test newbie newbie++ unit-test (was: flaky-test unit-test) >

[jira] [Created] (KAFKA-12747) Flaky Test RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix

A. Sophie Blee-Goldman created KAFKA-12747: -- Summary: Flaky Test RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix Key: KAFKA-12747 URL: https://issues.apache.org/jira/browse/KAFKA-12747

[jira] [Updated] (KAFKA-12742) 5. Checkpoint all uncorrupted state stores within the subtopology

[ https://issues.apache.org/jira/browse/KAFKA-12742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12742: --- Description: Once we have

[jira] [Updated] (KAFKA-12740) 3. Resume processing from last-cleared processor after soft crash

[ https://issues.apache.org/jira/browse/KAFKA-12740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12740: --- Description: Building off of that, we can go one step further and avoid

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