[
https://issues.apache.org/jira/browse/KAFKA-15054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li resolved KAFKA-15054.
Fix Version/s: 3.6.0
Resolution: Fixed
> Add configs and logic to decide if rack aware assignment
[
https://issues.apache.org/jira/browse/KAFKA-15025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li resolved KAFKA-15025.
Fix Version/s: 3.6.0
Resolution: Fixed
> Implement min-cost flow without balancing tasks for same
[
https://issues.apache.org/jira/browse/KAFKA-15027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li resolved KAFKA-15027.
Fix Version/s: 3.6.0
Resolution: Fixed
> Implement rack aware assignment for standby tasks
>
[
https://issues.apache.org/jira/browse/KAFKA-15024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li resolved KAFKA-15024.
Fix Version/s: 3.6.0
Resolution: Fixed
> Add cost function for task/client
>
[
https://issues.apache.org/jira/browse/KAFKA-15023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li resolved KAFKA-15023.
Fix Version/s: 3.6.0
Resolution: Fixed
> Get rack information for source topic partitions for a
Hao Li created KAFKA-15054:
--
Summary: Add configs and logic to decide if rack aware assignment
should be enabled
Key: KAFKA-15054
URL: https://issues.apache.org/jira/browse/KAFKA-15054
Project: Kafka
Hao Li created KAFKA-15027:
--
Summary: Implement rack aware assignment for standby tasks
Key: KAFKA-15027
URL: https://issues.apache.org/jira/browse/KAFKA-15027
Project: Kafka
Issue Type: Sub-task
Hao Li created KAFKA-15025:
--
Summary: Implement min-cost flow without balancing tasks for same
subtopology
Key: KAFKA-15025
URL: https://issues.apache.org/jira/browse/KAFKA-15025
Project: Kafka
Hao Li created KAFKA-15026:
--
Summary: Implement min-cost flow balancing tasks for same
subtopology
Key: KAFKA-15026
URL: https://issues.apache.org/jira/browse/KAFKA-15026
Project: Kafka
Issue
Hao Li created KAFKA-15024:
--
Summary: Add cost function for task/client
Key: KAFKA-15024
URL: https://issues.apache.org/jira/browse/KAFKA-15024
Project: Kafka
Issue Type: Sub-task
Hao Li created KAFKA-15023:
--
Summary: Get rack information for source topic partitions for a
task
Key: KAFKA-15023
URL: https://issues.apache.org/jira/browse/KAFKA-15023
Project: Kafka
Issue Type:
Hao Li created KAFKA-15022:
--
Summary: Support rack aware task assignment in Kafka streams
Key: KAFKA-15022
URL: https://issues.apache.org/jira/browse/KAFKA-15022
Project: Kafka
Issue Type:
Hao Li created KAFKA-14981:
--
Summary: Set `group.instance.id` in streams consumer so that
rebalance will not happen if a instance is restarted
Key: KAFKA-14981
URL: https://issues.apache.org/jira/browse/KAFKA-14981
[
https://issues.apache.org/jira/browse/KAFKA-14395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li resolved KAFKA-14395.
Resolution: Done
> Add config to configure client supplier for KafkaStreams
>
[
https://issues.apache.org/jira/browse/KAFKA-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li resolved KAFKA-13785.
Resolution: Done
> Support emit final result for windowed aggregation
>
Hao Li created KAFKA-14395:
--
Summary: Add config to configure client supplier for KafkaStreams
Key: KAFKA-14395
URL: https://issues.apache.org/jira/browse/KAFKA-14395
Project: Kafka
Issue Type:
Hao Li created KAFKA-14117:
--
Summary: Flaky Test
DynamicBrokerReconfigurationTest.testKeyStoreAlter
Key: KAFKA-14117
URL: https://issues.apache.org/jira/browse/KAFKA-14117
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li reopened KAFKA-12566:
Somehow this is still happening:
```
[2022-07-27T11:32:04.461Z] MirrorConnectorsIntegrationSSLTest >
Hao Li created KAFKA-13824:
--
Summary: Pass time object from constructor so that we can mock it
if needed
Key: KAFKA-13824
URL: https://issues.apache.org/jira/browse/KAFKA-13824
Project: Kafka
Hao Li created KAFKA-13817:
--
Summary: Schedule nextTimeToEmit to system time every time instead
of just once
Key: KAFKA-13817
URL: https://issues.apache.org/jira/browse/KAFKA-13817
Project: Kafka
Hao Li created KAFKA-13800:
--
Summary: Remove force cast of TimeWindowKStreamImpl in tests of
https://github.com/apache/kafka/pull/11896
Key: KAFKA-13800
URL: https://issues.apache.org/jira/browse/KAFKA-13800
Hao Li created KAFKA-13785:
--
Summary: Support emit final result for windowed aggregation
Key: KAFKA-13785
URL: https://issues.apache.org/jira/browse/KAFKA-13785
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li resolved KAFKA-13164.
Resolution: Cannot Reproduce
Closing this as I can't reproduce the issue
> State store is attached to
23 matches
Mail list logo
