chia7712 merged pull request #10661:
URL: https://github.com/apache/kafka/pull/10661
--
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.
For queries about this service, pleas
tang7526 commented on pull request #10588:
URL: https://github.com/apache/kafka/pull/10588#issuecomment-850770445
> > BTW, could you add tests for the code used to generate data?
(https://github.com/apache/kafka/blob/trunk/tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java#
tang7526 commented on a change in pull request #10588:
URL: https://github.com/apache/kafka/pull/10588#discussion_r641890279
##
File path:
tools/src/test/java/org/apache/kafka/tools/ProducerPerformanceTest.java
##
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Found
tang7526 commented on a change in pull request #10588:
URL: https://github.com/apache/kafka/pull/10588#discussion_r641890244
##
File path:
tools/src/test/java/org/apache/kafka/tools/ProducerPerformanceTest.java
##
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Found
tang7526 commented on a change in pull request #10588:
URL: https://github.com/apache/kafka/pull/10588#discussion_r641890227
##
File path:
tools/src/test/java/org/apache/kafka/tools/ProducerPerformanceTest.java
##
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Found
tang7526 commented on a change in pull request #10588:
URL: https://github.com/apache/kafka/pull/10588#discussion_r641890191
##
File path:
tools/src/test/java/org/apache/kafka/tools/ProducerPerformanceTest.java
##
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Found
dengziming commented on pull request #10789:
URL: https://github.com/apache/kafka/pull/10789#issuecomment-850759832
Hi @viktorsomogyi @ijuma , PTAL.
--
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
dengziming opened a new pull request #10789:
URL: https://github.com/apache/kafka/pull/10789
*More detailed description of your change*
I'm verifying reassigning partitions in KRaft mode, and I accidentally find
that #4090 only propagate errors when parsing reassignment json, we'd better
ableegoldman opened a new pull request #10788:
URL: https://github.com/apache/kafka/pull/10788
Pt. 1: [#10609](https://github.com/apache/kafka/pull/10609)
Pt. 2: [10683](https://github.com/apache/kafka/pull/10683)
In Pt. 3 we implement the `addNamedTopology` API. This can be used t
ijuma edited a comment on pull request #9229:
URL: https://github.com/apache/kafka/pull/9229#issuecomment-850747419
This PR:
```
test_id:
kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=lz4
status:
ijuma edited a comment on pull request #9229:
URL: https://github.com/apache/kafka/pull/9229#issuecomment-850747419
This PR:
> test_id:
kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=lz4
> status: PAS
ijuma commented on pull request #9229:
URL: https://github.com/apache/kafka/pull/9229#issuecomment-850747419
This PR:
>
> SESSION REPORT (ALL TESTS)
> ducktape version: 0.8.1
> session_id:
feyman2016 commented on pull request #10593:
URL: https://github.com/apache/kafka/pull/10593#issuecomment-850743673
@jsancio Thank you for the kindly review and help~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/KAFKA-12545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12545:
--
Assignee: loboxu
> Integrate snapshot in the shell tool
>
>
>
cmccabe opened a new pull request #10787:
URL: https://github.com/apache/kafka/pull/10787
--
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.
For queries about this service,
Colin McCabe created KAFKA-12864:
Summary: Move KafkaEventQueue and timeline data structures into
server-common
Key: KAFKA-12864
URL: https://issues.apache.org/jira/browse/KAFKA-12864
Project: Kafka
vvcephei commented on pull request #10507:
URL: https://github.com/apache/kafka/pull/10507#issuecomment-850642648
Hey @jeqo , now that https://github.com/apache/kafka/pull/10744 is merged,
what do you think about just closing this PR and breaking it up into a series
of PRs that migrate one
vvcephei merged pull request #10744:
URL: https://github.com/apache/kafka/pull/10744
--
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.
For queries about this service, pleas
Jose Armando Garcia Sancio created KAFKA-12863:
--
Summary: Configure controller snapshot generation
Key: KAFKA-12863
URL: https://issues.apache.org/jira/browse/KAFKA-12863
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-12787:
---
Summary: Integrate controller snapshot with the RaftClient (was: Con
jsancio opened a new pull request #10786:
URL: https://github.com/apache/kafka/pull/10786
*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
ijuma commented on pull request #10780:
URL: https://github.com/apache/kafka/pull/10780#issuecomment-850609061
@jlprat See
https://github.com/apache/kafka/pull/10702#issuecomment-841663450 for
additional things that need to be fixed.
--
This is an automated message from the Apache Git S
ijuma commented on a change in pull request #10585:
URL: https://github.com/apache/kafka/pull/10585#discussion_r641757745
##
File path: build.gradle
##
@@ -380,6 +380,15 @@ subprojects {
}
}
+ cleanTest {
+subprojects.each {
+ delete "${it.buildDir}/test-res
jlprat commented on pull request #10780:
URL: https://github.com/apache/kafka/pull/10780#issuecomment-850605601
Thanks @ijuma for the review! The upgrade to JDK 16 is this one
https://github.com/apache/kafka/pull/10415 , right?
--
This is an automated message from the Apache Git Service.
ijuma merged pull request #10780:
URL: https://github.com/apache/kafka/pull/10780
--
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.
For queries about this service, please c
ijuma commented on pull request #10780:
URL: https://github.com/apache/kafka/pull/10780#issuecomment-850604343
We'll hopefully switch to JDK 16 before the 3.0 release.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
lkokhreidze opened a new pull request #10785:
URL: https://github.com/apache/kafka/pull/10785
*Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be conside
[
https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353465#comment-17353465
]
Moses Nakamura commented on KAFKA-3539:
---
I've gotten lots of good feedback on the d
[
https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353465#comment-17353465
]
Moses Nakamura edited comment on KAFKA-3539 at 5/28/21, 5:15 PM:
--
jlprat commented on pull request #10784:
URL: https://github.com/apache/kafka/pull/10784#issuecomment-850556227
Noted, I will ping them when touching that area.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ijuma commented on pull request #10784:
URL: https://github.com/apache/kafka/pull/10784#issuecomment-850554801
Looks like the formatting changes are on the streams scala module. cc @mjsax
@vvcephei @guozhangwang
--
This is an automated message from the Apache Git Service.
To respond to
jlprat commented on pull request #10784:
URL: https://github.com/apache/kafka/pull/10784#issuecomment-850550830
Sorry to almost always point at you @ijuma If you would have time, could you
take a look at this one? Maybe it's worth change the scala fmt config instead
of leaving these deaful
jlprat commented on pull request #10783:
URL: https://github.com/apache/kafka/pull/10783#issuecomment-850547775
Sure thing, let me fetch them and link them here:
* Spotless: Unfortunately there is no release notes to be found
* Scala 2.12.14: https://github.com/scala/scala/releases/tag
ijuma commented on pull request #10783:
URL: https://github.com/apache/kafka/pull/10783#issuecomment-850542590
Thanks for the PR. Can you please include links to the various release
notes? We typically look through them to understand if there's anything to be
worried about.
--
This is a
jlprat commented on pull request #10783:
URL: https://github.com/apache/kafka/pull/10783#issuecomment-850534872
cc @ijuma Could you please review this PR, as you were the one reviewing
this for the last time?
Thanks in advance
--
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/KAFKA-12862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353444#comment-17353444
]
Josep Prat commented on KAFKA-12862:
For an example of how the new code formatted wi
jlprat opened a new pull request #10784:
URL: https://github.com/apache/kafka/pull/10784
Updates the scala fmt to the latest stable version
Applies all the style fixes (all source code changes are done by scala
fmt)
Removes setting about dangling parentheses as `true` is already the
[
https://issues.apache.org/jira/browse/KAFKA-10581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhukailas Reddy updated KAFKA-10581:
Description:
Provide an ability to filter Kafka message events at Kafka broker based on
c
[
https://issues.apache.org/jira/browse/KAFKA-10581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhukailas Reddy updated KAFKA-10581:
Description: Provide an ability to filter kafka message events at Kafka
broker based on co
[
https://issues.apache.org/jira/browse/KAFKA-10581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhukailas Reddy updated KAFKA-10581:
Priority: Critical (was: Major)
> Ability to filter events at Kafka broker based on Kafka
Josep Prat created KAFKA-12862:
--
Summary: Update ScalaFMT version to latest
Key: KAFKA-12862
URL: https://issues.apache.org/jira/browse/KAFKA-12862
Project: Kafka
Issue Type: Improvement
jlprat opened a new pull request #10783:
URL: https://github.com/apache/kafka/pull/10783
Updates Scala version for 2.12 to the latest available
Updates Scala libs to the latest ones available
### Committer Checklist (excluded from commit message)
- [ ] Verify design and impl
[
https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353419#comment-17353419
]
Denis Savenko commented on KAFKA-4107:
--
Yes, this indeed should be implemented as Ka
[
https://issues.apache.org/jira/browse/KAFKA-12861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gérald Quintana updated KAFKA-12861:
Description:
Since KAFKA-10503, the MockProducer may raise NullPointerException when
key/
Gérald Quintana created KAFKA-12861:
---
Summary: MockProducer raises NPE when no Serializer
Key: KAFKA-12861
URL: https://issues.apache.org/jira/browse/KAFKA-12861
Project: Kafka
Issue Type:
showuon edited a comment on pull request #10736:
URL: https://github.com/apache/kafka/pull/10736#issuecomment-850396020
OK, on second thought, I start to think the root cause of this flaky test is
because the bug mentioned above. Increasing session timeout is just a
workaround to avoid reb
kosiakk commented on pull request #7539:
URL: https://github.com/apache/kafka/pull/7539#issuecomment-850399911
Depending on the assignment strategy, not all currently assigned partitions
will be rewoked. For example
`org.apache.kafka.clients.consumer.CooperativeStickyAssignor` tries to pre
showuon commented on pull request #10736:
URL: https://github.com/apache/kafka/pull/10736#issuecomment-850396020
OK, on second thought, I start to think the root cause of this flaky test is
because the bug mentioned above. Increasing session timeout is just a
workaround to avoid rebalancin
[
https://issues.apache.org/jira/browse/KAFKA-12860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353301#comment-17353301
]
KahnCheny commented on KAFKA-12860:
---
Hi [~junrao] is this still an issue?
> Partition
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-12847:
--
Assignee: Abhijit Mane
> Dockerfile needed for kafka system tests needs changes
> ---
[
https://issues.apache.org/jira/browse/KAFKA-12850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353226#comment-17353226
]
Josep Prat commented on KAFKA-12850:
Probably this task can be closed as it's a dupl
Abhijit-Mane opened a new pull request #10782:
URL: https://github.com/apache/kafka/pull/10782
Jira issue: https://issues.apache.org/jira/browse/KAFKA-12847
Fixes #12847
Signed-off-by: Abhijit Mane
*Summary of testing strategy (including rationale)
for the feature or
mimaison commented on pull request #10743:
URL: https://github.com/apache/kafka/pull/10743#issuecomment-850300974
@skaundinya15 Yeah we may have to rebase but that shouldn't be an issue. I
did not touch ListOffsets in this PR, I'm only updating methods that interact
with coordinators
--
[
https://issues.apache.org/jira/browse/KAFKA-12860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KahnCheny updated KAFKA-12860:
--
Description:
We encountered an issue with Kafka after running out of heap space. When on
several brok
[
https://issues.apache.org/jira/browse/KAFKA-12860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KahnCheny updated KAFKA-12860:
--
Description:
We encountered an issue with Kafka after running out of heap space. When on
several brok
feyman2016 commented on pull request #10593:
URL: https://github.com/apache/kafka/pull/10593#issuecomment-850279646
Thanks for your quick reply, call for review again @jsancio :)
The failed test:
`org.apache.kafka.connect.integration.BlockingConnectorTest.testBlockInSinkTaskStop`
is not
[
https://issues.apache.org/jira/browse/KAFKA-12860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KahnCheny updated KAFKA-12860:
--
Description:
We encountered an issue with Kafka after running out of heap space. When on
several brok
[
https://issues.apache.org/jira/browse/KAFKA-12860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KahnCheny updated KAFKA-12860:
--
Description:
We encountered an issue with Kafka after running out of heap space. When on
several agen
[
https://issues.apache.org/jira/browse/KAFKA-12860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KahnCheny updated KAFKA-12860:
--
Description:
We encountered an issue with Kafka after running out of heap space. When
several agents
[
https://issues.apache.org/jira/browse/KAFKA-12860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KahnCheny updated KAFKA-12860:
--
Description:
We encountered an issue with Kafka after running out of heap space. When
several agents
KahnCheny created KAFKA-12860:
-
Summary: Partition offset due to non-monotonically incrementing
offsets in logs
Key: KAFKA-12860
URL: https://issues.apache.org/jira/browse/KAFKA-12860
Project: Kafka
saddays opened a new pull request #10781:
URL: https://github.com/apache/kafka/pull/10781
*More detailed description of your change,
Reduce repeat authentication check for same broker.
*Summary of testing strategy (including rationale)
The requests belong to same broker,
62 matches
Mail list logo
