[
https://issues.apache.org/jira/browse/KAFKA-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317386#comment-17317386
]
Jason Gustafson commented on KAFKA-12607:
-
[~dengziming] Aha, that makes sense. I was wondering
mumrah opened a new pull request #10504:
URL: https://github.com/apache/kafka/pull/10504
This is part of the implementation for
[KIP-730](https://cwiki.apache.org/confluence/display/KAFKA/KIP-730%3A+Producer+ID+generation+in+KRaft+mode)
which is still under discussion. The details of the
[
https://issues.apache.org/jira/browse/KAFKA-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
raphael auv updated KAFKA-12628:
Description:
There is a dynamic update of SLL conf by the broker client
mumrah merged pull request #10254:
URL: https://github.com/apache/kafka/pull/10254
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
raphael auv updated KAFKA-12628:
Summary: Enable dynamic update of client-side SSL in consumer or producer
clients (was: SSL
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r609948744
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -38,20 +48,36 @@
private final String
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r609954693
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -133,34 +141,37 @@ public void process(final
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r609948744
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -38,20 +48,36 @@
private final String
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r609948744
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -38,20 +48,36 @@
private final String
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r609948744
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -38,20 +48,36 @@
private final String
hachikuji merged pull request #10481:
URL: https://github.com/apache/kafka/pull/10481
--
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,
hachikuji commented on a change in pull request #10481:
URL: https://github.com/apache/kafka/pull/10481#discussion_r609943203
##
File path: raft/src/main/java/org/apache/kafka/raft/LeaderState.java
##
@@ -113,13 +113,18 @@ private boolean updateHighWatermark() {
[
https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-12555:
---
Assignee: Alexander Daskalov
> Log reason for rolling a segment
>
[
https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-12555:
---
Assignee: (was: Ryan Dielhenn)
> Log reason for rolling a segment
>
[
https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317372#comment-17317372
]
Jason Gustafson commented on KAFKA-12555:
-
[~Comonut] Yeah, that is a good list. I assume you
[
https://issues.apache.org/jira/browse/KAFKA-12457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-12457.
-
Resolution: Fixed
> Implications of KIP-516 for quorum controller
>
hachikuji merged pull request #10492:
URL: https://github.com/apache/kafka/pull/10492
--
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,
[
https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317364#comment-17317364
]
Mickael Maison commented on KAFKA-9831:
---
I saw it again today in the 2.7 build:
{noformat}
abbccdda commented on a change in pull request #10482:
URL: https://github.com/apache/kafka/pull/10482#discussion_r609922102
##
File path:
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java
##
@@ -181,7 +181,7 @@ public static
C0urante commented on a change in pull request #10503:
URL: https://github.com/apache/kafka/pull/10503#discussion_r609882468
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java
##
@@ -185,8 +185,15 @@ private void doRun() throws
abbccdda commented on a change in pull request #10482:
URL: https://github.com/apache/kafka/pull/10482#discussion_r609920651
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -1031,6 +1032,23 @@ protected StreamsConfig(final Map props,
[
https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317351#comment-17317351
]
Alexander Daskalov commented on KAFKA-12555:
I started looking into this issue, but I'm new
mjsax commented on a change in pull request #10482:
URL: https://github.com/apache/kafka/pull/10482#discussion_r609907071
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -1031,6 +1032,23 @@ protected StreamsConfig(final Map props,
[
https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn reassigned KAFKA-12555:
-
Assignee: Ryan Dielhenn
> Log reason for rolling a segment
>
[
https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317341#comment-17317341
]
Stanislav Kozlovski commented on KAFKA-12555:
-
No, I don't know the reasons. I was hoping
[
https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317339#comment-17317339
]
Jose Armando Garcia Sancio commented on KAFKA-12555:
Thanks [~enether]. This is a
Matthias J. Sax created KAFKA-12634:
---
Summary: Should checkpoint after restore finished
Key: KAFKA-12634
URL: https://issues.apache.org/jira/browse/KAFKA-12634
Project: Kafka
Issue Type:
junrao commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609895193
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java
##
@@ -0,0 +1,309 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317327#comment-17317327
]
Matthias J. Sax commented on KAFKA-12453:
-
{quote}and why `builder.stream().toTable()` is
Guozhang Wang created KAFKA-12633:
-
Summary: Remove deprecated "TopologyTestDriver#pipeInput /
readOutput"
Key: KAFKA-12633
URL: https://issues.apache.org/jira/browse/KAFKA-12633
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12630.
---
Fix Version/s: 3.0.0
Resolution: Fixed
> Remove deprecated
guozhangwang merged pull request #10502:
URL: https://github.com/apache/kafka/pull/10502
--
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,
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317116#comment-17317116
]
Sagar Rao edited comment on KAFKA-8295 at 4/8/21, 3:12 PM:
---
hey
dengziming commented on a change in pull request #10480:
URL: https://github.com/apache/kafka/pull/10480#discussion_r609608513
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -2235,6 +2233,7 @@ private Long append(int epoch, List records,
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317116#comment-17317116
]
Sagar Rao commented on KAFKA-8295:
--
hey [~ableegoldman], this is a very old ticket but i was looking at
[
https://issues.apache.org/jira/browse/KAFKA-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-12623.
Resolution: Fixed
> Fix LICENSE in 2.7
> --
>
> Key:
dengziming commented on a change in pull request #10481:
URL: https://github.com/apache/kafka/pull/10481#discussion_r609589579
##
File path: raft/src/main/java/org/apache/kafka/raft/LeaderState.java
##
@@ -113,13 +113,18 @@ private boolean updateHighWatermark() {
[
https://issues.apache.org/jira/browse/KAFKA-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317102#comment-17317102
]
Mickael Maison commented on KAFKA-12623:
I cherry picked the commit from 2.8 and made the
[
https://issues.apache.org/jira/browse/KAFKA-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317093#comment-17317093
]
Mickael Maison commented on KAFKA-12622:
When following this process for 2.7, I used this
g1geordie commented on pull request #10190:
URL: https://github.com/apache/kafka/pull/10190#issuecomment-815594893
@bbejeck
Thanks for your response !!
I see the compatibility claim in NamedInternal.
```
String orElseGenerateWithPrefix(final InternalNameProvider provider,
chia7712 merged pull request #10501:
URL: https://github.com/apache/kafka/pull/10501
--
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,
chia7712 merged pull request #10406:
URL: https://github.com/apache/kafka/pull/10406
--
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,
戈震 created KAFKA-12632:
--
Summary: Exception may missed when source task failing
Key: KAFKA-12632
URL: https://issues.apache.org/jira/browse/KAFKA-12632
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316930#comment-17316930
]
Patrick O'Keeffe commented on KAFKA-12453:
--
Thanks the response [~mjsax], and apologies for not
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609387061
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteLogMetadataManagerTest.java
##
@@ -0,0 +1,130 @@
+/*
+ *
satishd commented on pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#issuecomment-815513359
@junrao Thanks for your comments. Replied on comments and addressed them
with the
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r608820288
##
File path:
remote-storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataCache.java
##
@@ -0,0 +1,305 @@
+/*
+ * Licensed
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609372137
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCacheTest.java
##
@@ -0,0 +1,379 @@
+/*
+ *
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609372257
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCacheTest.java
##
@@ -0,0 +1,379 @@
+/*
+ *
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609369903
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCacheTest.java
##
@@ -0,0 +1,379 @@
+/*
+ *
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609369434
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java
##
@@ -0,0 +1,310 @@
+/*
+ *
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609369185
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteLogMetadataManager.java
##
@@ -0,0 +1,160 @@
+/*
+ *
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609352593
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCacheTest.java
##
@@ -0,0 +1,379 @@
+/*
+ *
satishd commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r609351020
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/storage/InmemoryRemoteStorageManagerTest.java
##
@@ -0,0 +1,246 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/KAFKA-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316889#comment-17316889
]
dengziming commented on KAFKA-12607:
[~hachikuji] [~guozhang] I find it's unnecessary to fix this
101 - 155 of 155 matches
Mail list logo
