ddrid commented on pull request #11979:
URL: https://github.com/apache/kafka/pull/11979#issuecomment-1085512862
Hi, @showuon @dajac, could you please take a look at this easy one?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515781#comment-17515781
]
Nico Pommerening commented on KAFKA-13787:
--
Hi [~mjsax] :
I'm experiencing the
showuon merged pull request #11978:
URL: https://github.com/apache/kafka/pull/11978
--
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.
showuon commented on a change in pull request #11979:
URL: https://github.com/apache/kafka/pull/11979#discussion_r840353943
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
##
@@ -378,12 +378,12 @@ public int splitAndReenqu
[
https://issues.apache.org/jira/browse/KAFKA-13783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515805#comment-17515805
]
Tom Bentley commented on KAFKA-13783:
-
[~dajac] do you want to update the KIP?
> Re
ddrid commented on a change in pull request #11979:
URL: https://github.com/apache/kafka/pull/11979#discussion_r840397657
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -113,16 +113,7 @@ private TopicPartitionEntry
ddrid commented on a change in pull request #11979:
URL: https://github.com/apache/kafka/pull/11979#discussion_r840399831
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -790,7 +781,6 @@ private void adjustSequences
kamalcph commented on pull request #9340:
URL: https://github.com/apache/kafka/pull/9340#issuecomment-1085675534
gentle reminder
--
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 comm
dengziming commented on pull request #11910:
URL: https://github.com/apache/kafka/pull/11910#issuecomment-1085768659
Thank you @cmccabe for the reminders, I added a TimelineMap
here, I'm not sure should we use a TimelineMap> since the
user may already create some topics colliding with each
akatona84 opened a new pull request #11982:
URL: https://github.com/apache/kafka/pull/11982
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testi
mumrah commented on a change in pull request #11941:
URL: https://github.com/apache/kafka/pull/11941#discussion_r840670498
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -530,21 +543,38 @@ private ApiError createTopic(Crea
[
https://issues.apache.org/jira/browse/KAFKA-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516001#comment-17516001
]
Tom Bentley commented on KAFKA-13782:
-
This is currently the last remaining blocker
cmccabe merged pull request #11941:
URL: https://github.com/apache/kafka/pull/11941
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516068#comment-17516068
]
Matthias J. Sax commented on KAFKA-13787:
-
`StateDirectory` should have all rele
C0urante opened a new pull request #11983:
URL: https://github.com/apache/kafka/pull/11983
[Jira](https://issues.apache.org/jira/browse/KAFKA-13763)
Builds on the changes from https://github.com/apache/kafka/pull/11974, which
exclusively touched on the `IncrementalCooperativeAssignor
C0urante commented on pull request #11974:
URL: https://github.com/apache/kafka/pull/11974#issuecomment-1086232261
Filed https://github.com/apache/kafka/pull/11983 as a more aggressive
follow-up that touches on the `IncrementalCooperativeAssignor` class.
--
This is an automated message f
ijuma opened a new pull request #11984:
URL: https://github.com/apache/kafka/pull/11984
* gradle: 7.3.3 -> 7.4.2
TBD
https://docs.gradle.org/7.4.2/release-notes.html
* dependencycheck gradle plugin: 6.5.3 -> 7.0.3
Minor fixes.
* spotbugs gradle plugin: 5.0.5 -> 5.0.6
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-7509:
Assignee: Chris Egerton
> Kafka Connect logs unnecessary warnings about unused configurati
RivenSun2 opened a new pull request #11985:
URL: https://github.com/apache/kafka/pull/11985
Supplement the description of `Valid Values` in the documentation of
`compression.type`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
RivenSun2 commented on pull request #11985:
URL: https://github.com/apache/kafka/pull/11985#issuecomment-1086549836
Hi @showuon @dajac
please help to review the PR .
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
C0urante opened a new pull request #11986:
URL: https://github.com/apache/kafka/pull/11986
[Jira](https://issues.apache.org/jira/browse/KAFKA-7509)
**NOTE: This may require a KIP. Please do not merge until it has been
explicitly confirmed that a KIP is not required, or a KIP for thes
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516226#comment-17516226
]
Chris Egerton commented on KAFKA-7509:
--
Alright, I dug a little deeper and it looks
C0urante commented on a change in pull request #11986:
URL: https://github.com/apache/kafka/pull/11986#discussion_r841016535
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java
##
@@ -366,6 +369,29 @@ public WorkerConfig(ConfigDef def
23 matches
Mail list logo
