satishd commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r722923763
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/CommittedOffsetsFile.java
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to
satishd commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r722911577
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSnapshotFile.java
##
@@ -0,0 +1,253 @@
+/*
+ * L
satishd commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r722884223
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/CommittedOffsetsFile.java
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to
mjsax commented on a change in pull request #11370:
URL: https://github.com/apache/kafka/pull/11370#discussion_r722840836
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java
##
@@ -98,9 +96,15 @@ public synchronized void put(
mjsax commented on pull request #11355:
URL: https://github.com/apache/kafka/pull/11355#issuecomment-935259937
Thanks for the PR @cddr! Merged to `trunk`.
--
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
mjsax merged pull request #11355:
URL: https://github.com/apache/kafka/pull/11355
--
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.
To unsubscribe, e-mail: jira-unsubscr...
[
https://issues.apache.org/jira/browse/KAFKA-13350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13350:
Description:
When we hit an `OffsetOutOfRangeException` during restore, we close a tasks a
Matthias J. Sax created KAFKA-13350:
---
Summary: Handle task corrupted exception on a per state store basis
Key: KAFKA-13350
URL: https://issues.apache.org/jira/browse/KAFKA-13350
Project: Kafka
satishd commented on pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#issuecomment-935124023
Thanks @junrao for the comments, added in-line replies.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
satishd commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r722794018
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerRestartTest.java
##
@@ -0,0 +1,
satishd commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r722791508
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerRestartTest.java
##
@@ -0,0 +1,
kowshik commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r722772977
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSnapshotFile.java
##
@@ -0,0 +1,253 @@
+/*
+ * L
junrao commented on a change in pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#discussion_r722776127
##
File path:
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerRestartTest.java
##
@@ -0,0 +1,1
cmccabe opened a new pull request #11383:
URL: https://github.com/apache/kafka/pull/11383
Change ZooKeeperTestHarness to QuorumTestHarness so that integration tests
which inherit from this
class can test both ZK and KRaft mode. Test cases which do this can specify
the modes they support
OmniaGM commented on a change in pull request #11220:
URL: https://github.com/apache/kafka/pull/11220#discussion_r722666580
##
File path:
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java
##
@@ -52,9 +52,39 @@ default String originalTop
TheKnowles opened a new pull request #11382:
URL: https://github.com/apache/kafka/pull/11382
This change allows Source Tasks the option to receive Producer Exceptions
and decide what to do with them. Currently the task is just killed if the
producer throws an exception via its callback. Su
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bartłomiej Stachura reassigned KAFKA-13349:
---
Assignee: Bartłomiej Stachura
> Allow Iterator.remove on KeyValueIterator
>
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13349:
Labels: needs-kip newbie++ (was: newbie++)
> Allow Iterator.remove on KeyValueIterator
>
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13346:
Component/s: streams
> Kafka Streams fails due to RocksDB Locks Not Available Exception
>
Guozhang Wang created KAFKA-13349:
-
Summary: Allow Iterator.remove on KeyValueIterator
Key: KAFKA-13349
URL: https://issues.apache.org/jira/browse/KAFKA-13349
Project: Kafka
Issue Type: Impro
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424647#comment-17424647
]
A. Sophie Blee-Goldman commented on KAFKA-13346:
+1 to increasing the op
ijuma merged pull request #11374:
URL: https://github.com/apache/kafka/pull/11374
--
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.
To unsubscribe, e-mail: jira-unsubscr...
hachikuji commented on pull request #11372:
URL: https://github.com/apache/kafka/pull/11372#issuecomment-934656281
@guozhangwang I've been trying to write a test case for this scenario, but
so far I've been unsuccessful. I think in order to hit this case, we have to
send to a new partition
ableegoldman commented on a change in pull request #11381:
URL: https://github.com/apache/kafka/pull/11381#discussion_r722488122
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1280,29 +1281,36 @@ int process(final int m
[
https://issues.apache.org/jira/browse/KAFKA-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch reassigned KAFKA-10865:
-
Assignee: Tiago Martins (was: Govinda Sakhare)
> Improve trace-logging for Transformat
[
https://issues.apache.org/jira/browse/KAFKA-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10865:
--
[~upsidedownsmile], I've assigned this issue to you as requested. You are now
listed as a contrib
ableegoldman commented on a change in pull request #11381:
URL: https://github.com/apache/kafka/pull/11381#discussion_r722480165
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -299,6 +301,7 @@ public boolean isRunning()
[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424590#comment-17424590
]
Hao Li commented on KAFKA-13164:
Hi Ralph,
I actually can see output for both cases
[
https://issues.apache.org/jira/browse/KAFKA-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Knowles Atchison Jr reassigned KAFKA-13348:
---
Assignee: Knowles Atchison Jr
> Allow Source Tasks to Handle Producer Excep
Knowles Atchison Jr created KAFKA-13348:
---
Summary: Allow Source Tasks to Handle Producer Exceptions
Key: KAFKA-13348
URL: https://issues.apache.org/jira/browse/KAFKA-13348
Project: Kafka
wcarlson5 commented on a change in pull request #11381:
URL: https://github.com/apache/kafka/pull/11381#discussion_r722408690
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1280,29 +1281,36 @@ int process(final int maxN
Scott M Messner created KAFKA-13347:
---
Summary: kafka-topics.sh required arguments and defaults
Key: KAFKA-13347
URL: https://issues.apache.org/jira/browse/KAFKA-13347
Project: Kafka
Issue T
[
https://issues.apache.org/jira/browse/KAFKA-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424480#comment-17424480
]
Tiago Martins commented on KAFKA-10865:
---
Hello, I assume that [~govi20] is no long
upsidedownsmile commented on pull request #11375:
URL: https://github.com/apache/kafka/pull/11375#issuecomment-934430195
@rhauch could you please review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424424#comment-17424424
]
Bruno Cadonna commented on KAFKA-13346:
---
Hi [~amitguptaiitr85],
Could you try to
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Gupta updated KAFKA-13346:
---
Description:
Hello,
We are using Kafka Streams and we observe that some times on some of the hosts
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Gupta updated KAFKA-13346:
---
Description:
Hello,
We are using Kafka Streams and we observe that some times on some of the hosts
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Gupta updated KAFKA-13346:
---
Description:
Hello,
We are using Kafka Streams and we observe that some times on some of the hosts
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Gupta updated KAFKA-13346:
---
Summary: Kafka Streams fails due to RocksDB Locks Not Available exception
(was: Kafka Streams fails
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Gupta updated KAFKA-13346:
---
Summary: Kafka Streams fails due to RocksDB Locks Not Available Exception
(was: Kafka Streams fails
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Gupta updated KAFKA-13346:
---
Description:
Hello,
We are using Kafka Streams and we observe that some times on some of the hosts
Amit Gupta created KAFKA-13346:
--
Summary: Kafka Streams fails due to unexpected exception
Key: KAFKA-13346
URL: https://issues.apache.org/jira/browse/KAFKA-13346
Project: Kafka
Issue Type: Bug
viktorsomogyi commented on pull request #11373:
URL: https://github.com/apache/kafka/pull/11373#issuecomment-934265796
@ijuma would you please quickly review this small pr?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
ableegoldman commented on pull request #11381:
URL: https://github.com/apache/kafka/pull/11381#issuecomment-934171853
Haven't finished writing tests for this, but the non-testing code is ready
for review -- cc @wcarlson5 @guozhangwang @rodesai
--
This is an automated message from the Ap
ableegoldman opened a new pull request #11381:
URL: https://github.com/apache/kafka/pull/11381
In the current exception handler, there's not much granularity and all
exceptions from all sources are treated equally. With the introduction of
independent named topologies, it would be nice to
kowshik edited a comment on pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#issuecomment-934133766
@ccding During a call to `log.flush()`, we remember
[here](https://github.com/apache/kafka/blob/1d3b96389b325520648d29b6363941f50e5b6d35/core/src/main/scala/kafka/log/Unif
lkokhreidze commented on pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#issuecomment-934149747
Thanks for the feedback @cadonna
I will review and address your comments this week.
--
This is an automated message from the Apache Git Service.
To respond to the messa
kowshik commented on pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#issuecomment-934133766
@ccding During a call to `log.flush()`, we remember
[here](https://github.com/apache/kafka/blob/1d3b96389b325520648d29b6363941f50e5b6d35/core/src/main/scala/kafka/log/UnifiedLog.
patrickstuedi commented on a change in pull request #11234:
URL: https://github.com/apache/kafka/pull/11234#discussion_r721953611
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java
##
@@ -351,10 +345,8 @@ public V fetchSession
49 matches
Mail list logo
