mjsax commented on code in PR #13925:
URL: https://github.com/apache/kafka/pull/13925#discussion_r1247273467
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1141,25 +1141,30 @@ public Map getTaskOffsetSums() {
// Not all ta
jolshan closed pull request #13918: DO NOT MERGE -- testing
URL: https://github.com/apache/kafka/pull/13918
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-m
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1247245146
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -507,9 +507,14 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = request
hachikuji commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1247229531
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -507,9 +507,14 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = reque
JimGalasyn commented on PR #13937:
URL: https://github.com/apache/kafka/pull/13937#issuecomment-1613837996
cc @guozhangwang @mjsax
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific co
JimGalasyn opened a new pull request, #13937:
URL: https://github.com/apache/kafka/pull/13937
Add a broker compatibility matrix to the Streams Developer Guide.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
szalapski commented on PR #5876:
URL: https://github.com/apache/kafka/pull/5876#issuecomment-1613828699
That sounds great. I'll try to upgrade and look into it soon. Feel free to
close.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
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 (KIP-945) (was: Update
threading model for Consumer)
>
CalvinConfluent commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1246995181
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -874,4 +1087,1362 @@ public void replay(
con
[
https://issues.apache.org/jira/browse/KAFKA-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14264:
--
Component/s: clients
> Refactor coordinator code
> -
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14875:
--
Component/s: clients
> Implement Wakeup()
> --
>
> Key: KAFKA-14875
>
[
https://issues.apache.org/jira/browse/KAFKA-14761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14761:
--
Component/s: clients
> Integration Tests for the New Consumer Implementation
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14252:
--
Component/s: clients
> Create background thread skeleton for new Consumer threading model
> --
[
https://issues.apache.org/jira/browse/KAFKA-14468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14468:
--
Component/s: clients
> Refactor Commit Logic
> -
>
> Key: KAFKA-14
[
https://issues.apache.org/jira/browse/KAFKA-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14247:
--
Component/s: clients
> Implement EventHandler interface and DefaultEventHandler for Consumer
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14960:
--
Component/s: clients
> Metadata Request Manager and listTopics/partitionsFor API
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14950:
--
Component/s: clients
> Implement assign() and assignment()
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14246:
--
Component/s: clients
> Update threading model for Consumer
> ---
>
>
CalvinConfluent commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1246964799
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -102,13 +108,34 @@ public Builder withLoader(Coordinat
[
https://issues.apache.org/jira/browse/KAFKA-14761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14761:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Integration Tests for the N
[
https://issues.apache.org/jira/browse/KAFKA-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14247:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Implement EventHandler inte
[
https://issues.apache.org/jira/browse/KAFKA-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14247:
--
Summary: Implement EventHandler interface and DefaultEventHandler for
Consumer (was: Implement EventH
[
https://issues.apache.org/jira/browse/KAFKA-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14252:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Create background thread sk
[
https://issues.apache.org/jira/browse/KAFKA-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14252:
--
Summary: Create background thread skeleton for new Consumer threading model
(was: Create background t
[
https://issues.apache.org/jira/browse/KAFKA-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14960:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Metadata Request Manager an
[
https://issues.apache.org/jira/browse/KAFKA-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14264:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Refactor coordinator code
>
[
https://issues.apache.org/jira/browse/KAFKA-14468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14468:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Refactor Commit Logic
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14966:
--
Parent: (was: KAFKA-14965)
Issue Type: Task (was: Sub-task)
> Extract reusable common log
[
https://issues.apache.org/jira/browse/KAFKA-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14950:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Implement assign() and assi
[
https://issues.apache.org/jira/browse/KAFKA-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14875:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Implement Wakeup()
> --
[
https://issues.apache.org/jira/browse/KAFKA-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14274:
--
Issue Type: Task (was: Improvement)
> Introduce FetchRequestManager to integrate fetch into new consu
[
https://issues.apache.org/jira/browse/KAFKA-14675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14675:
--
Issue Type: Task (was: Improvement)
> Extract metadata-related tasks from Fetcher into MetadataFetche
[
https://issues.apache.org/jira/browse/KAFKA-14365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14365:
--
Issue Type: Task (was: Improvement)
> Extract common logic from Fetcher
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14758:
--
Issue Type: Task (was: Improvement)
> Extract inner classes from Fetcher for reuse in refactoring
> -
[
https://issues.apache.org/jira/browse/KAFKA-14724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14724:
--
Issue Type: Task (was: Improvement)
> Port tests in FetcherTest to FetchRequestManagerTest
>
[
https://issues.apache.org/jira/browse/KAFKA-14724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14724:
--
Component/s: clients
consumer
> Port tests in FetcherTest to FetchRequestManagerTest
[
https://issues.apache.org/jira/browse/KAFKA-14848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14848:
--
Labels: kip-945 (was: )
> KafkaConsumer incorrectly passes locally-scoped deserializers to FetchConfi
[
https://issues.apache.org/jira/browse/KAFKA-13445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-13445:
--
Labels: OAuth (was: )
> Add ECDSA test for JWT validation
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-13444:
--
Labels: OAuth (was: )
> Fix OAuthCompatibilityTool help and add SSL options
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-13443:
--
Labels: OAuth beginner (was: beginner)
> Kafka broker exits when OAuth enabled and certain configurat
[
https://issues.apache.org/jira/browse/KAFKA-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14623:
--
Labels: OAuth (was: )
> OAuth's HttpAccessTokenRetriever potentially leaks secrets in logging
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-13725:
--
Labels: OAuth (was: )
> KIP-768 OAuth code mixes public and internal classes in same package
> --
[
https://issues.apache.org/jira/browse/KAFKA-13202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-13202:
--
Labels: OAuth (was: )
> KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC
>
[
https://issues.apache.org/jira/browse/KAFKA-13446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-13446:
--
Labels: OAuth (was: )
> Remove JWT access token from logs
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14724:
--
Labels: kip-945 (was: )
> Port tests in FetcherTest to FetchRequestManagerTest
>
[
https://issues.apache.org/jira/browse/KAFKA-14365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14365:
--
Labels: kip-945 (was: )
> Extract common logic from Fetcher
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14675:
--
Labels: kip-945 (was: )
> Extract metadata-related tasks from Fetcher into MetadataFetcher
>
[
https://issues.apache.org/jira/browse/KAFKA-14758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14758:
--
Labels: kip-945 (was: )
> Extract inner classes from Fetcher for reuse in refactoring
> -
[
https://issues.apache.org/jira/browse/KAFKA-14937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14937:
--
Parent: (was: KAFKA-14274)
Issue Type: Improvement (was: Sub-task)
> Refactoring for clie
[
https://issues.apache.org/jira/browse/KAFKA-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14966:
--
Labels: kip-945 (was: )
> Extract reusable common logic from OffsetFetcher
>
[
https://issues.apache.org/jira/browse/KAFKA-14937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14937:
--
Labels: kip-945 (was: )
> Refactoring for client code to reduce boilerplate
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14965:
--
Labels: kip-945 (was: )
> Introduce ListOffsetsRequestManager to integrate ListOffsetsRequests into n
[
https://issues.apache.org/jira/browse/KAFKA-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15081:
--
Labels: kip-945 (was: )
> Implement new consumer offsetsForTimes
> --
[
https://issues.apache.org/jira/browse/KAFKA-15115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15115:
--
Labels: kip-945 (was: )
> Implement resetPositions functionality in ListOffsetRequestManager
> --
[
https://issues.apache.org/jira/browse/KAFKA-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14252:
--
Labels: kip-945 (was: )
> Create background thread skeleton
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14247:
--
Labels: kip-945 (was: )
> Implement EventHandler interface and DefaultEventHandler
>
[
https://issues.apache.org/jira/browse/KAFKA-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14264:
--
Labels: kip-945 (was: )
> Refactor coordinator code
> -
>
> K
[
https://issues.apache.org/jira/browse/KAFKA-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738782#comment-17738782
]
Matthias J. Sax commented on KAFKA-15116:
-
> Message A uses an internal store to
[
https://issues.apache.org/jira/browse/KAFKA-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14274:
--
Labels: kip-945 (was: )
> Introduce FetchRequestManager to integrate fetch into new consumer threadin
[
https://issues.apache.org/jira/browse/KAFKA-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14960:
--
Labels: kip-945 (was: )
> Metadata Request Manager and listTopics/partitionsFor API
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14950:
--
Labels: kip-945 (was: )
> Implement assign() and assignment()
> ---
>
[
https://issues.apache.org/jira/browse/KAFKA-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14875:
--
Labels: kip-945 (was: )
> Implement Wakeup()
> --
>
> Key: KAFKA-1487
[
https://issues.apache.org/jira/browse/KAFKA-14468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14468:
--
Labels: kip-945 (was: )
> Refactor Commit Logic
> -
>
> Key: KAFK
[
https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14246:
--
Labels: kip-945 (was: )
> Update threading model for Consumer
> ---
>
[
https://issues.apache.org/jira/browse/KAFKA-14761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14761:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Integration Tests for the New Consumer
[
https://issues.apache.org/jira/browse/KAFKA-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14875:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Implement Wakeup()
> -
[
https://issues.apache.org/jira/browse/KAFKA-14761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14761:
--
Labels: kip-945 (was: )
> Integration Tests for the New Consumer Implementation
> ---
jolshan commented on code in PR #13901:
URL: https://github.com/apache/kafka/pull/13901#discussion_r1247163837
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -172,19 +186,21 @@ public List build(TopicsImage topicsImage)
[
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: Refactor KafkaConsumer
Threading Model)
> Update
jolshan commented on code in PR #13901:
URL: https://github.com/apache/kafka/pull/13901#discussion_r1247156849
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -728,6 +794,81 @@ public void replay(
}
jolshan commented on code in PR #13901:
URL: https://github.com/apache/kafka/pull/13901#discussion_r1247155039
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -825,4 +828,60 @@ public void testClose() throws Except
jolshan commented on code in PR #13901:
URL: https://github.com/apache/kafka/pull/13901#discussion_r1247154202
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -825,4 +828,60 @@ public void testClose() throws Except
kirktrue commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1613748954
Thanks @jolshan, @urbandan, and @hachikuji for the reviews!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738744#comment-17738744
]
Omnia Ibrahim edited comment on KAFKA-15102 at 6/29/23 7:30 PM:
--
C0urante merged PR #13934:
URL: https://github.com/apache/kafka/pull/13934
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738744#comment-17738744
]
Omnia Ibrahim edited comment on KAFKA-15102 at 6/29/23 7:01 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738744#comment-17738744
]
Omnia Ibrahim edited comment on KAFKA-15102 at 6/29/23 7:00 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738744#comment-17738744
]
Omnia Ibrahim edited comment on KAFKA-15102 at 6/29/23 7:00 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738744#comment-17738744
]
Omnia Ibrahim edited comment on KAFKA-15102 at 6/29/23 7:00 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738744#comment-17738744
]
Omnia Ibrahim edited comment on KAFKA-15102 at 6/29/23 7:00 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738744#comment-17738744
]
Omnia Ibrahim commented on KAFKA-15102:
---
Thanks, [~ddufour1a] for raising this. Th
jolshan commented on code in PR #13901:
URL: https://github.com/apache/kafka/pull/13901#discussion_r1246997020
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupTest.java:
##
@@ -537,8 +538,35 @@ public void testUpdateSubscriptionMetadat
[
https://issues.apache.org/jira/browse/KAFKA-15113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738740#comment-17738740
]
Chris Egerton commented on KAFKA-15113:
---
[~yash.mayya] although it seems a little
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738733#comment-17738733
]
Chris Egerton edited comment on KAFKA-15102 at 6/29/23 6:43 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738733#comment-17738733
]
Chris Egerton commented on KAFKA-15102:
---
[~ddufour1a] Thanks for raising this. I b
jolshan commented on PR #13876:
URL: https://github.com/apache/kafka/pull/13876#issuecomment-1613602815
@lucasbru -- I'm also thinking about consistency from the sense of
compatibility with previous state. Ideally our final state will balance
consistency in how we handle errors (so new user
jolshan merged PR #13591:
URL: https://github.com/apache/kafka/pull/13591
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
jolshan commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1613597535
Ok -- test failures seem to be consistent with current trunk and not due to
this change. Will go ahead and merge.
--
This is an automated message from the Apache Git Service.
To respon
C0urante merged PR #13933:
URL: https://github.com/apache/kafka/pull/13933
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache
cmccabe merged PR #13904:
URL: https://github.com/apache/kafka/pull/13904
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
[
https://issues.apache.org/jira/browse/KAFKA-15127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738704#comment-17738704
]
Sagar Rao commented on KAFKA-15127:
---
I don't intend working on this immediately or in
[
https://issues.apache.org/jira/browse/KAFKA-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya resolved KAFKA-15053.
--
Reviewer: Divij Vaidya
Resolution: Fixed
> Regression for security.protocol validation s
[
https://issues.apache.org/jira/browse/KAFKA-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15053:
-
Labels: backport (was: )
> Regression for security.protocol validation starting from 3.3.0
> --
[
https://issues.apache.org/jira/browse/KAFKA-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15053:
-
Fix Version/s: 3.3.3
3.5.1
3.4.2
> Regression for security
C0urante commented on PR #13530:
URL: https://github.com/apache/kafka/pull/13530#issuecomment-1613554645
Hmmm... is there an advantage to enabling users to pause/resume a failed
connector? I feel like restarting it is still the natural corrective action in
that case, which will also cause t
divijvaidya opened a new pull request, #13936:
URL: https://github.com/apache/kafka/pull/13936
**Changes**
1. Add new unit tests
2. Change the on-disk filename from `__.` to
`_.` i.e. remove trailing suffix
3. Fix a small bug where we were parsing offset as Int when reading the file
hudeqi commented on PR #13913:
URL: https://github.com/apache/kafka/pull/13913#issuecomment-1613529431
Hi! please help to review this PR when you are free, thank you! @C0urante
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
hudeqi commented on PR #13924:
URL: https://github.com/apache/kafka/pull/13924#issuecomment-1613525851
I have submitted some PRs (two others:
https://github.com/apache/kafka/pull/13926、https://github.com/apache/kafka/pull/13929)
on the topic of "clean metric", please help to review, thank y
hudeqi commented on PR #13930:
URL: https://github.com/apache/kafka/pull/13930#issuecomment-1613522211
Hi! Could you help to review this PR? @hachikuji @guozhangwang
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
C0urante commented on PR #13302:
URL: https://github.com/apache/kafka/pull/13302#issuecomment-1613519953
Verified locally by running the
`ConnectDistributedTest::test_file_source_and_sink`,
`ConnectDistributedTest::test_bounce`, and
`ConnectStandaloneFileTest::test_file_source_and_sink` te
1 - 100 of 176 matches
Mail list logo