[
https://issues.apache.org/jira/browse/KAFKA-15285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-15285:
--
Assignee: Satish Duggana
>
[
https://issues.apache.org/jira/browse/KAFKA-15285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-15285:
--
Assignee: (was: Satish Duggana)
> intermittent UT failures in storage module.
>
[
https://issues.apache.org/jira/browse/KAFKA-15285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15285:
---
Summary: intermittent UT failures in storage module. (was:
satishd commented on PR #13990:
URL: https://github.com/apache/kafka/pull/13990#issuecomment-1659608633
@junrao I was not aware of transient failures in storage module. Filed
https://issues.apache.org/jira/browse/KAFKA-15285 to track it.
--
This is an automated message from the Apache
Satish Duggana created KAFKA-15285:
--
Summary:
https://github.com/apache/kafka/pull/13990#issuecomment-1659256150
Key: KAFKA-15285
URL: https://issues.apache.org/jira/browse/KAFKA-15285
Project:
abhijeetk88 commented on PR #14074:
URL: https://github.com/apache/kafka/pull/14074#issuecomment-1659607013
@jeqo @showuon @divijvaidya can you help take a look at this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
showuon commented on PR #14114:
URL: https://github.com/apache/kafka/pull/14114#issuecomment-1659574317
@kamalcph , there's compilation error, could you take a look?
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14114/8/pipeline
--
This is an
showuon commented on code in PR #14114:
URL: https://github.com/apache/kafka/pull/14114#discussion_r1280113062
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java:
##
@@ -102,49 +102,14 @@ public String topicWarningMessage(String topicName) {
mehbey opened a new pull request, #14135:
URL: https://github.com/apache/kafka/pull/14135
KIP-937 Implementation
On a high level this implementation introduces two new configurations
`log.message.timestamp.before.max.ms` and `log.message.timestamp.after.max.ms`
and deprecates
satishd commented on code in PR #14128:
URL: https://github.com/apache/kafka/pull/14128#discussion_r1280069565
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -1002,4 +1004,36 @@ public void close() {
}
}
+static class CandidateLogSegment
satishd commented on code in PR #14128:
URL: https://github.com/apache/kafka/pull/14128#discussion_r1280069565
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -1002,4 +1004,36 @@ public void close() {
}
}
+static class CandidateLogSegment
kamalcph commented on code in PR #14114:
URL: https://github.com/apache/kafka/pull/14114#discussion_r1280095629
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java:
##
@@ -102,49 +102,14 @@ public String topicWarningMessage(String topicName) {
showuon commented on code in PR #14114:
URL: https://github.com/apache/kafka/pull/14114#discussion_r1280072894
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java:
##
@@ -102,49 +102,14 @@ public String topicWarningMessage(String topicName) {
flashmouse commented on PR #13920:
URL: https://github.com/apache/kafka/pull/13920#issuecomment-1659472862
> > I think the root cause is performReassignments in
GeneralAssignmentBuilder is a O(partSize * consumerNum) functions, it is very
inefficient.
>
> Ack, and with your changes,
[
https://issues.apache.org/jira/browse/KAFKA-15264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jianbin.chen updated KAFKA-15264:
-
Attachment: image-2023-08-01-10-26-07-146.png
> Compared with 1.1.0zk, the peak throughput of
[
https://issues.apache.org/jira/browse/KAFKA-15264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749419#comment-17749419
]
jianbin.chen commented on KAFKA-15264:
--
[~jsancio] Thanks for your reply, I tested with
[
https://issues.apache.org/jira/browse/KAFKA-15264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jianbin.chen updated KAFKA-15264:
-
Attachment: image-2023-08-01-10-24-10-227.png
> Compared with 1.1.0zk, the peak throughput of
[
https://issues.apache.org/jira/browse/KAFKA-15275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15275:
--
Summary: Implement consumer group membership state machine (was: Consumer
group membership state
[
https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15277:
--
Description:
As mentioned above, there are presently two different, coexisting
implementations of
[
https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15277:
--
Description:
As mentioned above, there are presently two different, coexisting
implementations of
[
https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15277:
--
Description:
As mentioned above, there are presently two different, coexisting
implementations of
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749378#comment-17749378
]
Kirk True commented on KAFKA-15284:
---
Suggestions for succinct names welcomed.
> Implement
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Summary: Implement ConsumerGroupProtocolVersionResolver to determine
consumer group protocol (was:
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Description:
At client initialization, we need to determine which of the
{{ConsumerDelegate}}
Kirk True created KAFKA-15284:
-
Summary: Determine group protocol at client initialization
Key: KAFKA-15284
URL: https://issues.apache.org/jira/browse/KAFKA-15284
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15277:
--
Description:
As mentioned above, there are presently two different, coexisting
implementations of
Kirk True created KAFKA-15283:
-
Summary: Add support for topic ID-related Consumer changes
Key: KAFKA-15283
URL: https://issues.apache.org/jira/browse/KAFKA-15283
Project: Kafka
Issue Type: Task
philipnee commented on PR #14123:
URL: https://github.com/apache/kafka/pull/14123#issuecomment-1659400843
Here are the most recent failures:
```
Build / JDK 11 and Scala 2.13 / testClose() –
kafka.log.remote.RemoteIndexCacheTest
<1s
Build / JDK 11 and Scala 2.13 /
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15282:
--
Description:
The client-side assignor provides the logic for the partition assignments
instead of on
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15282:
--
Description:
The client-side assignor provides the logic for the partition assignments
instead of on
Kirk True created KAFKA-15282:
-
Summary: Implement client support for KIP-848 client-side assignors
Key: KAFKA-15282
URL: https://issues.apache.org/jira/browse/KAFKA-15282
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-15280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15280:
--
Remaining Estimate: (was: 288h)
Original Estimate: (was: 288h)
> Implement client
[
https://issues.apache.org/jira/browse/KAFKA-15280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15280:
--
Remaining Estimate: 288h (was: 420h)
Original Estimate: 288h (was: 420h)
> Implement client
[
https://issues.apache.org/jira/browse/KAFKA-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15281:
--
Remaining Estimate: 504h
Original Estimate: 504h
> Implement the groupMetadata Consumer API
>
[
https://issues.apache.org/jira/browse/KAFKA-15280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15280:
--
Remaining Estimate: 420h
Original Estimate: 420h
> Implement client support for KIP-848
[
https://issues.apache.org/jira/browse/KAFKA-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15278:
--
Labels: consumer-threading-refactor kip-848 kip-848-client-support (was:
consumer-threading-refactor
[
https://issues.apache.org/jira/browse/KAFKA-15280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15280:
--
Labels: consumer-threading-refactor kip-848 kip-848-client-support (was:
consumer-threading-refactor
[
https://issues.apache.org/jira/browse/KAFKA-15276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15276:
--
Labels: kip-848 kip-848-client-support (was: kip-848)
> Implement partition assignment
[
https://issues.apache.org/jira/browse/KAFKA-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15281:
--
Labels: consumer-threading-refactor kip-848 kip-848-client-support (was:
consumer-threading-refactor
[
https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15277:
--
Labels: consumer-threading-refactor kip-848 kip-848-client-support (was:
consumer-threading-refactor
[
https://issues.apache.org/jira/browse/KAFKA-15275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15275:
--
Labels: kip-848 kip-848-client-support (was: kip-848)
> Consumer group membership state machine
>
[
https://issues.apache.org/jira/browse/KAFKA-15279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15279:
--
Labels: consumer-threading-refactor kip-848 kip-848-client-support (was:
consumer-threading-refactor
[
https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15277:
--
Description:
As mentioned above, there are presently two different, coexisting
implementations of
[
https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15277:
-
Assignee: Philip Nee (was: Kirk True)
> Design & implement support for internal Consumer
Kirk True created KAFKA-15281:
-
Summary: Implement the groupMetadata Consumer API
Key: KAFKA-15281
URL: https://issues.apache.org/jira/browse/KAFKA-15281
Project: Kafka
Issue Type: Task
Kirk True created KAFKA-15280:
-
Summary: Implement client support for KIP-848 server-side assignors
Key: KAFKA-15280
URL: https://issues.apache.org/jira/browse/KAFKA-15280
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15278:
--
Description:
The protocol introduces three new RPCs that the client uses to communicate with
the
Kirk True created KAFKA-15279:
-
Summary: Implement client support for KIP-848 assignment RPCs
Key: KAFKA-15279
URL: https://issues.apache.org/jira/browse/KAFKA-15279
Project: Kafka
Issue Type:
Kirk True created KAFKA-15278:
-
Summary: Implement client support for KIP-848
ConsumerGroupHeartbeat protocol RPC
Key: KAFKA-15278
URL: https://issues.apache.org/jira/browse/KAFKA-15278
Project: Kafka
Kirk True created KAFKA-15277:
-
Summary: Design & implement support for internal Consumer delegates
Key: KAFKA-15277
URL: https://issues.apache.org/jira/browse/KAFKA-15277
Project: Kafka
Issue
Kirk True created KAFKA-15276:
-
Summary: Implement partition assignment reconciliation
Key: KAFKA-15276
URL: https://issues.apache.org/jira/browse/KAFKA-15276
Project: Kafka
Issue Type: Task
Kirk True created KAFKA-15275:
-
Summary: Consumer group membership state machine
Key: KAFKA-15275
URL: https://issues.apache.org/jira/browse/KAFKA-15275
Project: Kafka
Issue Type: Task
ex172000 commented on PR #14110:
URL: https://github.com/apache/kafka/pull/14110#issuecomment-1659366875
Thank you @divijvaidya for the timely review, updated!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15173:
--
Summary: Consumer event queues should be bounded (was:
ApplicationEventQueue and
[
https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14246:
--
Summary: Update threading model for Consumer (was: Update threading model
for Consumer (KIP-945))
>
[
https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15173:
-
Assignee: Kirk True (was: Philip Nee)
> ApplicationEventQueue and BackgroundEventQueue should
[
https://issues.apache.org/jira/browse/KAFKA-15270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15270:
--
Labels: consumer-threading-refactor (was: )
> Integration tests for AsyncConsumer simple consume
[
https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14196:
--
Labels: consumer-threading-refactor new-consumer-threading-should-fix
(was:
[
https://issues.apache.org/jira/browse/KAFKA-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14274:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Introduce
[
https://issues.apache.org/jira/browse/KAFKA-14761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14761:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Integration Tests
[
https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14246:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Update threading
[
https://issues.apache.org/jira/browse/KAFKA-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14960:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Metadata Request
[
https://issues.apache.org/jira/browse/KAFKA-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14247:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Implement
[
https://issues.apache.org/jira/browse/KAFKA-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14264:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Refactor
[
https://issues.apache.org/jira/browse/KAFKA-14468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14468:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Refactor Commit
[
https://issues.apache.org/jira/browse/KAFKA-15188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15188:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Implement more of
[
https://issues.apache.org/jira/browse/KAFKA-14365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14365:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Extract common
[
https://issues.apache.org/jira/browse/KAFKA-14937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14937:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Refactoring for
[
https://issues.apache.org/jira/browse/KAFKA-15180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15180:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Generalize
[
https://issues.apache.org/jira/browse/KAFKA-14758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14758:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Extract inner
[
https://issues.apache.org/jira/browse/KAFKA-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14950:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Implement assign()
[
https://issues.apache.org/jira/browse/KAFKA-14848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14848:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> KafkaConsumer
[
https://issues.apache.org/jira/browse/KAFKA-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15164:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Extract reusable
[
https://issues.apache.org/jira/browse/KAFKA-14675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14675:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Extract
[
https://issues.apache.org/jira/browse/KAFKA-14724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14724:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Port tests in
[
https://issues.apache.org/jira/browse/KAFKA-15115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15115:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Implement
[
https://issues.apache.org/jira/browse/KAFKA-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14965:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Introduce
[
https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15173:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
>
[
https://issues.apache.org/jira/browse/KAFKA-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14966:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Extract reusable
[
https://issues.apache.org/jira/browse/KAFKA-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15081:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Implement new
[
https://issues.apache.org/jira/browse/KAFKA-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14252:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Create background
[
https://issues.apache.org/jira/browse/KAFKA-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15174:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Ensure the correct
[
https://issues.apache.org/jira/browse/KAFKA-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14875:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Implement Wakeup()
[
https://issues.apache.org/jira/browse/KAFKA-15163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15163:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> Implement
[
https://issues.apache.org/jira/browse/KAFKA-15184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15184:
--
Labels: consumer-threading-refactor (was: consumer-threading-refactor
kip-945)
> New consumer
[
https://issues.apache.org/jira/browse/KAFKA-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14966:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Extract reusable logic from
[
https://issues.apache.org/jira/browse/KAFKA-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15164:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Extract reusable logic from
[
https://issues.apache.org/jira/browse/KAFKA-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14247:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Implement EventHandler interface and
[
https://issues.apache.org/jira/browse/KAFKA-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14264:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Refactor coordinator code
>
[
https://issues.apache.org/jira/browse/KAFKA-14761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14761:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Integration Tests for the New Consumer
[
https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15173:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> ApplicationEventQueue and
[
https://issues.apache.org/jira/browse/KAFKA-15115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15115:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Implement resetPositions functionality
[
https://issues.apache.org/jira/browse/KAFKA-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15081:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Implement new consumer offsetsForTimes
[
https://issues.apache.org/jira/browse/KAFKA-14468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14468:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Refactor Commit Logic
>
[
https://issues.apache.org/jira/browse/KAFKA-15188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15188:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Implement more of the remaining
[
https://issues.apache.org/jira/browse/KAFKA-14937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14937:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Refactoring for client code to reduce
[
https://issues.apache.org/jira/browse/KAFKA-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14960:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Metadata Request Manager and
[
https://issues.apache.org/jira/browse/KAFKA-14675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14675:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Extract metadata-related tasks from
[
https://issues.apache.org/jira/browse/KAFKA-15180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15180:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Generalize integration tests to change
[
https://issues.apache.org/jira/browse/KAFKA-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14950:
--
Labels: consumer-threading-refactor kip-945 (was: kip-945)
> Implement assign() and assignment()
>
1 - 100 of 190 matches
Mail list logo
