huxihx opened a new pull request #9203:
URL: https://github.com/apache/kafka/pull/9203
*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 te
showuon commented on pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#issuecomment-677036776
@abbccdda @vahidhashemian @hachikuji , could you help review this PR? Thanks.
This is an automated message from th
showuon opened a new pull request #9202:
URL: https://github.com/apache/kafka/pull/9202
Fix the `currentStateTimeStamp` doesn't get set in
`GROUP_METADATA_VALUE_SCHEMA_V3`, and did a small refactor to use the
`GROUP_VALUE_SCHEMAS.size - 1` replace the default hard-coded max version
number
LMnet commented on pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#issuecomment-676950368
There were some failed style checks. I fixed them.
This is an automated message from the Apache Git Service.
To resp
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180919#comment-17180919
]
Jerry Wei commented on KAFKA-10134:
---
[~guozhang] sure, I'll porting PR #9038 on 2.6.0
abbccdda commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r473515635
##
File path: core/src/main/scala/kafka/server/AlterIsrManager.scala
##
@@ -0,0 +1,149 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under o
[
https://issues.apache.org/jira/browse/KAFKA-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huxihx resolved KAFKA-10407.
Fix Version/s: 2.7.0
Resolution: Fixed
> add linger.ms parameter support to KafkaLog4jAppender
> --
[
https://issues.apache.org/jira/browse/KAFKA-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180901#comment-17180901
]
huxihx commented on KAFKA-10407:
Merged this to trunk and 2.7 branch.
> add linger.ms p
huxihx merged pull request #9189:
URL: https://github.com/apache/kafka/pull/9189
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
huxihx commented on pull request #9189:
URL: https://github.com/apache/kafka/pull/9189#issuecomment-676840253
@omkreddy Thanks for the review, merging to trunk. @dongjinleekr Thanks for
the comments again.
This is an automat
[
https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180897#comment-17180897
]
Rohan Desai commented on KAFKA-10396:
-
> I mean to say if my topic going to have 10
[
https://issues.apache.org/jira/browse/KAFKA-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180889#comment-17180889
]
Matthias J. Sax commented on KAFKA-10380:
-
Thanks for clarifying. I am sure that
[
https://issues.apache.org/jira/browse/KAFKA-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180886#comment-17180886
]
Adrian Cole commented on KAFKA-10380:
-
I'm referring to the binary dist (produced by
[
https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-8812:
--
Assignee: (was: Matthias J. Sax)
> Rebalance Producers
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10395:
Comment: was deleted
(was: [~ableegoldman] [~vvcephei] Seems the PR was merged. Can we clo
[
https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180882#comment-17180882
]
Matthias J. Sax commented on KAFKA-10408:
-
Another example implementation is thi
[
https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10408:
Labels: needs-kip (was: )
> Calendar based windows
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10396:
---
Assignee: Rohan Desai
> Overall memory of container keep on growing due to kafka st
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180881#comment-17180881
]
Matthias J. Sax commented on KAFKA-10395:
-
[~ableegoldman] [~vvcephei] Seems the
[
https://issues.apache.org/jira/browse/KAFKA-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180878#comment-17180878
]
Matthias J. Sax commented on KAFKA-10380:
-
[~adriancole] – when you say "Kafka i
[
https://issues.apache.org/jira/browse/KAFKA-10410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180811#comment-17180811
]
Guozhang Wang commented on KAFKA-10410:
---
Hello [~markshelton], thanks for reportin
abbccdda commented on pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#issuecomment-676632413
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, p
abbccdda commented on pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#issuecomment-676628747
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
cmccabe commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r473276446
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4071,6 +4081,168 @@ void handleFailure(Throwable throwable)
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180775#comment-17180775
]
Guozhang Wang commented on KAFKA-10134:
---
I think I'd need more information to furt
cmccabe commented on pull request #9194:
URL: https://github.com/apache/kafka/pull/9194#issuecomment-676596370
I tested that this works to allow console consumer to run without a jackson
dependency.
This is an automated mess
ijuma commented on pull request #9197:
URL: https://github.com/apache/kafka/pull/9197#issuecomment-676594223
Sounds great, thanks!
This is an automated message from the Apache Git Service.
To respond to the message, please lo
cmccabe merged pull request #9197:
URL: https://github.com/apache/kafka/pull/9197
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 th
cmccabe commented on pull request #9197:
URL: https://github.com/apache/kafka/pull/9197#issuecomment-676589352
The failed test is flaky. Committing now. Thanks for the review
This is an automated message from the Apache Git
cmccabe commented on pull request #9197:
URL: https://github.com/apache/kafka/pull/9197#issuecomment-676589017
I verified that this removed the dependency by doing this:
```
./gradlew install -x check -x test
find | grep jackson | grep jar$ | xargs -l rm
```
And then testing t
gardnervickers opened a new pull request #9201:
URL: https://github.com/apache/kafka/pull/9201
Increase the amount of time available to the `test_verifiable_producer` test
to login and get the process name for the verifiable producer from 5 seconds to
10 seconds.
We were seeing some
[
https://issues.apache.org/jira/browse/KAFKA-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10419:
--
Component/s: (was: KafkaConnect)
core
> KAFKA BROKER Shuts down when a to
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r473158779
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasRequest.java
##
@@ -76,6 +77,16 @@ public AlterClientQuotasRequest b
vvcephei commented on a change in pull request #9137:
URL: https://github.com/apache/kafka/pull/9137#discussion_r473071200
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java
##
@@ -58,7 +62,7 @@ public synchronized boolean hasNext
cmccabe commented on pull request #9197:
URL: https://github.com/apache/kafka/pull/9197#issuecomment-676507773
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
cmccabe commented on pull request #9197:
URL: https://github.com/apache/kafka/pull/9197#issuecomment-676507610
Another Jenkins problem.
```
08:36:34 > git fetch --tags --progress -- git://github.com/apache/kafka.git
+refs/heads/*:refs/remotes/origin/* +refs/pull/*:refs/remotes/origin
[
https://issues.apache.org/jira/browse/KAFKA-10414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-10414:
-
Description:
There is a dependency on org.apache.directory.api:api-util:1.0.0, which is
involve
rondagostino commented on pull request #9199:
URL: https://github.com/apache/kafka/pull/9199#issuecomment-676492765
JDK 11 build failure was a n infrastructure issue. JDK 8 test failure is an
unrelated flaky test
(`org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEo
rondagostino commented on pull request #9199:
URL: https://github.com/apache/kafka/pull/9199#issuecomment-676491706
Note that KIP-377 landed in 2.2 and explicitly stated in the new code that
altering topic configurations via `kafka-topics` was deprecated – even using
the `--zookeeper` flag
lbradstreet commented on a change in pull request #9200:
URL: https://github.com/apache/kafka/pull/9200#discussion_r473110543
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -185,10 +192,10 @@ public void cl
vvcephei commented on pull request #9148:
URL: https://github.com/apache/kafka/pull/9148#issuecomment-676482308
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-8940:
Fix Version/s: (was: 2.5.0)
2.6.1
2.5.2
lbradstreet commented on a change in pull request #9200:
URL: https://github.com/apache/kafka/pull/9200#discussion_r473075940
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -185,10 +192,10 @@ public void cl
vvcephei commented on a change in pull request #9137:
URL: https://github.com/apache/kafka/pull/9137#discussion_r473068515
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBPrefixIterator.java
##
@@ -1,54 +0,0 @@
-/*
- * Licensed to the Apache
ijuma commented on pull request #9197:
URL: https://github.com/apache/kafka/pull/9197#issuecomment-676427721
@cmccabe There's a checkstyle error, it seems.
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180572#comment-17180572
]
Ranadeep Deb commented on KAFKA-10421:
--
I don't change the delivery.timeout.ms valu
rhauch commented on pull request #9176:
URL: https://github.com/apache/kafka/pull/9176#issuecomment-676385111
Yes, please create an issue as described above.
This is an automated message from the Apache Git Service.
To respo
[
https://issues.apache.org/jira/browse/KAFKA-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180562#comment-17180562
]
Ismael Juma commented on KAFKA-10421:
-
What is the delivery.timeout.ms config?
> Ka
[
https://issues.apache.org/jira/browse/KAFKA-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180563#comment-17180563
]
Ismael Juma commented on KAFKA-10421:
-
Also, would you be able to upgrade to 2.5.1 a
[
https://issues.apache.org/jira/browse/KAFKA-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ranadeep Deb updated KAFKA-10421:
-
Summary: Kafka Producer deadlocked on get() call (was: Kafka Producer
deadlocked on get call)
[
https://issues.apache.org/jira/browse/KAFKA-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ranadeep Deb updated KAFKA-10421:
-
Description:
I have been experiencing a similar issue in 2.3.0
I have a multi threaded applicat
rajinisivaram merged pull request #9142:
URL: https://github.com/apache/kafka/pull/9142
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
rajinisivaram commented on pull request #9142:
URL: https://github.com/apache/kafka/pull/9142#issuecomment-676279828
@skaundinya15 Thanks for the PR, merging to trunk
This is an automated message from the Apache Git Service.
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r472947852
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the
carlos-verdes commented on pull request #9176:
URL: https://github.com/apache/kafka/pull/9176#issuecomment-676156385
I will be happy to do but I may need help about the KIP.
Do you need me to open a Jira ticket to move forward?
---
[
https://issues.apache.org/jira/browse/KAFKA-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ranadeep Deb updated KAFKA-10421:
-
Description:
I have been experiencing a similar issue in 2.3.0
I have a multi threaded applicat
Ranadeep Deb created KAFKA-10421:
Summary: Kafka Producer deadlocked on get call
Key: KAFKA-10421
URL: https://issues.apache.org/jira/browse/KAFKA-10421
Project: Kafka
Issue Type: Bug
rajinisivaram commented on a change in pull request #9200:
URL: https://github.com/apache/kafka/pull/9200#discussion_r472885774
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -185,10 +192,10 @@ public void
cadonna commented on pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#issuecomment-676001391
I removed `synchronized` during adding and removing store level sensors and
metrics. Let me know what you think. If you do not like it, we can revert the
last commit.
-
Tomasz Kaszuba created KAFKA-10420:
--
Summary: group instance id Optional.empty failed due to
UNKNOWN_MEMBER_ID, resetting generation when running kafka client 2.6 against
broker 2.3.1
Key: KAFKA-10420
URL: https
[
https://issues.apache.org/jira/browse/KAFKA-10363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180346#comment-17180346
]
Alexey Kornev commented on KAFKA-10363:
---
[~RensGroothuijsen] Unfortunately, this i
cadonna edited a comment on pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#issuecomment-675909416
If we assume, that the same thread adds and removes the state store level
metrics (which is currently the case), we just need thread-safe maps
`storeLevelSensors` and `stor
cadonna commented on pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#issuecomment-675909416
If we assume, that the same thread adds and removes the state store level
metrics (which is currently the case), we just need thread-safe maps
`storeLevelSensors` and `storeLevelM
mjsax commented on pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#issuecomment-675900333
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
64 matches
Mail list logo
