dajac commented on a change in pull request #9401:
URL: https://github.com/apache/kafka/pull/9401#discussion_r521902936
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java
##
@@ -194,7 +106,27 @@ private ProduceRequest build(short version,
chia7712 commented on a change in pull request #9401:
URL: https://github.com/apache/kafka/pull/9401#discussion_r521927723
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java
##
@@ -194,7 +106,27 @@ private ProduceRequest build(short versio
chia7712 commented on a change in pull request #9401:
URL: https://github.com/apache/kafka/pull/9401#discussion_r521931887
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java
##
@@ -323,27 +222,30 @@ public String toString(boolean verbose)
feyman2016 opened a new pull request #9588:
URL: https://github.com/apache/kafka/pull/9588
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade note
feyman2016 commented on pull request #9588:
URL: https://github.com/apache/kafka/pull/9588#issuecomment-725938758
Running without the fix in
KAFKA-10284(https://github.com/apache/kafka/pull/9270), the
`FencedInstanceIdException` will be thrown.
---
feyman2016 edited a comment on pull request #9588:
URL: https://github.com/apache/kafka/pull/9588#issuecomment-725938758
Running without the fix in
KAFKA-10284(https://github.com/apache/kafka/pull/9270), the
`FencedInstanceIdException` will be thrown, details as below.
Test log:
```
chia7712 commented on a change in pull request #9401:
URL: https://github.com/apache/kafka/pull/9401#discussion_r521927723
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java
##
@@ -194,7 +106,27 @@ private ProduceRequest build(short versio
Chia-Ping Tsai created KAFKA-10709:
--
Summary: Sender#sendProduceRequest should use auto-generated
protocol directly
Key: KAFKA-10709
URL: https://issues.apache.org/jira/browse/KAFKA-10709
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-10446.
Resolution: Won't Fix
> add "lz4" and "zstd" to compression type of benchmark_test.py
> --
chia7712 commented on a change in pull request #9401:
URL: https://github.com/apache/kafka/pull/9401#discussion_r521957221
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java
##
@@ -194,7 +106,27 @@ private ProduceRequest build(short versio
[
https://issues.apache.org/jira/browse/KAFKA-10438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-10438.
Fix Version/s: 2.8.0
Resolution: Fixed
> Lazy initialization of record header to re
chia7712 closed pull request #9587:
URL: https://github.com/apache/kafka/pull/9587
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 #9587:
URL: https://github.com/apache/kafka/pull/9587#issuecomment-725960391
@vergilchiu I'm going to close this PR. feel free to reopen it if you have
other idea.
This is an automated mess
Julien C created KAFKA-10710:
Summary: MirrorMaker 2 creates all combinations of herders
Key: KAFKA-10710
URL: https://issues.apache.org/jira/browse/KAFKA-10710
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien C updated KAFKA-10710:
-
Description:
We are using MM2 distributed to synchronize topics from a "Central" broker down
to multipl
[
https://issues.apache.org/jira/browse/KAFKA-10710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien C updated KAFKA-10710:
-
Description:
We are using MM2 distributed to synchronize topics from a "Central" broker down
to multipl
[
https://issues.apache.org/jira/browse/KAFKA-10710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien C updated KAFKA-10710:
-
Description:
We are using MM2 distributed to synchronize topics from a "Central" broker down
to multipl
Ruslan Gryn created KAFKA-10711:
---
Summary: A low value in commit.interval.ms leads to unnecessary
committing offsets
Key: KAFKA-10711
URL: https://issues.apache.org/jira/browse/KAFKA-10711
Project: Kafk
stanislavkozlovski commented on a change in pull request #7498:
URL: https://github.com/apache/kafka/pull/7498#discussion_r521996452
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
##
@@ -639,8 +644,9 @@ else if (error == Errors.CLUS
stanislavkozlovski commented on a change in pull request #7498:
URL: https://github.com/apache/kafka/pull/7498#discussion_r52132
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
##
@@ -659,6 +655,12 @@ else if (error == Errors.CLU
[
https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-10515:
--
Assignee: Mickael Maison
> NPE: Foreign key join serde may not be initialized with de
[
https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-10515:
--
Assignee: Thorsten Hake (was: Mickael Maison)
> NPE: Foreign key join serde may not
chia7712 commented on a change in pull request #9401:
URL: https://github.com/apache/kafka/pull/9401#discussion_r522005653
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java
##
@@ -204,118 +75,79 @@ public ProduceResponse(Map responses) {
[
https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230553#comment-17230553
]
Mickael Maison commented on KAFKA-10309:
Fidex in https://github.com/apache/kafk
[
https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230553#comment-17230553
]
Mickael Maison edited comment on KAFKA-10309 at 11/12/20, 11:45 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10309.
Resolution: Fixed
> KafkaProducer's sendOffsetsToTransaction should not block infinitively
[
https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison closed KAFKA-10309.
--
> KafkaProducer's sendOffsetsToTransaction should not block infinitively
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230559#comment-17230559
]
Mickael Maison commented on KAFKA-10417:
SInce there's still no PR, removing 2.6
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10417:
---
Fix Version/s: (was: 2.6.1)
> suppress() with cogroup() throws ClassCastException
>
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230559#comment-17230559
]
Mickael Maison edited comment on KAFKA-10417 at 11/12/20, 11:47 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-9861:
--
Fix Version/s: (was: 2.6.1)
> Process Simplification - Community Validation of Kafka Releas
[
https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230560#comment-17230560
]
Mickael Maison commented on KAFKA-9861:
---
Since there's still no PR, removing 2.6.1
stanislavkozlovski commented on pull request #7498:
URL: https://github.com/apache/kafka/pull/7498#issuecomment-726079643
test failures for JDK 15 seem unrelated:
```
kafka.server.ScramServerStartupTest.testAuthentications
org.apache.zookeeper.KeeperException$NoAuthException: Keeper
cadonna commented on a change in pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#discussion_r522027942
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java
##
@@ -314,6 +317,50 @@ public void buildAndOpti
feyman2016 commented on pull request #9588:
URL: https://github.com/apache/kafka/pull/9588#issuecomment-726134837
The failed test:
`org.apache.kafka.streams.integration.StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization`
d
feyman2016 edited a comment on pull request #9588:
URL: https://github.com/apache/kafka/pull/9588#issuecomment-726134837
Call for review @abbccdda :)
The failed test:
`org.apache.kafka.streams.integration.StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDiff
iprithv commented on pull request #9204:
URL: https://github.com/apache/kafka/pull/9204#issuecomment-726148418
Thanks for approving @chia7712 , have attached the images of before and
after message.
https://user-images.githubusercontent.com/48927540/98959127-fb4d5180-2528-11eb-9f72-4
twobeeb opened a new pull request #9589:
URL: https://github.com/apache/kafka/pull/9589
As described in JIRA KAFKA-10710,
Running mirror maker 2 with multiple clusters defined in the clusters
properties creates a herder for all the possible combinations even if the
"link" are not wante
vvcephei commented on a change in pull request #9489:
URL: https://github.com/apache/kafka/pull/9489#discussion_r522203482
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -703,6 +703,16 @@ void runOnce() {
/
chia7712 commented on pull request #9204:
URL: https://github.com/apache/kafka/pull/9204#issuecomment-726159989
@iprithv Thanks for the sharing. nit: there is a redundant space before
“batchSize”.
This is an automated messag
Mickael Maison created KAFKA-10712:
--
Summary: Update release scripts to Python3
Key: KAFKA-10712
URL: https://issues.apache.org/jira/browse/KAFKA-10712
Project: Kafka
Issue Type: Improvement
Mickael Maison created KAFKA-10713:
--
Summary: Surprising behaviour when bootstrap servers are separated
by semicolons
Key: KAFKA-10713
URL: https://issues.apache.org/jira/browse/KAFKA-10713
Project:
[
https://issues.apache.org/jira/browse/KAFKA-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10713:
---
Description:
When creating a Kafka client with bootstrap.servers set to
"kafka-0:9092;kafka
[
https://issues.apache.org/jira/browse/KAFKA-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10713:
---
Description:
When creating a Kafka client with {{bootstrap.servers}} set to
"kafka-0:9092;k
ableegoldman commented on a change in pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#discussion_r522381803
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java
##
@@ -71,6 +78,21 @@ public Pattern topicP
ableegoldman commented on a change in pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#discussion_r522384690
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java
##
@@ -71,6 +78,21 @@ public Pattern topicP
jolshan opened a new pull request #9590:
URL: https://github.com/apache/kafka/pull/9590
The current behavior for KafkaConsumer.beginningOffsets on compacted topics
is to always return offset 0. However, when looking at the record with the
earliest timestamp in the log with KafkaConsumer.of
Boyang Chen created KAFKA-10714:
---
Summary: Save unnecessary end txn call when the transaction is
confirmed to be done
Key: KAFKA-10714
URL: https://issues.apache.org/jira/browse/KAFKA-10714
Project: Kaf
hachikuji merged pull request #9201:
URL: https://github.com/apache/kafka/pull/9201
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
Lincong commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r522441321
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1236,9 +1236,19 @@ class KafkaApis(val requestChannel: RequestChannel,
val topicM
Lincong commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r522441321
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1236,9 +1236,19 @@ class KafkaApis(val requestChannel: RequestChannel,
val topicM
JimGalasyn opened a new pull request #9591:
URL: https://github.com/apache/kafka/pull/9591
Fixes internal ticket DOCS-5813.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r522472868
##
File path: core/src/test/scala/unit/kafka/network/RequestConvertToJsonTest.scala
##
@@ -0,0 +1,199 @@
+/**
+ * Licensed to the Apache Software Found
ableegoldman commented on a change in pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#discussion_r522384690
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java
##
@@ -71,6 +78,21 @@ public Pattern topicP
ableegoldman commented on a change in pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#discussion_r522384690
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java
##
@@ -71,6 +78,21 @@ public Pattern topicP
ableegoldman commented on a change in pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#discussion_r522476382
##
File path:
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java
##
@@ -895,6 +898,55 @@ public void
shouldUseSpecifiedNameForAgg
Ravindranath Kakarla created KAFKA-10715:
Summary: Support Kafka connect converter for AVRO
Key: KAFKA-10715
URL: https://issues.apache.org/jira/browse/KAFKA-10715
Project: Kafka
Issu
ableegoldman commented on a change in pull request #9583:
URL: https://github.com/apache/kafka/pull/9583#discussion_r522514992
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -102,6 +107,15 @@ public StateDirectory(fin
[
https://issues.apache.org/jira/browse/KAFKA-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231048#comment-17231048
]
Mickael Maison commented on KAFKA-10665:
Failure while building 2.6.1:
https://
olafurpg commented on pull request #9548:
URL: https://github.com/apache/kafka/pull/9548#issuecomment-726424250
Feel free to commandeer this PR if you still think it’s a good idea. I
totally understand the reasoning to keep things unchanged so I’m not sure I’m
the best person to push this
ableegoldman commented on a change in pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#discussion_r522525068
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java
##
@@ -314,6 +317,50 @@ public void buildAn
mjsax commented on a change in pull request #9568:
URL: https://github.com/apache/kafka/pull/9568#discussion_r522531710
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -575,17 +577,22 @@ private void
setRepa
mjsax commented on a change in pull request #9568:
URL: https://github.com/apache/kafka/pull/9568#discussion_r522531802
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
##
@@ -135,6 +141,37 @@ private Admin createAdminC
mjsax commented on a change in pull request #9568:
URL: https://github.com/apache/kafka/pull/9568#discussion_r522531802
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
##
@@ -135,6 +141,37 @@ private Admin createAdminC
mjsax commented on a change in pull request #9568:
URL: https://github.com/apache/kafka/pull/9568#discussion_r522531802
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
##
@@ -135,6 +141,37 @@ private Admin createAdminC
ableegoldman commented on pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#issuecomment-726433686
> According to the ticket similar work needs to be done for table() and
globalTable(). What do you think of adding subtasks to the ticket to track what
has already been done
ableegoldman commented on a change in pull request #9582:
URL: https://github.com/apache/kafka/pull/9582#discussion_r522549685
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java
##
@@ -314,6 +317,50 @@ public void buildAn
A. Sophie Blee-Goldman created KAFKA-10716:
--
Summary: Streams processId is unstable across restarts resulting
in task mass migration
Key: KAFKA-10716
URL: https://issues.apache.org/jira/browse/KAFKA-10716
[
https://issues.apache.org/jira/browse/KAFKA-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231084#comment-17231084
]
A. Sophie Blee-Goldman commented on KAFKA-10678:
Yeah, it seems like any
[
https://issues.apache.org/jira/browse/KAFKA-10716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231116#comment-17231116
]
A. Sophie Blee-Goldman commented on KAFKA-10716:
There are a few possibl
ableegoldman commented on a change in pull request #9489:
URL: https://github.com/apache/kafka/pull/9489#discussion_r522579641
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -703,6 +703,16 @@ void runOnce() {
[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231123#comment-17231123
]
Richard Yu commented on KAFKA-10575:
Thanks for letting me know! I was already looki
ableegoldman commented on a change in pull request #9489:
URL: https://github.com/apache/kafka/pull/9489#discussion_r522591013
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -703,6 +703,16 @@ void runOnce() {
ableegoldman commented on a change in pull request #9568:
URL: https://github.com/apache/kafka/pull/9568#discussion_r522591645
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -575,17 +577,22 @@ private void
abbccdda merged pull request #9588:
URL: https://github.com/apache/kafka/pull/9588
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
ableegoldman commented on a change in pull request #9568:
URL: https://github.com/apache/kafka/pull/9568#discussion_r522594933
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
##
@@ -135,6 +141,37 @@ private Admin creat
ableegoldman commented on a change in pull request #9568:
URL: https://github.com/apache/kafka/pull/9568#discussion_r522595543
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java
##
@@ -135,6 +141,37 @@ private Admin creat
chia7712 commented on pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#issuecomment-726491192
@Lincong Thanks for updating code. Could you fix the conflicting files as
well?
This is an automated message fro
Lincong commented on pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#issuecomment-726495188
> @Lincong Thanks for updating code. Could you fix the conflicting files as
well?
Conflicts resolved
This
ableegoldman commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r518488577
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -255,8 +255,9 @@ public ByteBuffe
ableegoldman commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r522596527
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -366,6 +375,93 @@ public void setUncaughtExceptionHandler(final
T
chia7712 commented on a change in pull request #9401:
URL: https://github.com/apache/kafka/pull/9401#discussion_r522670294
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java
##
@@ -204,118 +75,79 @@ public ProduceResponse(Map responses) {
[
https://issues.apache.org/jira/browse/KAFKA-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley reassigned KAFKA-10713:
---
Assignee: Tom Bentley
> Surprising behaviour when bootstrap servers are separated by semico
guozhangwang commented on a change in pull request #9569:
URL: https://github.com/apache/kafka/pull/9569#discussion_r522675518
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -713,6 +715,8 @@ public void sendOffsetsToTransaction(M
Stefan Bejan created KAFKA-10717:
Summary: ACL authorization log when consumer requires all topics
Key: KAFKA-10717
URL: https://issues.apache.org/jira/browse/KAFKA-10717
Project: Kafka
Issue
85 matches
Mail list logo
