omkreddy commented on pull request #8717:
URL: https://github.com/apache/kafka/pull/8717#issuecomment-640014947
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9712:
--
Assignee: Matthias J. Sax (was: Nigel Liang)
> Reflections library 0.9.12 introduced
[
https://issues.apache.org/jira/browse/KAFKA-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9712:
--
Assignee: Nigel Liang (was: Matthias J. Sax)
> Reflections library 0.9.12 introduced
[
https://issues.apache.org/jira/browse/KAFKA-9840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-9840.
Fix Version/s: 2.6.0
Resolution: Fixed
> Consumer should not use OffsetForLeaderEpoc
[
https://issues.apache.org/jira/browse/KAFKA-10094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127142#comment-17127142
]
Jakob Homan commented on KAFKA-10094:
-
Patch accepted and merged.
> In MirrorSource
[
https://issues.apache.org/jira/browse/KAFKA-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127196#comment-17127196
]
James Cheng commented on KAFKA-8180:
Do we know if this has been fixed in recent vers
[
https://issues.apache.org/jira/browse/KAFKA-10094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jakob Homan resolved KAFKA-10094.
-
Resolution: Fixed
> In MirrorSourceConnector replace two-step assignment with single call
>
[
https://issues.apache.org/jira/browse/KAFKA-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127377#comment-17127377
]
Will LaForst commented on KAFKA-5514:
-
I think the misuse of propertlies can be linke
omkreddy closed pull request #8717:
URL: https://github.com/apache/kafka/pull/8717
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
[
https://issues.apache.org/jira/browse/KAFKA-10033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-10033.
---
Fix Version/s: 2.7.0
Resolution: Fixed
> AdminClient should throw UnknownTopicOrPartitionExce
abbccdda commented on a change in pull request #8820:
URL: https://github.com/apache/kafka/pull/8820#discussion_r436278473
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -107,6 +107,9 @@
private boolean commitNeeded
[
https://issues.apache.org/jira/browse/KAFKA-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9851:
--
Fix Version/s: 2.5.1
2.4.2
2.6.0
bellemare commented on a change in pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#discussion_r436278818
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializationIntegrationTest.java
##
@@ -94,15 +101,
guozhangwang commented on pull request #8820:
URL: https://github.com/apache/kafka/pull/8820#issuecomment-640080856
test this
This is an automated message from the Apache Git Service.
To respond to the message, please
bellemare commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-640080864
Updated KTableKTableForeignKeyJoinScenarioTest from (String,String) to
(Integer,String). This would have caught this particular bug. Reverted the
JSON-related test since it's no
guozhangwang commented on pull request #8820:
URL: https://github.com/apache/kafka/pull/8820#issuecomment-640080953
okay to test
This is an automated message from the Apache Git Service.
To respond to the message, please log
guozhangwang commented on pull request #8820:
URL: https://github.com/apache/kafka/pull/8820#issuecomment-640081002
okay to test
This is an automated message from the Apache Git Service.
To respond to the message, ple
[
https://issues.apache.org/jira/browse/KAFKA-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-9851.
---
Resolution: Fixed
> Revoking Connect tasks due to connectivity issues should
[
https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-7833:
---
Labels: newbie (was: )
> StreamsBuilder should throw an exception if addGlobalStore and addS
abbccdda commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r436283473
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -100,11 +103,11 @@ public InternalTopicMa
mtillu commented on pull request #8797:
URL: https://github.com/apache/kafka/pull/8797#issuecomment-640097211
> Thanks for the contribution! Can we please follow the guidelines as
described here for future contributions?
>
> https://cwiki.apache.org/confluence/display/KAFKA/Contribut
lbradstreet commented on a change in pull request #8807:
URL: https://github.com/apache/kafka/pull/8807#discussion_r436289337
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1242,131 +1243,138 @@ class ReplicaManager(val config: KafkaConfig,
Jason Gustafson created KAFKA-10113:
---
Summary: LogTruncationException sets fetch offsets incorrectly
Key: KAFKA-10113
URL: https://issues.apache.org/jira/browse/KAFKA-10113
Project: Kafka
I
hachikuji opened a new pull request #8822:
URL: https://github.com/apache/kafka/pull/8822
This patch fixes a bug in the constructor of `LogTruncationException`. We
were passing the divergent offsets to the super constructor as the fetch
offsets. There is no way to fix this without breaking
mjsax commented on pull request #8820:
URL: https://github.com/apache/kafka/pull/8820#issuecomment-640112555
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8820:
URL: https://github.com/apache/kafka/pull/8820#issuecomment-640112530
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8803:
URL: https://github.com/apache/kafka/pull/8803#issuecomment-640113151
Java 8 and Java 11 failed with env issue. Java 14 passed.
This is an automated message from the Apache Git Service.
mjsax commented on pull request #8803:
URL: https://github.com/apache/kafka/pull/8803#issuecomment-640113179
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax opened a new pull request #8823:
URL: https://github.com/apache/kafka/pull/8823
Call for review @bbejeck
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9891:
---
Fix Version/s: 2.5.1
2.6.0
> Invalid state store content after task migrat
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127456#comment-17127456
]
John Roesler commented on KAFKA-10091:
--
Sure thing, Guozhang!
I’m a little hazy on
mjsax merged pull request #8820:
URL: https://github.com/apache/kafka/pull/8820
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
[
https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10097:
---
Assignee: Boyang Chen
> Avoid getting null map for task checkpoint
> --
mjsax commented on pull request #8820:
URL: https://github.com/apache/kafka/pull/8820#issuecomment-640138817
Merged to `trunk` and cherry-picked to `2.6` branch.
This is an automated message from the Apache Git Service.
To re
wlaforest opened a new pull request #8824:
URL: https://github.com/apache/kafka/pull/8824
KafkaConsumer (and some other classes like KafkaProducer) does not respect
defaults in Properties objects. This is because a process translates the
Properties to a Map in the Utils class which uses t
[
https://issues.apache.org/jira/browse/KAFKA-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127471#comment-17127471
]
Gwen Shapira commented on KAFKA-8180:
-
[~dajac] merged some performance improvements
[
https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10097:
Summary: Avoid passing task checkpoint file externally (was: Avoid getting
null map for task chec
[
https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10097.
-
Resolution: Fixed
> Avoid passing task checkpoint file externally
>
[
https://issues.apache.org/jira/browse/KAFKA-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127488#comment-17127488
]
Will LaForst commented on KAFKA-5514:
-
See pull request: [https://github.com/apache/k
abbccdda commented on a change in pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#discussion_r436318626
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -852,14 +835,28 @@ public void onFailure(RuntimeExcepti
[
https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127500#comment-17127500
]
Rob Meng edited comment on KAFKA-7833 at 6/7/20, 4:30 AM:
--
I'm l
[
https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127500#comment-17127500
]
Rob Meng commented on KAFKA-7833:
-
I'm looking for my first issue to tackle. It sounds li
kkonstantine commented on pull request #8805:
URL: https://github.com/apache/kafka/pull/8805#issuecomment-640156075
Recent build history:
jdk8 and jdk14 green
jdk11 two on
`org.apache.kafka.streams.integration.QueryableStateIntegrationTest` which is
unrelated.
Adding another
ijuma commented on pull request #8807:
URL: https://github.com/apache/kafka/pull/8807#issuecomment-640157773
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
ijuma commented on a change in pull request #8802:
URL: https://github.com/apache/kafka/pull/8802#discussion_r436325309
##
File path: clients/src/main/resources/common/message/FetchRequest.json
##
@@ -49,7 +49,7 @@
"fields": [
{ "name": "ReplicaId", "type": "int32", "ve
[
https://issues.apache.org/jira/browse/KAFKA-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127513#comment-17127513
]
Ismael Juma commented on KAFKA-8180:
This too: [https://github.com/apache/kafka/pull/
robin5540 opened a new pull request #8825:
URL: https://github.com/apache/kafka/pull/8825
*Summary of testing strategy (including rationale)
* Added a test that attempts to call `.addStateStore` with the same
`StoreBuilder`, which builds two stores of the same name.
### Committer
[
https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127522#comment-17127522
]
Rob Meng commented on KAFKA-7833:
-
PR: [https://github.com/apache/kafka/pull/8825]
> Str
48 matches
Mail list logo
