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
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
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
[
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
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-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
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
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
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
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
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
[
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
[
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-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-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-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-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-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-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
>
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-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?
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
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
[
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
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
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
[
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
[
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
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
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-692897599
Yeah I've already cherry-picked to 2.6/2.5.
This is an automated message from the Apache Git Service.
To resp
[
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
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-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
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
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 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 under high load (over
6,000 msg/sec and 1,5 Mbytes/sec) using OpenJDK 11.0.7 and the following kafka
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
---
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
[
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
> --
[
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
> ---
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
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
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
[
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 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
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
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
[
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
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
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 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
[
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
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
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
[
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
> -
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
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,
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
[
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
> ---
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
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 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
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 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
[
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
> -
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
73 matches
Mail list logo
