chia7712 opened a new pull request #9291:
URL: https://github.com/apache/kafka/pull/9291
issue: https://issues.apache.org/jira/browse/KAFKA-10264
The test case sends two records before killing broker. The failure is caused
by that the both records are NOT in a single batch and so the
[
https://issues.apache.org/jira/browse/KAFKA-10488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vodevops updated KAFKA-10488:
-
Labels: build kafka-manager (was: kafka-manager)
> Adding cluster with ssl to kafka-manager
> -
guozhangwang commented on pull request #9247:
URL: https://github.com/apache/kafka/pull/9247#issuecomment-693164059
> @DOJI45 Thanks for the PR! Could you also add a unit test to complete the
coverage? You can find some examples in StreamTaskTest or
ProcessorStateManagerTest
Seems t
vodevops created KAFKA-10488:
Summary: Adding cluster with ssl to kafka-manager
Key: KAFKA-10488
URL: https://issues.apache.org/jira/browse/KAFKA-10488
Project: Kafka
Issue Type: Bug
guozhangwang commented on a change in pull request #9247:
URL: https://github.com/apache/kafka/pull/9247#discussion_r489156100
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -662,4 +662,10 @@ public TopicPartit
guozhangwang commented on pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#issuecomment-693163575
LGTM. Leaving to @kkonstantine and @rhauch for final review and merge.
This is an automated message from the
guozhangwang commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-693162999
@nizhikov could you rebase your PR on trunk so I can trigger a system test
run to verify?
This is an automat
[
https://issues.apache.org/jira/browse/KAFKA-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-9876:
-
Component/s: core
> Implement Raft Protocol for Metadata Quorum
> ---
ableegoldman commented on a change in pull request #9083:
URL: https://github.com/apache/kafka/pull/9083#discussion_r489129386
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
##
@@ -37,6 +37,7 @@
/**
* If the chec
chia7712 commented on pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#issuecomment-693137180
@ijuma please take a look :)
This is an automated message from the Apache Git Service.
To respond to the message,
chia7712 commented on pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#issuecomment-693137029
```
Build / JDK 8 / kafka.api.TransactionsBounceTest.testWithGroupMetadata
```
this flaky is traced by https://issues.apache.org/jira/browse/KAFKA-10251
[
https://issues.apache.org/jira/browse/KAFKA-10264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-10264:
--
Assignee: Chia-Ping Tsai
> Flaky Test TransactionsTest.testBumpTransactionalEpoch
> -
guozhangwang commented on pull request #9083:
URL: https://github.com/apache/kafka/pull/9083#issuecomment-693127922
@ableegoldman @abbccdda This is a minor cleanup PR that I found while
working on KAFKA-9450.
This is an auto
ableegoldman commented on a change in pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#discussion_r488999403
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -65,10 +65,6 @@ public ProcessorConte
[
https://issues.apache.org/jira/browse/KAFKA-10487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10487:
Description:
Consider the following scenario:
Three replicas: A, B, and C. In epoch=1, re
hachikuji edited a comment on pull request #9290:
URL: https://github.com/apache/kafka/pull/9290#issuecomment-693114335
An alternative name for "diverging epoch" is "previous epoch" which is used
in the literature. I preferred the former because it is more descriptive and
because the retur
hachikuji commented on pull request #9290:
URL: https://github.com/apache/kafka/pull/9290#issuecomment-693114335
An alternative name for "diverging epoch" is "previous epoch." I preferred
the former because it is more descriptive and because the returned epoch could
be equal to the last_fe
hachikuji opened a new pull request #9290:
URL: https://github.com/apache/kafka/pull/9290
This patch changes the Fetch response schema to include both the diverging
epoch and its end offset rather than just the offset. This allows for more
accurate truncation on the follower. This is the s
[
https://issues.apache.org/jira/browse/KAFKA-10487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10487:
Description:
Consider the following scenario:
Three replicas: A, B, and C. In epoch=1, re
Jason Gustafson created KAFKA-10487:
---
Summary: Fix edge case in Raft truncation protocol
Key: KAFKA-10487
URL: https://issues.apache.org/jira/browse/KAFKA-10487
Project: Kafka
Issue Type: S
[
https://issues.apache.org/jira/browse/KAFKA-10487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10487:
Description:
Consider the following scenario:
Three replicas: A, B, and C. In epoch=1, re
guozhangwang merged pull request #9258:
URL: https://github.com/apache/kafka/pull/9258
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 #9258:
URL: https://github.com/apache/kafka/pull/9258#issuecomment-693030043
LGTM!
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
ableegoldman commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r488977783
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -306,40 +306,52 @@ public synchronized void
[
https://issues.apache.org/jira/browse/KAFKA-10405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196553#comment-17196553
]
Sophie Blee-Goldman commented on KAFKA-10405:
-
Same error as above –
[https
ableegoldman removed a comment on pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#issuecomment-692979445
Retest this please
This is an automated message from the Apache Git Service.
To respond to the messag
ableegoldman commented on pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#issuecomment-692980127
One unrelated known-flaky test failure:
`PurgeRepartitionTopicIntegrationTest.shouldRestoreState`
This is an
ableegoldman commented on pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#issuecomment-692979445
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, pleas
guozhangwang commented on pull request #9268:
URL: https://github.com/apache/kafka/pull/9268#issuecomment-692968498
7500 LOC :) new record man.
This is an automated message from the Apache Git Service.
To respond to the messa
[
https://issues.apache.org/jira/browse/KAFKA-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10435.
-
Resolution: Fixed
> Fetch protocol changes for KIP-595
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10435:
Fix Version/s: 2.7.0
> Fetch protocol changes for KIP-595
> --
hachikuji merged pull request #9275:
URL: https://github.com/apache/kafka/pull/9275
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
gordonmessmer commented on pull request #5785:
URL: https://github.com/apache/kafka/pull/5785#issuecomment-692935583
Could everyone who is having this issue test this pull request instead and
comment there if it resolves your issue?
https://github.com/apache/kafka/pull/9188
---
kildibaev edited a comment on pull request #5785:
URL: https://github.com/apache/kafka/pull/5785#issuecomment-692927289
Hi there
I was able to reproduce the "buffer overflow" warning under high load (over
6,000 msg/sec and 1,5 Mbytes/sec) using OpenJDK 11.0.7 and the following kafka
kildibaev edited a comment on pull request #5785:
URL: https://github.com/apache/kafka/pull/5785#issuecomment-692927289
Hi there
I was able to reproduce the "buffer overflow" warning under high load (over
6,000 msg/sec) using OpenJDK 11.0.7 and the following kafka option:
`-Djsse.SS
kildibaev edited a comment on pull request #5785:
URL: https://github.com/apache/kafka/pull/5785#issuecomment-692927289
Hi there
I was able to reproduce the "buffer overflow" warning using OpenJDK 11.0.7
and the following kafka option: `-Djsse.SSLEngine.acceptLargeFragments=true`.
I
kildibaev commented on pull request #5785:
URL: https://github.com/apache/kafka/pull/5785#issuecomment-692927289
Hi there
I was able to reproduce the "buffer overflow" warning using OpenJDK 11.0.7
and the following kafka option: `-Djsse.SSLEngine.acceptLargeFragments=true`.
If I'm r
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196476#comment-17196476
]
Guozhang Wang commented on KAFKA-8803:
--
[~bp...@yahoo.com][~msilb][~vkorna][~eleanor
cadonna commented on pull request #9286:
URL: https://github.com/apache/kafka/pull/9286#issuecomment-692901008
Thanks a lot!
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
[
https://issues.apache.org/jira/browse/KAFKA-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196462#comment-17196462
]
Guozhang Wang commented on KAFKA-10475:
---
[~bchen225242] could you also help lookin
guozhangwang commented on pull request #9286:
URL: https://github.com/apache/kafka/pull/9286#issuecomment-692897599
Yeah I've already cherry-picked to 2.6/2.5.
This is an automated message from the Apache Git Service.
To resp
cadonna commented on pull request #9286:
URL: https://github.com/apache/kafka/pull/9286#issuecomment-692893920
@guozhangwang, Thank you for merging! Could you please cherry-pick this PR
to 2.6 and 2.5?
This is an automated m
guozhangwang commented on pull request #9286:
URL: https://github.com/apache/kafka/pull/9286#issuecomment-692886348
LGTM!
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
guozhangwang merged pull request #9286:
URL: https://github.com/apache/kafka/pull/9286
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
[
https://issues.apache.org/jira/browse/KAFKA-10486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vodevops updated KAFKA-10486:
-
Description:
I'm trying to add cluster in kafka which is ssl enabled with port 9093.
below is the issue
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196442#comment-17196442
]
ke commented on KAFKA-8803:
---
Hi, we have similar issue too. kafka broker version is 2.3.1. but
vodevops created KAFKA-10486:
Summary: Adding cluster with ssl to kafka-manager
Key: KAFKA-10486
URL: https://issues.apache.org/jira/browse/KAFKA-10486
Project: Kafka
Issue Type: Bug
Co
hachikuji commented on a change in pull request #9275:
URL: https://github.com/apache/kafka/pull/9275#discussion_r488850209
##
File path: core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala
##
@@ -47,63 +47,81 @@ class LeaderEpochFileCache(topicPartition: TopicPar
[
https://issues.apache.org/jira/browse/KAFKA-10264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196428#comment-17196428
]
Sophie Blee-Goldman commented on KAFKA-10264:
-
Go for it
> Flaky Test Trans
mumrah commented on pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#issuecomment-692859976
Recent changes include:
* Controller no longer sends LeaderAndIsr, only UpdateMetadata (more more
leader epoch bump)
* Update Partition's ISR from AlterIsr response
* P
rajinisivaram commented on a change in pull request #9275:
URL: https://github.com/apache/kafka/pull/9275#discussion_r488833309
##
File path: core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala
##
@@ -47,63 +47,81 @@ class LeaderEpochFileCache(topicPartition: Topi
[
https://issues.apache.org/jira/browse/KAFKA-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196402#comment-17196402
]
Andrey Polyakov commented on KAFKA-10313:
-
Possibly a duplicate of KAFKA-9543?
Guozhang Wang created KAFKA-10485:
-
Summary: Use a separate error code for replication related errors
Key: KAFKA-10485
URL: https://issues.apache.org/jira/browse/KAFKA-10485
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-6664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino resolved KAFKA-6664.
--
Resolution: Won't Do
KIP was not accepted
> KIP-269 Substitution Within Configuration Values
>
[
https://issues.apache.org/jira/browse/KAFKA-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino resolved KAFKA-10418.
---
Resolution: Fixed
PR: https://github.com/apache/kafka/pull/9199
> Incomplete error/docs whe
[
https://issues.apache.org/jira/browse/KAFKA-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-10213:
--
Fix Version/s: 2.7.0
> Prefer --bootstrap-server in ducktape tests for Kafka clients
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-10258:
--
Fix Version/s: 2.7.0
> Get rid of use_zk_connection flag in kafka.py public methods
>
[
https://issues.apache.org/jira/browse/KAFKA-10258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino resolved KAFKA-10258.
---
Resolution: Fixed
> Get rid of use_zk_connection flag in kafka.py public methods
> -
[
https://issues.apache.org/jira/browse/KAFKA-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino resolved KAFKA-10213.
---
Resolution: Fixed
> Prefer --bootstrap-server in ducktape tests for Kafka clients
>
[
https://issues.apache.org/jira/browse/KAFKA-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino resolved KAFKA-10131.
---
Fix Version/s: 2.7.0
Reviewer: Colin McCabe
Resolution: Fixed
PR: https://gi
[
https://issues.apache.org/jira/browse/KAFKA-10484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196289#comment-17196289
]
Guozhang Wang commented on KAFKA-10484:
---
Thanks Bruno. I agree that providing some
pasriva opened a new pull request #9289:
URL: https://github.com/apache/kafka/pull/9289
*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 testing s
showuon commented on pull request #9062:
URL: https://github.com/apache/kafka/pull/9062#issuecomment-692651239
@omkreddy , could you review this PR? Thanks.
This is an automated message from the Apache Git Service.
To respond
cadonna commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r488578475
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -328,15 +328,15 @@ private synchronized void cle
cadonna commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r488578142
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -328,15 +328,15 @@ private synchronized void cle
cadonna commented on pull request #9286:
URL: https://github.com/apache/kafka/pull/9286#issuecomment-692643436
System test run for trunk:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4166/
System test run for 2.6:
https://jenkins.confluent.io/job/system-test
rajinisivaram commented on a change in pull request #9236:
URL: https://github.com/apache/kafka/pull/9236#discussion_r488519370
##
File path:
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java
##
@@ -213,6 +213,7 @@ public LoginContext login() t
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195982#comment-17195982
]
Michael Silbermann commented on KAFKA-8803:
---
Hi all,
Is there any update on th
showuon closed pull request #9288:
URL: https://github.com/apache/kafka/pull/9288
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
[
https://issues.apache.org/jira/browse/KAFKA-10264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195946#comment-17195946
]
Chia-Ping Tsai commented on KAFKA-10264:
[~ableegoldman] Could I take over this
Bruno Cadonna created KAFKA-10484:
-
Summary: Reduce Metrics Exposed by Streams
Key: KAFKA-10484
URL: https://issues.apache.org/jira/browse/KAFKA-10484
Project: Kafka
Issue Type: Improvement
zaahirlaher edited a comment on pull request #9225:
URL: https://github.com/apache/kafka/pull/9225#issuecomment-690019628
@huxihx Currently the --num-records is the actual number of records sent,
which are randomly selected from the payload file.
What if --num-records < the entries in
Ning Zhang created KAFKA-10483:
--
Summary: extract common functions from SourceConnector and
SourceTask
Key: KAFKA-10483
URL: https://issues.apache.org/jira/browse/KAFKA-10483
Project: Kafka
Iss
73 matches
Mail list logo
