chia7712 commented on pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#issuecomment-697177819
@cadonna
```
org.apache.kafka.streams.processor.internals.StateDirectoryTest.shouldLogStateDirCleanerMessage
failed, log available in
/home/chia7712/kafka/streams/bui
[
https://issues.apache.org/jira/browse/KAFKA-10514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200617#comment-17200617
]
Chia-Ping Tsai commented on KAFKA-10514:
more details: https://github.com/apache
[
https://issues.apache.org/jira/browse/KAFKA-10514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-10514:
-
Assignee: Bruno Cadonna
> failed test StateDirectoryTest.shouldLogStateDirCleanerMessag
[
https://issues.apache.org/jira/browse/KAFKA-10514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200647#comment-17200647
]
Bruno Cadonna commented on KAFKA-10514:
---
Thank you for catching this! This test se
tombentley commented on pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#issuecomment-697220456
@ijuma sorry about that. Now fixed.
This is an automated message from the Apache Git Service.
To respond to th
chia7712 commented on pull request #9162:
URL: https://github.com/apache/kafka/pull/9162#issuecomment-697223860
```
Build / JDK 8 /
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
```
It is flaky on my local so it should b
Thorsten Hake created KAFKA-10515:
-
Summary: NPE: Foreign key join serde may not be initialized with
default serde if application is distributed
Key: KAFKA-10515
URL: https://issues.apache.org/jira/browse/KAFKA-10
cadonna opened a new pull request #9323:
URL: https://github.com/apache/kafka/pull/9323
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
cadonna commented on pull request #9323:
URL: https://github.com/apache/kafka/pull/9323#issuecomment-697269502
Call for review: @chia7712 @vvcephei @mjsax @guozhangwang @abbccdda
This is an automated message from the Apache
chia7712 opened a new pull request #9324:
URL: https://github.com/apache/kafka/pull/9324
this patch is similar to
https://github.com/apache/kafka/commit/ee68b999c49cbbf514940a81282ff894e6cf50d9
the tool "iproute2" is required by ```round_trip_fault_test.py``` and it is
not in openjd
ankit-kumar-25 closed pull request #9314:
URL: https://github.com/apache/kafka/pull/9314
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 g
ankit-kumar-25 opened a new pull request #9325:
URL: https://github.com/apache/kafka/pull/9325
What? :: Mentioning "Request Queue Size" under Monitoring tab.
RequestQueueSize is an important metric to monitor the number of requests in
the queue. As a crowded queue might face issue processi
nizhikov commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-697300763
Hello, @guozhangwang
Do you have system tests run results?
Can you, please, show me it.
This is an aut
[
https://issues.apache.org/jira/browse/KAFKA-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200748#comment-17200748
]
ASF GitHub Bot commented on KAFKA-8360:
---
ankit-kumar-25 closed pull request #220:
U
[
https://issues.apache.org/jira/browse/KAFKA-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200749#comment-17200749
]
ASF GitHub Bot commented on KAFKA-8360:
---
ankit-kumar-25 edited a comment on pull re
rajinisivaram merged pull request #9301:
URL: https://github.com/apache/kafka/pull/9301
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
edenhill commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-697307919
Excerpt from the Jenkins test run:
```
SESSION REPORT (ALL TESTS)
ducktape version: 0.7.9
session_id: 2020-09-20--001
run time: 400 minutes 59.682 seco
ankit-kumar-25 opened a new pull request #9326:
URL: https://github.com/apache/kafka/pull/9326
What? :: See
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/ConfigHandler.scala#L220
. The logic is supposed to accept only two cases:
list of k:v pairs
a s
nizhikov commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-697311299
>
kafkatest.tests.streams.streams_static_membership_test.StreamsStaticMembershipTest.test_rolling_bounces_will_not_trigger_rebalance_under_static_membership
>
kafkatest.tests.
nizhikov commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-697311780
@edenhill
> The IGNORED tests seems to be mostly
kafkatest.tests.streams.streams_upgrade_test.StreamsUpgradeTest.test_upgrade_downgrade_brokers..
Are they ignored i
[
https://issues.apache.org/jira/browse/KAFKA-10484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-10484:
-
Assignee: Bruno Cadonna
> Reduce Metrics Exposed by Streams
> -
C0urante commented on pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#issuecomment-697324142
Hi @michael-carter-instaclustr--unfortunately, it can take some time.
Usually I tag @rhauch and @kkonstantine on GitHub since they're the committers
that work most closely with t
David Jacot created KAFKA-10516:
---
Summary: Implement Topic Command changes
Key: KAFKA-10516
URL: https://issues.apache.org/jira/browse/KAFKA-10516
Project: Kafka
Issue Type: Sub-task
rajinisivaram commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493520165
##
File path: core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
##
@@ -331,6 +334,50 @@ class DynamicBrokerConfig(private val kafkaConfig:
K
vvcephei commented on pull request #9323:
URL: https://github.com/apache/kafka/pull/9323#issuecomment-697497868
Test failure was unrelated:
```
Build / JDK 11 /
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
```
---
vvcephei merged pull request #9323:
URL: https://github.com/apache/kafka/pull/9323
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 t
chia7712 commented on pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#issuecomment-697504023
rebase to fix conflicting
This is an automated message from the Apache Git Service.
To respond to the message, pl
chia7712 commented on pull request #9206:
URL: https://github.com/apache/kafka/pull/9206#issuecomment-697508626
rebase to include the fixes of flaky.
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200880#comment-17200880
]
Ilia Pasynkov commented on KAFKA-8318:
--
Hello, can I pick this issue?
> Session Win
mumrah opened a new pull request #9327:
URL: https://github.com/apache/kafka/pull/9327
Add Jenkinsfile to 2.5 branch so we can use the PR builder job
This is an automated message from the Apache Git Service.
To respond to the
mumrah opened a new pull request #9328:
URL: https://github.com/apache/kafka/pull/9328
Add a `deleteDir` directive to the temporary dir we create during the
streams/quickstart archetype test in the Jenkinsfile
This is an aut
viktorsomogyi commented on pull request #4090:
URL: https://github.com/apache/kafka/pull/4090#issuecomment-697538096
Rebased the PR
This is an automated message from the Apache Git Service.
To respond to the message, please l
viktorsomogyi edited a comment on pull request #4090:
URL: https://github.com/apache/kafka/pull/4090#issuecomment-697538096
Rebased the PR and addressed your comment
This is an automated message from the Apache Git Service.
T
mumrah opened a new pull request #9329:
URL: https://github.com/apache/kafka/pull/9329
This is a backport of the Jenkinsfile for 2.4 so we can use the PR builder
job
This is an automated message from the Apache Git Service.
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r493695444
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -1072,7 +1076,11 @@ private void transitio
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r493708455
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala
##
@@ -381,24 +385,35 @@ class TransactionCoordinator(broke
hachikuji opened a new pull request #9330:
URL: https://github.com/apache/kafka/pull/9330
A previous iteration of the Raft patch had a broken check for disconnects.
We had fixed the problem, but forgotten to remove the FIXME.
### Committer Checklist (excluded from commit message)
hachikuji merged pull request #9330:
URL: https://github.com/apache/kafka/pull/9330
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
hachikuji commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493742677
##
File path: core/src/main/scala/kafka/api/ApiVersion.scala
##
@@ -103,6 +103,9 @@ object ApiVersion {
KAFKA_2_7_IV0,
// Bup Fetch protocol for
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493751026
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -513,15 +513,21 @@ class AdminManager(val config: KafkaConfig,
resource -> Api
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493752855
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -547,7 +553,8 @@ class AdminManager(val config: KafkaConfig,
None
else
[
https://issues.apache.org/jira/browse/KAFKA-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaik Zakir Hussain updated KAFKA-10477:
Affects Version/s: 2.3.1
> Sink Connector fails with DataException when trying to
piotrrzysko commented on pull request #9315:
URL: https://github.com/apache/kafka/pull/9315#issuecomment-697717628
@jolshan @mumrah Thanks for the review! Of course, I agree with you that it
would be nice to use the mock in all tests, but after rethinking the solution
suggested in this PR
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493771144
##
File path: core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
##
@@ -331,6 +334,50 @@ class DynamicBrokerConfig(private val kafkaConfig:
KafkaC
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493771267
##
File path: core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
##
@@ -331,6 +334,50 @@ class DynamicBrokerConfig(private val kafkaConfig:
KafkaC
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493773324
##
File path: core/src/main/scala/kafka/server/ConfigHandler.scala
##
@@ -203,7 +203,13 @@ class BrokerConfigHandler(private val brokerConfig:
KafkaConfig
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493782410
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java
##
@@ -25,23 +25,35 @@
import org.apache.kafka.
hachikuji commented on pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#issuecomment-697805395
@chia7712 Mentioning the fix in the upgrade notes seems the best we can do.
The old (unintended) behavior does not seem worth keeping for the sake of
compatibility. @rajinisivar
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493795436
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -117,6 +117,89 @@ class KafkaApis(val requestChannel: RequestChannel,
val adminZkCl
[
https://issues.apache.org/jira/browse/KAFKA-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201019#comment-17201019
]
Shaik Zakir Hussain commented on KAFKA-10477:
-
All versions up and above *v2
mimaison commented on pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#issuecomment-697868544
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
mimaison commented on pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#issuecomment-697885454
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
hachikuji commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r493823776
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -117,6 +117,89 @@ class KafkaApis(val requestChannel: RequestChannel,
val adminZkC
apovzner commented on a change in pull request #9317:
URL: https://github.com/apache/kafka/pull/9317#discussion_r493869256
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1414,7 +1420,8 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metric
apovzner commented on a change in pull request #9317:
URL: https://github.com/apache/kafka/pull/9317#discussion_r493869256
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1414,7 +1420,8 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metric
mumrah commented on pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#issuecomment-697953307
@hachikuji yea, good catch. This works today using a ZK watch on the
partition "/state" znode which is still getting triggered with this PR. We can
modify the new ISR update path t
scanterog commented on pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#issuecomment-697968761
@hachikuji is there any chance you can review this? Thanks!
This is an automated message from the Apache Git Ser
guozhangwang commented on pull request #9312:
URL: https://github.com/apache/kafka/pull/9312#issuecomment-697980115
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4182/
passed now. I'm going to merge this one.
guozhangwang merged pull request #9312:
URL: https://github.com/apache/kafka/pull/9312
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
guozhangwang commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-697981040
https://github.com/apache/kafka/pull/9312 has been merged it. Could you
rebase this PR so I can re-trigger the system test suite?
As for the ignored test cases, they ar
guozhangwang merged pull request #9083:
URL: https://github.com/apache/kafka/pull/9083
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
nizhikov commented on pull request #9312:
URL: https://github.com/apache/kafka/pull/9312#issuecomment-697986003
Thanks for the review and merge!
This is an automated message from the Apache Git Service.
To respond to the mess
nizhikov commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-697987563
@guozhangwang
> Could you rebase this PR
done.
This is an automated message from the Apache Git Se
wushujames commented on pull request #9276:
URL: https://github.com/apache/kafka/pull/9276#issuecomment-697994325
The pull request lists lots of failed checks. However, this pull request
only changed an HTML file, and it seems unrelated to the test failures in those
checks.
-
Dhruvil Shah created KAFKA-10517:
Summary: Inefficient consumer processing with fetch sessions
Key: KAFKA-10517
URL: https://issues.apache.org/jira/browse/KAFKA-10517
Project: Kafka
Issue Typ
[
https://issues.apache.org/jira/browse/KAFKA-10517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dhruvil Shah updated KAFKA-10517:
-
Description:
With the introduction of fetch sessions, the consumer and the broker share a
unifi
Dhruvil Shah created KAFKA-10518:
Summary: Consumer fetches could be inefficient when lags are
unbalanced
Key: KAFKA-10518
URL: https://issues.apache.org/jira/browse/KAFKA-10518
Project: Kafka
ijuma opened a new pull request #9331:
URL: https://github.com/apache/kafka/pull/9331
I also removed a test class with no tests currently.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build statu
hachikuji opened a new pull request #9332:
URL: https://github.com/apache/kafka/pull/9332
There is a minor difference in behavior between the epoch caching logic in
`MockLog` from the behavior in `LeaderEpochFileCache`. The latter ensures that
every new epoch/start offset entry added to th
Jason Gustafson created KAFKA-10519:
---
Summary: Unit tests for VotedState
Key: KAFKA-10519
URL: https://issues.apache.org/jira/browse/KAFKA-10519
Project: Kafka
Issue Type: Sub-task
hachikuji commented on a change in pull request #9331:
URL: https://github.com/apache/kafka/pull/9331#discussion_r493968673
##
File path: raft/src/test/java/org/apache/kafka/raft/VotedStateTest.java
##
@@ -1,28 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) un
ijuma commented on a change in pull request #9331:
URL: https://github.com/apache/kafka/pull/9331#discussion_r493969248
##
File path: raft/src/test/java/org/apache/kafka/raft/VotedStateTest.java
##
@@ -1,28 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under
mjsax opened a new pull request #9333:
URL: https://github.com/apache/kafka/pull/9333
Partially reverts #8864
Call for review @vvcephei @hachikuji @cmccabe @ijuma
This is an automated message from the Apache Git Serv
mjsax commented on a change in pull request #8864:
URL: https://github.com/apache/kafka/pull/8864#discussion_r493976743
##
File path:
streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java
##
@@ -45,6 +45,7 @@
private static final Stri
[
https://issues.apache.org/jira/browse/KAFKA-10297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10297.
-
Resolution: Invalid
We change the KIP to not deprecate `retries`. Hence, this ticket is
chia7712 commented on pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#issuecomment-698083970
```
Build / JDK 11 /
kafka.api.ConsumerBounceTest.testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
```
it is flaky on trunk branch also so it is unr
[
https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankit Kumar reassigned KAFKA-9075:
--
Assignee: Ankit Kumar
> Extend documentation for usage of GlobalKTable vs KTable
> ---
apovzner commented on a change in pull request #9317:
URL: https://github.com/apache/kafka/pull/9317#discussion_r494034591
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1447,13 +1454,33 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metr
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including new APIs for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awkw
apovzner commented on a change in pull request #9317:
URL: https://github.com/apache/kafka/pull/9317#discussion_r494053882
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1292,6 +1292,12 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metri
apovzner commented on pull request #9317:
URL: https://github.com/apache/kafka/pull/9317#issuecomment-698128538
@dajac Thanks for the review, I addressed your comments.
This is an automated message from the Apache Git Service
abbccdda commented on a change in pull request #9332:
URL: https://github.com/apache/kafka/pull/9332#discussion_r494062676
##
File path: raft/src/test/java/org/apache/kafka/raft/MockLogTest.java
##
@@ -370,6 +365,23 @@ public void testReadOutOfRangeOffset() {
Isola
cadonna commented on pull request #9328:
URL: https://github.com/apache/kafka/pull/9328#issuecomment-698151176
@mumrah, error message
```
[2020-09-24T01:46:33.204Z] Cleaning up test-streams-archetype
No such property: deleteDir for class: groovy.lang.Binding
```
in build
84 matches
Mail list logo
