[
https://issues.apache.org/jira/browse/KAFKA-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14419.
Assignee: A. Sophie Blee-Goldman
Resolution: Duplicate
> Failed Sync
[
https://issues.apache.org/jira/browse/KAFKA-18326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-18326.
Fix Version/s: 4.0.0
3.9.1
3.8.2
[
https://issues.apache.org/jira/browse/KAFKA-18026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-18026.
Resolution: Fixed
> Allow custom processor wrapping
>
[
https://issues.apache.org/jira/browse/KAFKA-13713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13713.
Resolution: Won't Fix
> Tech Debt: keep StreamThread and TopologyMetadata'
[
https://issues.apache.org/jira/browse/KAFKA-13282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13282.
Resolution: Won't Fix
> Draft final NamedTopology API and publish a KIP
>
[
https://issues.apache.org/jira/browse/KAFKA-13645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13645.
Resolution: Won't Fix
> Support the TopologyTestDriver with modular topolo
[
https://issues.apache.org/jira/browse/KAFKA-13644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13644.
Resolution: Won't Fix
> Support global state stores with modular topologie
[
https://issues.apache.org/jira/browse/KAFKA-13283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13283.
Resolution: Won't Fix
> Migrate experimental feature to public API
> -
[
https://issues.apache.org/jira/browse/KAFKA-13643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13643.
Resolution: Won't Fix
> Replace "NamedTopology" with "ModularTopology" in
[
https://issues.apache.org/jira/browse/KAFKA-13712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13712.
Resolution: Won't Fix
> Make topology addition/removal atomic so we can ro
[
https://issues.apache.org/jira/browse/KAFKA-12648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-12648.
Resolution: Won't Fix
Deprecated named topologies in 4.0 with the intentio
[
https://issues.apache.org/jira/browse/KAFKA-13711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13711.
Resolution: Won't Fix
> Fix bugs with input topic management to support pa
A. Sophie Blee-Goldman created KAFKA-18196:
--
Summary: Reuse window store for stream-stream self-join
Key: KAFKA-18196
URL: https://issues.apache.org/jira/browse/KAFKA-18196
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-18195:
--
Summary: Enter "incompatible" instead of leaving incompatible
entires blank in Kafka Streams broker compatibility matrix
Key: KAFKA-18195
URL: https://issues.
[
https://issues.apache.org/jira/browse/KAFKA-18067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-18067.
Resolution: Fixed
> Kafka Streams can leak Producer client under EOS
> ---
A. Sophie Blee-Goldman created KAFKA-18191:
--
Summary: StreamJoined name is not used for processor names
Key: KAFKA-18191
URL: https://issues.apache.org/jira/browse/KAFKA-18191
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-18190:
--
Summary: TopologyTestDriver time is not synchronized with test
topics
Key: KAFKA-18190
URL: https://issues.apache.org/jira/browse/KAFKA-18190
Proj
A. Sophie Blee-Goldman created KAFKA-18067:
--
Summary: Kafka Streams can leak Producer client under EOS
Key: KAFKA-18067
URL: https://issues.apache.org/jira/browse/KAFKA-18067
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-18066:
--
Summary: Misleading/mismatched StreamThread id in logging
Key: KAFKA-18066
URL: https://issues.apache.org/jira/browse/KAFKA-18066
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-18054:
--
Summary: Automatically detect missed configs needed by a topology
Key: KAFKA-18054
URL: https://issues.apache.org/jira/browse/KAFKA-18054
Project:
A. Sophie Blee-Goldman created KAFKA-18055:
--
Summary: Remove TopologyConfig and clean up
Topology/StreamsBuilder config APIs
Key: KAFKA-18055
URL: https://issues.apache.org/jira/browse/KAFKA-18055
A. Sophie Blee-Goldman created KAFKA-18053:
--
Summary: Clean up TopologyConfig and API for supplying configs
needed by the topology
Key: KAFKA-18053
URL: https://issues.apache.org/jira/browse/KAFKA-18053
[
https://issues.apache.org/jira/browse/KAFKA-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-18044.
Resolution: Not A Problem
> Test ticket for INFRA
> -
[
https://issues.apache.org/jira/browse/KAFKA-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-10409:
> Refactor Kafka Streams RocksDb iterators
>
[
https://issues.apache.org/jira/browse/KAFKA-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-10409.
Resolution: Incomplete
> Refactor Kafka Streams RocksDb iterators
> -
A. Sophie Blee-Goldman created KAFKA-18026:
--
Summary: Allow custom processor wrapping
Key: KAFKA-18026
URL: https://issues.apache.org/jira/browse/KAFKA-18026
Project: Kafka
Issue Typ
A. Sophie Blee-Goldman created KAFKA-17805:
--
Summary: Deprecate named topologies
Key: KAFKA-17805
URL: https://issues.apache.org/jira/browse/KAFKA-17805
Project: Kafka
Issue Type: Ta
A. Sophie Blee-Goldman created KAFKA-17441:
--
Summary: Add RETRY option to other exception handlers
Key: KAFKA-17441
URL: https://issues.apache.org/jira/browse/KAFKA-17441
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-16875:
--
Summary: Replace ClientState with TaskAssignment when creating
individual consumer Assignments
Key: KAFKA-16875
URL: https://issues.apache.org/jira/browse/KAFK
A. Sophie Blee-Goldman created KAFKA-16874:
--
Summary: Remove old TaskAssignor interface
Key: KAFKA-16874
URL: https://issues.apache.org/jira/browse/KAFKA-16874
Project: Kafka
Issue T
A. Sophie Blee-Goldman created KAFKA-16873:
--
Summary: Remove StreamsConfig.INTERNAL_TASK_ASSIGNOR_CLASS
Key: KAFKA-16873
URL: https://issues.apache.org/jira/browse/KAFKA-16873
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-16872:
--
Summary: Remove ClientState class
Key: KAFKA-16872
URL: https://issues.apache.org/jira/browse/KAFKA-16872
Project: Kafka
Issue Type: Sub-
A. Sophie Blee-Goldman created KAFKA-16871:
--
Summary: Clean up internal AssignmentConfigs class in Streams
Key: KAFKA-16871
URL: https://issues.apache.org/jira/browse/KAFKA-16871
Project: Kafk
A. Sophie Blee-Goldman created KAFKA-16869:
--
Summary: Rewrite HighAvailabilityTaskAssignor to implement the new
TaskAssignor interface
Key: KAFKA-16869
URL: https://issues.apache.org/jira/browse/KAFKA-168
A. Sophie Blee-Goldman created KAFKA-16868:
--
Summary: Post KIP-924 StreamsPartitionAssignor code cleanup
Key: KAFKA-16868
URL: https://issues.apache.org/jira/browse/KAFKA-16868
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-16867:
--
Summary: Streams should run tag-based standby assignment based on
rack ids
Key: KAFKA-16867
URL: https://issues.apache.org/jira/browse/KAFKA-16867
[
https://issues.apache.org/jira/browse/KAFKA-15170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-15170.
Resolution: Fixed
> CooperativeStickyAssignor cannot adjust assignment cor
A. Sophie Blee-Goldman created KAFKA-16758:
--
Summary: Extend Consumer#close with option to leave the group or
not
Key: KAFKA-16758
URL: https://issues.apache.org/jira/browse/KAFKA-16758
Proje
[
https://issues.apache.org/jira/browse/KAFKA-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-16277.
Resolution: Fixed
> CooperativeStickyAssignor does not spread topics evenl
A. Sophie Blee-Goldman created KAFKA-15782:
--
Summary: Establish concrete project conventions to define public
APIs that require a KIP
Key: KAFKA-15782
URL: https://issues.apache.org/jira/browse/KAFKA-1578
A. Sophie Blee-Goldman created KAFKA-15781:
--
Summary: Change ProducerConfig(props, doLog) constructor to
protected
Key: KAFKA-15781
URL: https://issues.apache.org/jira/browse/KAFKA-15781
Proj
[
https://issues.apache.org/jira/browse/KAFKA-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-15116.
Resolution: Not A Problem
> Kafka Streams processing blocked during rebala
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-12550.
Resolution: Won't Fix
Closing this out since it's usefulness is preempted
[
https://issues.apache.org/jira/browse/KAFKA-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-15463.
Resolution: Not A Problem
> StreamsException: Accessing from an unknown n
[
https://issues.apache.org/jira/browse/KAFKA-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-15571.
Resolution: Fixed
> StateRestoreListener#onRestoreSuspended is never calle
A. Sophie Blee-Goldman created KAFKA-15215:
--
Summary: The default.dsl.store config is not compatible with
custom state stores
Key: KAFKA-15215
URL: https://issues.apache.org/jira/browse/KAFKA-15215
A. Sophie Blee-Goldman created KAFKA-15045:
--
Summary: Move Streams task assignor to public configs
Key: KAFKA-15045
URL: https://issues.apache.org/jira/browse/KAFKA-15045
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-14976:
--
Summary: Left/outer stream-stream joins create KV stores that
aren't customizable
Key: KAFKA-14976
URL: https://issues.apache.org/jira/browse/KAFKA-14976
A. Sophie Blee-Goldman created KAFKA-14650:
--
Summary: IQv2 can throw ConcurrentModificationException when
accessing Tasks
Key: KAFKA-14650
URL: https://issues.apache.org/jira/browse/KAFKA-14650
[
https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13602.
Resolution: Fixed
> Allow to broadcast a result record
> -
A. Sophie Blee-Goldman created KAFKA-14539:
--
Summary: Simplify StreamsMetadataState by replacing the Cluster
metadata with partition info map
Key: KAFKA-14539
URL: https://issues.apache.org/jira/browse/KA
[
https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-13602:
Reverting in 3.4 due to logging-related perf/security issue, and some open
se
[
https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13736.
Resolution: Fixed
> Flaky kafka.network.SocketServerTest.closingChannelWit
[
https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-4852.
---
Resolution: Fixed
> ByteBufferSerializer not compatible with offsets
> --
[
https://issues.apache.org/jira/browse/KAFKA-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14291.
Resolution: Duplicate
Marking this as a duplicate of KAFKA-13990 as descri
A. Sophie Blee-Goldman created KAFKA-14460:
--
Summary: In-memory store iterators can return results with null
values
Key: KAFKA-14460
URL: https://issues.apache.org/jira/browse/KAFKA-14460
Pro
A. Sophie Blee-Goldman created KAFKA-14459:
--
Summary: Document how to use and close a 'Statistics' in the
example RocksDBConfigSetter
Key: KAFKA-14459
URL: https://issues.apache.org/jira/browse/KAFKA-1445
[
https://issues.apache.org/jira/browse/KAFKA-14454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14454.
Resolution: Fixed
> KTableKTableForeignKeyInnerJoinCustomPartitionerIntegr
[
https://issues.apache.org/jira/browse/KAFKA-14432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14432.
Resolution: Fixed
> RocksDBStore relies on finalizers to not leak memory
>
[
https://issues.apache.org/jira/browse/KAFKA-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14260.
Resolution: Fixed
> InMemoryKeyValueStore iterator still throws Concurrent
[
https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13602.
Resolution: Fixed
> Allow to broadcast a result record
> -
[
https://issues.apache.org/jira/browse/KAFKA-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14415.
Resolution: Fixed
> ThreadCache is getting slower with every additional st
A. Sophie Blee-Goldman created KAFKA-1:
--
Summary: Simplify user experience of customizing partitioning
strategy in Streams
Key: KAFKA-1
URL: https://issues.apache.org/jira/browse/KAFKA-1
[
https://issues.apache.org/jira/browse/KAFKA-14406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14406.
Resolution: Fixed
> Double iteration of records in batches to be restored
A. Sophie Blee-Goldman created KAFKA-14406:
--
Summary: Double iteration of records in batches to be restored
Key: KAFKA-14406
URL: https://issues.apache.org/jira/browse/KAFKA-14406
Project: Kaf
A. Sophie Blee-Goldman created KAFKA-14405:
--
Summary: Log a warning when users attempt to set a config
controlled by Streams
Key: KAFKA-14405
URL: https://issues.apache.org/jira/browse/KAFKA-14405
A. Sophie Blee-Goldman created KAFKA-14404:
--
Summary: Improve dWarn that the ProducerConfig partitioner.class
cannot be used in Streams
Key: KAFKA-14404
URL: https://issues.apache.org/jira/browse/KAFKA-14
A. Sophie Blee-Goldman created KAFKA-14385:
--
Summary: Flaky Test
QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable
Key: KAFKA-14385
URL: https://issues.apache.org/jira/brows
A. Sophie Blee-Goldman created KAFKA-14384:
--
Summary: Flaky Test
SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff
Key: KAFKA-14384
URL: https://issues.apache.org/jira/browse/KAFKA-1
[
https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-12935.
Assignee: Lucas Brutschy
Fixed again via
https://github.com/apache/kafka/
A. Sophie Blee-Goldman created KAFKA-14382:
--
Summary: StreamThreads can miss rebalance events when processing
records during a rebalance
Key: KAFKA-14382
URL: https://issues.apache.org/jira/browse/KAFKA-1
[
https://issues.apache.org/jira/browse/KAFKA-13891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-13891:
Reopening – original fix was reverted, we should instead fix this assignor-sid
[
https://issues.apache.org/jira/browse/KAFKA-14211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14211.
Resolution: Fixed
Resolving this since it's apparently fixed by PR (see Br
[
https://issues.apache.org/jira/browse/KAFKA-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14123.
Resolution: Not A Problem
> Delete with null value not supported in Stream
A. Sophie Blee-Goldman created KAFKA-14318:
--
Summary: KIP-878: Autoscaling for Statically Partitioned Streams
Key: KAFKA-14318
URL: https://issues.apache.org/jira/browse/KAFKA-14318
Project: K
A. Sophie Blee-Goldman created KAFKA-14008:
--
Summary: Add docs for new metrics introduced in KIP-846
Key: KAFKA-14008
URL: https://issues.apache.org/jira/browse/KAFKA-14008
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-13957:
--
Summary: Flaky Test
StoreQueryIntegrationTest.shouldQuerySpecificActivePartitionStores
Key: KAFKA-13957
URL: https://issues.apache.org/jira/browse/KAFKA-13957
A. Sophie Blee-Goldman created KAFKA-13945:
--
Summary: Add task-level metrics to Streams for bytes/records
Produced
Key: KAFKA-13945
URL: https://issues.apache.org/jira/browse/KAFKA-13945
Proj
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13152.
Resolution: Fixed
> Replace "buffered.records.per.partition" with "input.b
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-13542:
Reopening this since it was reverted pending investigation into a benchmark
r
A. Sophie Blee-Goldman created KAFKA-13713:
--
Summary: Tech Debt: keep StreamThread and TopologyMetadata's view
of the topology in sync
Key: KAFKA-13713
URL: https://issues.apache.org/jira/browse/KAFKA-137
A. Sophie Blee-Goldman created KAFKA-13712:
--
Summary: Make topology addition/removal atomic so we can roll back
if request fails
Key: KAFKA-13712
URL: https://issues.apache.org/jira/browse/KAFKA-13712
A. Sophie Blee-Goldman created KAFKA-13711:
--
Summary: Fix bugs with input topic management to support pattern
subscription fully
Key: KAFKA-13711
URL: https://issues.apache.org/jira/browse/KAFKA-13711
A. Sophie Blee-Goldman created KAFKA-13690:
--
Summary: Flaky test
EosIntegrationTest.shouldWriteLatestOffsetsToCheckpointOnShutdown[at_least_once]
Key: KAFKA-13690
URL: https://issues.apache.org/jira/brows
A. Sophie Blee-Goldman created KAFKA-13645:
--
Summary: Support the TopologyTestDriver with modular topologies
Key: KAFKA-13645
URL: https://issues.apache.org/jira/browse/KAFKA-13645
Project: Ka
A. Sophie Blee-Goldman created KAFKA-13644:
--
Summary: Support global state stores with modular topologies
Key: KAFKA-13644
URL: https://issues.apache.org/jira/browse/KAFKA-13644
Project: Kafka
A. Sophie Blee-Goldman created KAFKA-13643:
--
Summary: Replace "NamedTopology" with "ModularTopology" in the
codebase
Key: KAFKA-13643
URL: https://issues.apache.org/jira/browse/KAFKA-13643
Pr
A. Sophie Blee-Goldman created KAFKA-13590:
--
Summary: Rename InternalTopologyBuilder's #topicGroups method to
be more descriptive
Key: KAFKA-13590
URL: https://issues.apache.org/jira/browse/KAFKA-13590
A. Sophie Blee-Goldman created KAFKA-13543:
--
Summary: Consumer may pass stale cluster metadata to the assignor
following a subscription update
Key: KAFKA-13543
URL: https://issues.apache.org/jira/browse/K
A. Sophie Blee-Goldman created KAFKA-13542:
--
Summary: Utilize the new Consumer#enforceRebalance(reason) API in
Streams
Key: KAFKA-13542
URL: https://issues.apache.org/jira/browse/KAFKA-13542
A. Sophie Blee-Goldman created KAFKA-13439:
--
Summary: Deprecate EAGER rebalancing in Kafka Streams
Key: KAFKA-13439
URL: https://issues.apache.org/jira/browse/KAFKA-13439
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-13381.
Resolution: Fixed
> Wrap all uncaught exceptions as StreamsException with
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-12994.
Resolution: Fixed
> Migrate all Tests to New API and Remove Suppression fo
A. Sophie Blee-Goldman created KAFKA-13381:
--
Summary: Wrap all uncaught exceptions as StreamsException with
TaskId field
Key: KAFKA-13381
URL: https://issues.apache.org/jira/browse/KAFKA-13381
A. Sophie Blee-Goldman created KAFKA-13336:
--
Summary: Migrate StreamsBuilder class to interface with factory
method on KafkaStreams
Key: KAFKA-13336
URL: https://issues.apache.org/jira/browse/KAFKA-13336
A. Sophie Blee-Goldman created KAFKA-1:
--
Summary: Optimize condition for triggering rebalance after wiping
out corrupted task
Key: KAFKA-1
URL: https://issues.apache.org/jira/browse/KAFKA-1
[
https://issues.apache.org/jira/browse/KAFKA-12486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-12486.
Resolution: Fixed
> Utilize HighAvailabilityTaskAssignor to avoid downtime
A. Sophie Blee-Goldman created KAFKA-13332:
--
Summary: New pattern-matched topic with more partitions than
existing matched topics can crash Kafka Streams
Key: KAFKA-13332
URL: https://issues.apache.org/ji
A. Sophie Blee-Goldman created KAFKA-13295:
--
Summary: Long restoration times for new tasks can lead to
transaction timeouts
Key: KAFKA-13295
URL: https://issues.apache.org/jira/browse/KAFKA-13295
A. Sophie Blee-Goldman created KAFKA-13283:
--
Summary: Migrate experimental feature to public API
Key: KAFKA-13283
URL: https://issues.apache.org/jira/browse/KAFKA-13283
Project: Kafka
1 - 100 of 386 matches
Mail list logo
