Sophie Blee-Goldman created KAFKA-10579:
---
Summary: Flaky test
connect.integration.InternalTopicsIntegrationTest.testStartWhenInternalTopicsCreatedManuallyWithCompactForBrokersDefaultCleanupPolicy
Key: KAFKA-10579
Sophie Blee-Goldman created KAFKA-10563:
---
Summary: Make sure task directories don't remain locked by dead
threads
Key: KAFKA-10563
URL: https://issues.apache.org/jira/browse/KAFKA-10563
Sophie Blee-Goldman created KAFKA-10559:
---
Summary: Don't shutdown the entire app upon TimeoutException
during internal topic validation
Key: KAFKA-10559
URL:
[
https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-6127.
Resolution: Fixed
> Streams should never block infinitely
>
[
https://issues.apache.org/jira/browse/KAFKA-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-7970.
Fix Version/s: 2.7.0
Assignee: Bruno Cadonna
Resolution: Fixed
>
Sophie Blee-Goldman created KAFKA-10455:
---
Summary: Probing rebalances are not guaranteed to be triggered by
non-leader members
Key: KAFKA-10455
URL: https://issues.apache.org/jira/browse/KAFKA-10455
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-10395.
-
Fix Version/s: 2.7.0
Resolution: Fixed
> TopologyTestDriver does not
Sophie Blee-Goldman created KAFKA-10395:
---
Summary: TopologyTestDriver does not work with dynamic topic
routing
Key: KAFKA-10395
URL: https://issues.apache.org/jira/browse/KAFKA-10395
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-9161:
> Close gaps in Streams configs documentation
>
Sophie Blee-Goldman created KAFKA-10264:
---
Summary: Flaky Test TransactionsTest.testBumpTransactionalEpoch
Key: KAFKA-10264
URL: https://issues.apache.org/jira/browse/KAFKA-10264
Project: Kafka
Sophie Blee-Goldman created KAFKA-10262:
---
Summary: StateDirectory is not thread-safe
Key: KAFKA-10262
URL: https://issues.apache.org/jira/browse/KAFKA-10262
Project: Kafka
Issue Type:
Sophie Blee-Goldman created KAFKA-10251:
---
Summary: Flaky Test
kafka.api.TransactionsBounceTest.testWithGroupMetadata
Key: KAFKA-10251
URL: https://issues.apache.org/jira/browse/KAFKA-10251
Sophie Blee-Goldman created KAFKA-10249:
---
Summary: In-memory stores are skipped when checkpointing but not
skipped when reading the checkpoint
Key: KAFKA-10249
URL:
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-10191.
-
Resolution: Fixed
> fix flaky StreamsOptimizedTest
>
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-10166:
-
Assignee: (was: Bruno Cadonna)
Found two edge cases we missed earlier so
[
https://issues.apache.org/jira/browse/KAFKA-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-6508.
Resolution: Fixed
This should be addressed via KIP-441
> Look into optimizing
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-10166.
-
Resolution: Fixed
> Excessive TaskCorruptedException seen in testing
>
[
https://issues.apache.org/jira/browse/KAFKA-8197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-8197:
Saw this fail again:
kafka.server.DynamicBrokerConfigTest >
Sophie Blee-Goldman created KAFKA-10198:
---
Summary: Dirty tasks may be recycled instead of closed
Key: KAFKA-10198
URL: https://issues.apache.org/jira/browse/KAFKA-10198
Project: Kafka
Sophie Blee-Goldman created KAFKA-10186:
---
Summary: Aborting transaction with pending data should throw
non-fatal exception
Key: KAFKA-10186
URL: https://issues.apache.org/jira/browse/KAFKA-10186
[
https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-9509:
Saw this fail again on a PR build:
h3. Stacktrace
java.lang.RuntimeException: Could
[
https://issues.apache.org/jira/browse/KAFKA-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-10151.
-
Fix Version/s: 2.6.0
Resolution: Fixed
> Flaky Test
>
[
https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-9974:
Unfortunately this just failed again, at a different place:
h3. Stacktrace
Sophie Blee-Goldman created KAFKA-10177:
---
Summary: Replace/improve/remove Percentiles metric
Key: KAFKA-10177
URL: https://issues.apache.org/jira/browse/KAFKA-10177
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-9896:
Assignee: Sophie Blee-Goldman (was: Matthias J. Sax)
Saw this fail again
Sophie Blee-Goldman created KAFKA-10169:
---
Summary: KafkaException: Failing batch since transaction was
aborted
Key: KAFKA-10169
URL: https://issues.apache.org/jira/browse/KAFKA-10169
Project:
Sophie Blee-Goldman created KAFKA-10166:
---
Summary: Excessive TaskCorruptedException seen in soak
Key: KAFKA-10166
URL: https://issues.apache.org/jira/browse/KAFKA-10166
Project: Kafka
Sophie Blee-Goldman created KAFKA-10165:
---
Summary: Percentiles metric leaking memory
Key: KAFKA-10165
URL: https://issues.apache.org/jira/browse/KAFKA-10165
Project: Kafka
Issue Type:
Sophie Blee-Goldman created KAFKA-10156:
---
Summary: Flaky Test SslSelectorTest.testCloseOldestConnection
Key: KAFKA-10156
URL: https://issues.apache.org/jira/browse/KAFKA-10156
Project: Kafka
Sophie Blee-Goldman created KAFKA-10155:
---
Summary: Flaky Test
ReassignPartitionsUnitTest.testModifyBrokerThrottles
Key: KAFKA-10155
URL: https://issues.apache.org/jira/browse/KAFKA-10155
Sophie Blee-Goldman created KAFKA-10152:
---
Summary: Attempt to write checkpoint without first committing
during recycle
Key: KAFKA-10152
URL: https://issues.apache.org/jira/browse/KAFKA-10152
Sophie Blee-Goldman created KAFKA-10151:
---
Summary: Flaky Test
Sophie Blee-Goldman created KAFKA-10150:
---
Summary: IllegalStateException when revoking task in CREATED state
Key: KAFKA-10150
URL: https://issues.apache.org/jira/browse/KAFKA-10150
Project:
Sophie Blee-Goldman created KAFKA-10144:
---
Summary: Corrupted standby tasks are not always cleaned up
Key: KAFKA-10144
URL: https://issues.apache.org/jira/browse/KAFKA-10144
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-10119.
-
Resolution: Duplicate
Closing this as a duplicate, the issue is tracked by
[
https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9923.
Resolution: Not A Problem
[~cadonna] pointed out that this actually ins't a
Sophie Blee-Goldman created KAFKA-10102:
---
Summary: Source node references not updated after rebuilding
topology
Key: KAFKA-10102
URL: https://issues.apache.org/jira/browse/KAFKA-10102
Project:
Sophie Blee-Goldman created KAFKA-10085:
---
Summary: Compute lag correctly for optimized source changelogs
Key: KAFKA-10085
URL: https://issues.apache.org/jira/browse/KAFKA-10085
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9987.
Fix Version/s: 2.5.1
2.4.2
2.6.0
Sophie Blee-Goldman created KAFKA-10079:
---
Summary: Support high availability for in-memory stores
Key: KAFKA-10079
URL: https://issues.apache.org/jira/browse/KAFKA-10079
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9821.
Resolution: Fixed
> Stream task may skip assignment with static members and
Sophie Blee-Goldman created KAFKA-10078:
---
Summary: Partition may skip assignment with static members and
incremental rebalances
Key: KAFKA-10078
URL: https://issues.apache.org/jira/browse/KAFKA-10078
[
https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-6145.
Fix Version/s: 2.6.0
Resolution: Fixed
> Warm up new KS instances before
Sophie Blee-Goldman created KAFKA-10054:
---
Summary: Add TRACE-level end-to-end latency metrics to Streams
Key: KAFKA-10054
URL: https://issues.apache.org/jira/browse/KAFKA-10054
Project: Kafka
Sophie Blee-Goldman created KAFKA-10052:
---
Summary: Flaky Test
InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers
Key: KAFKA-10052
URL:
Sophie Blee-Goldman created KAFKA-10025:
---
Summary: Segfault in RocksDB Statistics
Key: KAFKA-10025
URL: https://issues.apache.org/jira/browse/KAFKA-10025
Project: Kafka
Issue Type: Bug
Sophie Blee-Goldman created KAFKA-10017:
---
Summary: Flaky Test
EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
Key: KAFKA-10017
URL: https://issues.apache.org/jira/browse/KAFKA-10017
Sophie Blee-Goldman created KAFKA-10006:
---
Summary: Streams should not attempt to create internal topics that
may exist
Key: KAFKA-10006
URL: https://issues.apache.org/jira/browse/KAFKA-10006
[
https://issues.apache.org/jira/browse/KAFKA-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9521.
Resolution: Duplicate
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-8174.
Resolution: Won't Do
> Can't call arbitrary SimpleBenchmarks tests from
>
[
https://issues.apache.org/jira/browse/KAFKA-9001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9001.
Resolution: Cannot Reproduce
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-9132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9132.
Fix Version/s: 2.6.0
Resolution: Fixed
> Refactor StreamThread to take
Sophie Blee-Goldman created KAFKA-9991:
--
Summary: Flaky Test
KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosAlphaEnabled
Key: KAFKA-9991
URL:
Sophie Blee-Goldman created KAFKA-9987:
--
Summary: Add new cooperative assignor optimized for
constant-subscription. group
Key: KAFKA-9987
URL: https://issues.apache.org/jira/browse/KAFKA-9987
Sophie Blee-Goldman created KAFKA-9983:
--
Summary: Add end-to-end latency metrics to Streams
Key: KAFKA-9983
URL: https://issues.apache.org/jira/browse/KAFKA-9983
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9112.
Fix Version/s: 2.6.0
Assignee: Guozhang Wang
Resolution: Fixed
[
https://issues.apache.org/jira/browse/KAFKA-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-6063.
Resolution: Not A Problem
> StreamsException is thrown after the changing
[
https://issues.apache.org/jira/browse/KAFKA-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-8858.
Assignee: Guozhang Wang
Resolution: Duplicate
> Kafka Streams - Failed to
[
https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-8207.
Resolution: Not A Problem
Closing this as "Not a Problem" as the partition
[
https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-4969.
Fix Version/s: (was: 1.1.0)
2.6.0
Resolution: Fixed
Sophie Blee-Goldman created KAFKA-9923:
--
Summary: Join window store duplicates can be compacted in
changelog
Key: KAFKA-9923
URL: https://issues.apache.org/jira/browse/KAFKA-9923
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-9176:
Saw this fail again on a PR with
h3. Stacktrace
[
https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-9798:
Assignee: (was: Guozhang Wang)
> Flaky test:
>
Sophie Blee-Goldman created KAFKA-9898:
--
Summary: Flaky Test
StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores
Key: KAFKA-9898
URL: https://issues.apache.org/jira/browse/KAFKA-9898
Sophie Blee-Goldman created KAFKA-9875:
--
Summary: Flaky Test
SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once]
Key: KAFKA-9875
URL:
[
https://issues.apache.org/jira/browse/KAFKA-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-7484.
Resolution: Fixed
> Fix test
>
[
https://issues.apache.org/jira/browse/KAFKA-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-7484:
failed on a PR with
h3. Stacktrace
java.lang.RuntimeException:
Sophie Blee-Goldman created KAFKA-9868:
--
Summary: Flaky Test
EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore
Key: KAFKA-9868
URL:
Sophie Blee-Goldman created KAFKA-9846:
--
Summary: Race condition can lead to severe lag underestimate for
active tasks
Key: KAFKA-9846
URL: https://issues.apache.org/jira/browse/KAFKA-9846
Sophie Blee-Goldman created KAFKA-9819:
--
Summary: Flaky Test
StoreChangelogReaderTest#shouldNotThrowOnUnknownRevokedPartition[0]
Key: KAFKA-9819
URL: https://issues.apache.org/jira/browse/KAFKA-9819
Sophie Blee-Goldman created KAFKA-9818:
--
Summary: Flaky Test
RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler
Key: KAFKA-9818
URL:
Sophie Blee-Goldman created KAFKA-9792:
--
Summary: Improve sticky task assignment for previous active tasks
Key: KAFKA-9792
URL: https://issues.apache.org/jira/browse/KAFKA-9792
Project: Kafka
Sophie Blee-Goldman created KAFKA-9664:
--
Summary: Flaky Test KafkaStreamsTest#testStateThreadClose
Key: KAFKA-9664
URL: https://issues.apache.org/jira/browse/KAFKA-9664
Project: Kafka
Sophie Blee-Goldman created KAFKA-9585:
--
Summary: Flaky Test:
LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization
Key: KAFKA-9585
URL: https://issues.apache.org/jira/browse/KAFKA-9585
[
https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9540.
Fix Version/s: 2.6.0
Resolution: Fixed
> Application getting "Could not
Sophie Blee-Goldman created KAFKA-9559:
--
Summary: Change the default "default serde" from ByteArraySerde to
null
Key: KAFKA-9559
URL: https://issues.apache.org/jira/browse/KAFKA-9559
Project:
Sophie Blee-Goldman created KAFKA-9525:
--
Summary: Allow explicit rebalance triggering on the Consumer
Key: KAFKA-9525
URL: https://issues.apache.org/jira/browse/KAFKA-9525
Project: Kafka
Sophie Blee-Goldman created KAFKA-9521:
--
Summary: Flaky Test
DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup
Key: KAFKA-9521
URL: https://issues.apache.org/jira/browse/KAFKA-9521
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-5868.
Fix Version/s: 2.5.0
Resolution: Fixed
> Kafka Consumer Rebalancing takes
Sophie Blee-Goldman created KAFKA-9467:
--
Summary: Multiple wallclock punctuators may be scheduled after a
rebalance
Key: KAFKA-9467
URL: https://issues.apache.org/jira/browse/KAFKA-9467
Project:
Sophie Blee-Goldman created KAFKA-9450:
--
Summary: Decouple inner state flushing from committing with EOS
Key: KAFKA-9450
URL: https://issues.apache.org/jira/browse/KAFKA-9450
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9356.
Resolution: Not A Problem
> Potential data loss in InMemoryWindowStore and
[
https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-3596.
Resolution: Not A Problem
> Kafka Streams: Window expiration needs to consider
Sophie Blee-Goldman created KAFKA-9368:
--
Summary: Preserve stream-time across rebalances/restarts
Key: KAFKA-9368
URL: https://issues.apache.org/jira/browse/KAFKA-9368
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-7994:
Assignee: (was: Richard Yu)
I'm not sure we should close this yet, it seems
Sophie Blee-Goldman created KAFKA-9349:
--
Summary: Investigate new member timeout for dynamic v4 JoinGroup
Key: KAFKA-9349
URL: https://issues.apache.org/jira/browse/KAFKA-9349
Project: Kafka
Sophie Blee-Goldman created KAFKA-9323:
--
Summary: Refactor Streams' upgrade system tests
Key: KAFKA-9323
URL: https://issues.apache.org/jira/browse/KAFKA-9323
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9281.
Resolution: Duplicate
> Consider more flexible node grouping for Pattern
Sophie Blee-Goldman created KAFKA-9282:
--
Summary: Consider more flexible node grouping for Pattern
subscription
Key: KAFKA-9282
URL: https://issues.apache.org/jira/browse/KAFKA-9282
Project:
Sophie Blee-Goldman created KAFKA-9281:
--
Summary: Consider more flexible node grouping for Pattern
subscription
Key: KAFKA-9281
URL: https://issues.apache.org/jira/browse/KAFKA-9281
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-9208:
Note that this test is distinct from the similar flaky test
Sophie Blee-Goldman created KAFKA-9208:
--
Summary: Flaky Test
SslAdminClientIntegrationTest.testCreatePartitions
Key: KAFKA-9208
URL: https://issues.apache.org/jira/browse/KAFKA-9208
Project:
Sophie Blee-Goldman created KAFKA-9177:
--
Summary: Pause completed partitions on restore consumer
Key: KAFKA-9177
URL: https://issues.apache.org/jira/browse/KAFKA-9177
Project: Kafka
Sophie Blee-Goldman created KAFKA-9161:
--
Summary: Close gaps in Streams configs documentation
Key: KAFKA-9161
URL: https://issues.apache.org/jira/browse/KAFKA-9161
Project: Kafka
Issue
Sophie Blee-Goldman created KAFKA-9148:
--
Summary: Consider forking RocksDB for Streams
Key: KAFKA-9148
URL: https://issues.apache.org/jira/browse/KAFKA-9148
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-8367.
Resolution: Fixed
> Non-heap memory leak in Kafka Streams
>
Sophie Blee-Goldman created KAFKA-9140:
--
Summary: Consumer gets stuck rejoining the group indefinitely
Key: KAFKA-9140
URL: https://issues.apache.org/jira/browse/KAFKA-9140
Project: Kafka
Sophie Blee-Goldman created KAFKA-9134:
--
Summary: Refactor the StreamsPartitionAssignor for more code
sharing with the FutureStreamsPartitionAssignor
Key: KAFKA-9134
URL:
Sophie Blee-Goldman created KAFKA-9132:
--
Summary: Refactor StreamThread to take advantage of new
ConsumerRebalanceListener exception handling
Key: KAFKA-9132
URL:
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-8972.
Resolution: Fixed
Nice work guys!
> KafkaConsumer.unsubscribe could leave
201 - 300 of 358 matches
Mail list logo
