Andre Araujo created KAFKA-10478:
Summary: advertised.listeners should allow duplicated ports
Key: KAFKA-10478
URL: https://issues.apache.org/jira/browse/KAFKA-10478
Project: Kafka
Issue
chia7712 commented on pull request #9271:
URL: https://github.com/apache/kafka/pull/9271#issuecomment-691397979
```
失敗
Build / JDK 8 /
org.apache.kafka.clients.admin.KafkaAdminClientTest.testMetadataRetries
```
it is already fixed by
guozhangwang commented on pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#issuecomment-691389142
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194590#comment-17194590
]
Guozhang Wang commented on KAFKA-6127:
--
I think we can close this ticket now, since:
* All blocking
showuon commented on pull request #9178:
URL: https://github.com/apache/kafka/pull/9178#issuecomment-691365862
@junrao , No, the failing tests are not related to my change.
**tests/Build/JDK 11**: PASS
**tests/Build/JDK 15**:
MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691360304
@mjsax that sounds like it will work for the majority of the use cases I've
come across. One thing thats not clear to me is how kstream operations that are
down stream of a
ableegoldman commented on pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#issuecomment-691358663
Alright this should finally be ready for a final pass and merge @vvcephei
@cadonna -- sorry for leaving this hanging for so long.
After running a few different tests,
ableegoldman commented on pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#issuecomment-691357934
Also, looks like there were checkstyle issues. Probably you just need to add
the license header to the new file
ableegoldman commented on a change in pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#discussion_r487336115
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
##
@@ -418,10 +419,14 @@ private boolean
[
https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194565#comment-17194565
]
Sophie Blee-Goldman edited comment on KAFKA-6127 at 9/11/20, 11:47 PM:
[
https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194565#comment-17194565
]
Sophie Blee-Goldman commented on KAFKA-6127:
[~guozhang] any thoughts on this? You probably
mjsax commented on a change in pull request #9255:
URL: https://github.com/apache/kafka/pull/9255#discussion_r487321249
##
File path: clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java
##
@@ -784,4 +787,39 @@ public void testCloseAllQuietly() {
mjsax commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691339633
@MicahRam I completely agree with what you are saying, and there are
actually two relevant KIPs in-flight atm the might help. For the Processor API,
we could use the KIP John
[
https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194548#comment-17194548
]
Matthias J. Sax commented on KAFKA-6127:
Not 100% sure either :) – this ticket is almost 3 years
[
https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194543#comment-17194543
]
Sophie Blee-Goldman commented on KAFKA-6127:
[~mjsax] is this ticket still relevant? I didn't
[
https://issues.apache.org/jira/browse/KAFKA-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-7970.
Fix Version/s: 2.7.0
Assignee: Bruno Cadonna
Resolution: Fixed
>
vvcephei merged pull request #9239:
URL: https://github.com/apache/kafka/pull/9239
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
vvcephei commented on pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#issuecomment-691322853
These test failures look unrelated:
```
Build / JDK 11 /
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
[
https://issues.apache.org/jira/browse/KAFKA-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194533#comment-17194533
]
Shaik Zakir Hussain commented on KAFKA-10477:
-
Observed that the issue doesn't occur in
[
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.4.0
> Sink Connector fails with DataException when trying to
MicahRam edited a comment on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691315131
@mjsax its been a while since I looked at the code but from what I remember
from looking through the commit history it used to throw exceptions and there
was a commit
MicahRam edited a comment on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691315131
@mjsax its been a while since I looked at the code but from what I remember
from looking through the commit history it used to throw exceptions and there
was a commit
MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691315131
@mjsax its been a while since I looked at the code but from what I remember
from looking through the commit history it used to throw exceptions and there
was a commit thats
Shaik Zakir Hussain created KAFKA-10477:
---
Summary: Sink Connector fails with DataException when trying to
convert Kafka record with empty key to Connect Record
Key: KAFKA-10477
URL:
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194483#comment-17194483
]
Swayam Raina commented on KAFKA-10467:
--
> did it happen in the latest version of Kafka?
>
[
https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194469#comment-17194469
]
Sophie Blee-Goldman commented on KAFKA-10455:
-
Yeah, I think you're touching on a related
vvcephei commented on pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#issuecomment-691224736
Oops:
```
17:31:33 [ant:checkstyle] [ERROR]
[
https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194449#comment-17194449
]
Walker Carlson commented on KAFKA-9331:
---
vvcephei commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r487174400
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java
##
@@ -493,52 +494,59 @@ public void
mjsax commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487172402
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -832,18 +834,25 @@ public String queryableStoreName() {
vvcephei commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r487171555
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java
##
@@ -131,14 +157,15 @@ public
vvcephei commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r487170646
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java
##
@@ -131,14 +157,15 @@ public
mjsax commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487169320
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java
##
@@ -39,9 +39,15 @@
}
@Override
-
mjsax commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487167789
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -182,6 +182,8 @@ public String queryableStoreName() {
mjsax commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487166164
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java
##
@@ -47,8 +47,10 @@
}
@Override
-
lct45 commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r487110043
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java
##
@@ -131,14 +157,15 @@ public void
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487057805
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -182,6 +182,8 @@ public String
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487060524
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java
##
@@ -295,12 +295,39 @@ public void
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487060171
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java
##
@@ -77,10 +77,16 @@ public String
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487060524
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java
##
@@ -295,12 +295,39 @@ public void
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487059154
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java
##
@@ -39,9 +39,15 @@
}
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487059154
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java
##
@@ -39,9 +39,15 @@
}
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487060078
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java
##
@@ -39,9 +39,15 @@
}
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487057186
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java
##
@@ -47,8 +47,10 @@
}
@Override
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487059154
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java
##
@@ -39,9 +39,15 @@
}
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487058548
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -832,18 +834,25 @@ public String
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487057805
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -182,6 +182,8 @@ public String
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487057186
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java
##
@@ -47,8 +47,10 @@
}
@Override
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487049443
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java
##
@@ -17,11 +17,12 @@
package
AbdulRahman Mahmoud created KAFKA-10476:
---
Summary: Error when calling (kafka-configs.sh --add-config):
org.apache.kafka.common.KafkaException: Failed to create new
KafkaAdminClient. Caused by: javax.crypto.BadPaddingException: Given
nym3r0s commented on pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#issuecomment-691058386
@mjsax @ableegoldman @hachikuji - tagging for awareness.
This is an automated message from the Apache Git
jeqo commented on pull request #9139:
URL: https://github.com/apache/kafka/pull/9139#issuecomment-691045209
cc @ableegoldman and team, this should be ready to review.
Would also be great to look #9228 as part of KIP-666, to get the APIs
aligned.
Thanks!
[
https://issues.apache.org/jira/browse/KAFKA-9795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194209#comment-17194209
]
Rishika Modi commented on KAFKA-9795:
-
Thank you :)
> Add throttleTimeMs in logs
>
[
https://issues.apache.org/jira/browse/KAFKA-9795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rishika Modi reassigned KAFKA-9795:
---
Assignee: Rishika Modi
> Add throttleTimeMs in logs
> --
>
>
nym3r0s opened a new pull request #9280:
URL: https://github.com/apache/kafka/pull/9280
KAFKA-10186: Abort transaction with pending data with
TransactionAbortedException
If a transaction is aborted with no underlying exception, throw
a new kind of exception -
tombentley commented on pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#issuecomment-690954007
@ijuma @hachikuji @guozhangwang any chance one of you could review this?
This is an automated message from the
[
https://issues.apache.org/jira/browse/KAFKA-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194093#comment-17194093
]
M. Manna commented on KAFKA-10465:
--
[~guozhang] - Thanks for your comments. I am not sure whether you
[
https://issues.apache.org/jira/browse/KAFKA-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194082#comment-17194082
]
Javier Holguera commented on KAFKA-9752:
What version of the Kafka clients
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194047#comment-17194047
]
Florian Rossier commented on KAFKA-10413:
-
Hi,
We are also affected by this issue, seem's for
ning2008wisc commented on pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#issuecomment-690907900
@ryannedolan @mimaison when possible, very appreciated for your attentions
and feedback :) Thanks
This is
xakassi commented on a change in pull request #9211:
URL: https://github.com/apache/kafka/pull/9211#discussion_r478325832
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java
##
@@ -733,10 +734,11 @@ public void
61 matches
Mail list logo
