Fleshgrinder edited a comment on pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#issuecomment-704057098
@chia7712 the server gets null right now, and the code you propose is more
or less what I had originally. However, at least @rondagostino was directly
confused by the
Fleshgrinder commented on pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#issuecomment-704057098
@chia7712 the server gets null right now, and the code you propose is more
or less what I had originally. However, at least @rondagostino was directly
confused by the ternary
lkokhreidze commented on a change in pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#discussion_r500023844
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationIntegrationTest.java
##
@@ -0,0 +1,256 @@
+
chia7712 commented on pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#issuecomment-704046977
Nice finding!
Is there also a potential NPE in server-side? According to the protocol
schema
(https://github.com/apache/kafka/blob/trunk/clients/src/main/resources/common/
[
https://issues.apache.org/jira/browse/KAFKA-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208497#comment-17208497
]
Ilia Pasynkov commented on KAFKA-8318:
--
Hello, [~vvcephei].
Right now I'm looking a
guozhangwang commented on a change in pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#discussion_r51027
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -659,13 +665,12 @@ void runOnce() {
[
https://issues.apache.org/jira/browse/KAFKA-10577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10577:
Component/s: streams
> StreamThread should be able to process any processible tasks regard
[
https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208492#comment-17208492
]
Matthias J. Sax commented on KAFKA-10555:
-
{quote}I thought we were only conside
Guozhang Wang created KAFKA-10577:
-
Summary: StreamThread should be able to process any processible
tasks regardless of its state
Key: KAFKA-10577
URL: https://issues.apache.org/jira/browse/KAFKA-10577
mikebin commented on pull request #9373:
URL: https://github.com/apache/kafka/pull/9373#issuecomment-704032434
Thanks for the review @ableegoldman! Added a unit test. And thanks @vvcephei
for making it easier to cherry pick this fix back to 2.6.
---
[
https://issues.apache.org/jira/browse/KAFKA-10576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuriy Badalyantc updated KAFKA-10576:
-
Description:
It looks like {{commitSync}} and {{commitAsync}} consumer's methods have a
Yuriy Badalyantc created KAFKA-10576:
Summary: Different behavior of commitSync and commitAsync
Key: KAFKA-10576
URL: https://issues.apache.org/jira/browse/KAFKA-10576
Project: Kafka
Issu
ableegoldman commented on a change in pull request #9139:
URL: https://github.com/apache/kafka/pull/9139#discussion_r46879
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java
##
@@ -359,7 +431,11 @@ private void getNextSegm
Guozhang Wang created KAFKA-10575:
-
Summary: StateRestoreListener#onRestoreEnd should always be
triggered
Key: KAFKA-10575
URL: https://issues.apache.org/jira/browse/KAFKA-10575
Project: Kafka
ableegoldman commented on pull request #9373:
URL: https://github.com/apache/kafka/pull/9373#issuecomment-704010744
By the way, John was so kind as to cherrypick the trunk PR that rearranged
things in this method back to the 2.6 branch -- so we should be able to
cherrypick this PR smoothly
ableegoldman edited a comment on pull request #9373:
URL: https://github.com/apache/kafka/pull/9373#issuecomment-704010744
By the way, John was so kind as to cherrypick the trunk PR that rearranged
things in this method back to the 2.6 branch -- so we should be able to
cherrypick this PR s
guozhangwang commented on a change in pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#discussion_r499988582
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestoreThread.java
##
@@ -0,0 +1,263 @@
+/*
+ * Licensed to the
vvcephei commented on a change in pull request #9368:
URL: https://github.com/apache/kafka/pull/9368#discussion_r499812565
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -205,4 +207,9 @@ default boolean maybePunctuateSystemTime
[
https://issues.apache.org/jira/browse/KAFKA-10439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-10439.
Resolution: Fixed
Merged and back ported to the branches listed under "Fix
[
https://issues.apache.org/jira/browse/KAFKA-10439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-10439:
---
Fix Version/s: 2.6.1
2.5.2
2.4.2
kkonstantine opened a new pull request #9379:
URL: https://github.com/apache/kafka/pull/9379
Currently `BlockingConnectorTest` is incorrectly runs as a unit test.
Categorize this test correctly as integration test by adding the appropriate
annotation
### Committer Checklist (excl
rondagostino opened a new pull request #9378:
URL: https://github.com/apache/kafka/pull/9378
This PR adds missing broker ACLs required to create topics and SCRAM
credentials when ACLs are enabled for a system test. These ACLs were missed
for system tests in the PR for KAFKA-10131
(https
gardnervickers commented on pull request #7929:
URL: https://github.com/apache/kafka/pull/7929#issuecomment-703966954
@junrao I was able to get some more time to pick this back up, apologies for
the long gap in time since my last update.
In the most recent commit, I've moved away fro
kkonstantine merged pull request #9320:
URL: https://github.com/apache/kafka/pull/9320
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
hachikuji commented on a change in pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#discussion_r499939576
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java
##
@@ -2358,6 +2359,41 @@ public void testForceShutdownWi
hachikuji merged pull request #9377:
URL: https://github.com/apache/kafka/pull/9377
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
bbejeck commented on pull request #9099:
URL: https://github.com/apache/kafka/pull/9099#issuecomment-703947094
>Do I need to do anything on this?
@badaiaqrandista, nope as soon as we can get a green build, I'll merge it.
--
badaiaqrandista commented on pull request #9099:
URL: https://github.com/apache/kafka/pull/9099#issuecomment-703939623
@bbejeck Do I need to do anything on this?
This is an automated message from the Apache Git Service.
To re
bbejeck commented on pull request #9099:
URL: https://github.com/apache/kafka/pull/9099#issuecomment-703928924
Java 11 and Java 15 passed.
Java 8 failed with
`org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest.shouldRestoreState`
known flaky test.
--
[
https://issues.apache.org/jira/browse/KAFKA-10405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208393#comment-17208393
]
Bill Bejeck commented on KAFKA-10405:
-
Saw same error again -
https://github.com/ap
bbejeck commented on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-703926657
Note the tests for JDK 11 passed
(https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-9237/12/?cloudbees-analytics-link=scm-reporting%2Fstage%2Fpending)
but the job isn't e
bbejeck commented on a change in pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#discussion_r499908753
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationIntegrationTest.java
##
@@ -0,0 +1,256 @@
+/*
+
guozhangwang merged pull request #9342:
URL: https://github.com/apache/kafka/pull/9342
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
guozhangwang commented on pull request #9377:
URL: https://github.com/apache/kafka/pull/9377#issuecomment-703906935
LGTM!
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208344#comment-17208344
]
Kyle Leiby commented on KAFKA-7421:
---
Hi all, we've been encountering a similar deadlock
hachikuji opened a new pull request #9377:
URL: https://github.com/apache/kafka/pull/9377
To avoid confusion since is only used by `TestRaftServer`, this PR moves
`RaftRequestHandler` to the `tools` package.
### Committer Checklist (excluded from commit message)
- [ ] Verify desig
hachikuji merged pull request #9349:
URL: https://github.com/apache/kafka/pull/9349
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
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208316#comment-17208316
]
Sophie Blee-Goldman commented on KAFKA-5998:
[~sandeep.lakdaw...@gmail.com] a
hachikuji opened a new pull request #9376:
URL: https://github.com/apache/kafka/pull/9376
This field is leftover from the early days of the KIP when it covered
reassignment. Since the API is not exposed yet, should be no harm updating the
first version.
### Committer Checklist (excl
wcarlson5 commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499871426
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -364,6 +368,62 @@ public void setUncaughtExceptionHandler(final
Thre
wcarlson5 commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499871031
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -436,6 +496,8 @@ private void maybeSetError() {
}
wcarlson5 commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499868891
##
File path:
streams/src/main/java/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apac
vvcephei commented on pull request #8353:
URL: https://github.com/apache/kafka/pull/8353#issuecomment-703874939
Cherry-picked to 2.4 and 2.3
This is an automated message from the Apache Git Service.
To respond to the message,
kowshik edited a comment on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-703873486
@junrao Thanks for the review! I've addressed the latest comments in
e55358fd1a00f12ef98fc4d2d649a297ddf146da . The PR is ready for another pass.
-
kowshik commented on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-703873486
@junrao Thanks for the review! I've addressed the latest comments in
e55358fd1a00f12ef98fc4d2d649a297ddf146da .
T
vvcephei commented on pull request #8353:
URL: https://github.com/apache/kafka/pull/8353#issuecomment-703869908
cherry-picked to 2.5
This is an automated message from the Apache Git Service.
To respond to the message, please
vvcephei commented on pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#issuecomment-703867931
Cherry-picked to 2.6
This is an automated message from the Apache Git Service.
To respond to the message, please
vvcephei commented on pull request #9323:
URL: https://github.com/apache/kafka/pull/9323#issuecomment-703867815
Cherry-picked to 2.6
This is an automated message from the Apache Git Service.
To respond to the message, please
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499847021
##
File path:
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala
##
@@ -715,7 +747,58 @@ class ControllerIntegrationTest extends
Zo
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499843780
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -616,7 +616,7 @@ public void
shouldThrowExceptionSettingUncaughtE
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499842547
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -436,6 +496,8 @@ private void maybeSetError() {
}
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499842547
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -436,6 +496,8 @@ private void maybeSetError() {
}
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499838819
##
File path:
streams/src/main/java/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apach
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499836489
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -364,6 +368,62 @@ public void setUncaughtExceptionHandler(final
Threa
[
https://issues.apache.org/jira/browse/KAFKA-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10531:
--
Fix Version/s: 2.5.2
2.7.0
> KafkaBasedLog can sleep for negative values
>
dima5rr commented on pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#issuecomment-703838454
Hi @guozhangwang can you trigger new build, looks like flaky tests?
This is an automated message from the Apache G
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499816619
##
File path: core/src/test/scala/unit/kafka/server/UpdateFeaturesTest.scala
##
@@ -0,0 +1,580 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499816373
##
File path: core/src/test/scala/unit/kafka/server/UpdateFeaturesTest.scala
##
@@ -0,0 +1,580 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499812076
##
File path: core/src/test/scala/unit/kafka/server/UpdateFeaturesTest.scala
##
@@ -0,0 +1,580 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
rhauch merged pull request #9347:
URL: https://github.com/apache/kafka/pull/9347
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
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499811752
##
File path: core/src/test/scala/unit/kafka/cluster/BrokerEndPointTest.scala
##
@@ -185,7 +185,7 @@ class BrokerEndPointTest {
"endpoints":["CLIENT:
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499811265
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,161 @@ class KafkaController(val config: KafkaConfig,
}
}
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499810462
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,161 @@ class KafkaController(val config: KafkaConfig,
}
}
[
https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10559:
---
Assignee: Sagar Rao
> Don't shutdown the entire app upon TimeoutException d
piotrrzysko commented on pull request #9371:
URL: https://github.com/apache/kafka/pull/9371#issuecomment-703823226
Hi @stanislavkozlovski, would you mind taking a look at this PR?
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208257#comment-17208257
]
Sophie Blee-Goldman commented on KAFKA-10559:
-
[~sagarrao] Yeah, go ahead! T
soondenana commented on pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#issuecomment-703805880
There was an error when building `streams.examples`:
```
[2020-10-05T08:40:05.722Z] [ERROR] Failed to execute goal
org.apache.maven.plugins:maven-archetype-plugin:3.2.
bbejeck commented on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-703803731
@lkokhreidze, thanks for the quick update. I'll make another pass soon.
This is an automated message from the Apac
junrao commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499753420
##
File path: core/src/test/scala/unit/kafka/cluster/BrokerEndPointTest.scala
##
@@ -185,7 +185,7 @@ class BrokerEndPointTest {
"endpoints":["CLIENT:/
[
https://issues.apache.org/jira/browse/KAFKA-9585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-9585.
--
Resolution: Cannot Reproduce
> Flaky Test:
> LagFetchIntegrationTest#shouldFetchLagsDuringReba
[
https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208231#comment-17208231
]
Sophie Blee-Goldman commented on KAFKA-10555:
-
Just to clarify, I do agree w
[
https://issues.apache.org/jira/browse/KAFKA-10530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10530.
--
Resolution: Duplicate
Closing now, since this seems like a duplicate report, and visual code
[
https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10562:
-
Summary: KIP-478: Delegate the store wrappers to the new init method (was:
Delegate the store w
[
https://issues.apache.org/jira/browse/KAFKA-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10546:
-
Component/s: streams
> KIP-478: Deprecate old PAPI
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10544:
-
Component/s: streams
> Convert KTable aggregations to new PAPI
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10562:
-
Component/s: streams
> Delegate the store wrappers to the new init method
>
[
https://issues.apache.org/jira/browse/KAFKA-10539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10539:
-
Component/s: streams
> Convert KStreamImpl joins to new PAPI
> -
[
https://issues.apache.org/jira/browse/KAFKA-10538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10538:
-
Component/s: streams
> Convert KStreamImpl maps to new PAPI
> --
[
https://issues.apache.org/jira/browse/KAFKA-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10540:
-
Component/s: streams
> Convert KStream aggregations to new PAPI
> --
[
https://issues.apache.org/jira/browse/KAFKA-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10542:
-
Component/s: streams
> Convert KTable maps to new PAPI
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10543:
-
Component/s: streams
> Convert KTable joins to new PAPI
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10541:
-
Component/s: streams
> Convert KTable filters to new PAPI
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-10537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10537:
-
Component/s: streams
> Convert KStreamImpl filters to new PAPI
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10536:
-
Fix Version/s: 2.7.0
> KIP-478: Implement KStream changes
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-10536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10536:
-
Component/s: streams
> KIP-478: Implement KStream changes
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-10535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10535:
-
Fix Version/s: 2.7.0
> KIP-478: Implement StateStoreContext and Record
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10535.
--
Resolution: Fixed
> KIP-478: Implement StateStoreContext and Record
>
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10437:
-
Fix Version/s: 2.7.0
> KIP-478: Implement test-utils changes
> -
[
https://issues.apache.org/jira/browse/KAFKA-10535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10535:
-
Component/s: streams
> KIP-478: Implement StateStoreContext and Record
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10437:
-
Component/s: streams
> KIP-478: Implement test-utils changes
> -
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10437:
-
Component/s: (was: streams-test-utils)
> KIP-478: Implement test-utils changes
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10437:
-
Component/s: streams-test-utils
> KIP-478: Implement test-utils changes
> --
[
https://issues.apache.org/jira/browse/KAFKA-10436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10436:
-
Component/s: streams
> Implement KIP-478 Topology changes
> --
>
C0urante commented on pull request #9375:
URL: https://github.com/apache/kafka/pull/9375#issuecomment-703775022
Thanks @kkonstantine, I've added a comment and addressed the Checkstyle
issues.
This is an automated message fro
C0urante commented on a change in pull request #9375:
URL: https://github.com/apache/kafka/pull/9375#discussion_r499754411
##
File path:
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java
##
@@ -73,6 +76,15 @@
INT_LIST.add(-987654321);
}
+
C0urante commented on a change in pull request #9375:
URL: https://github.com/apache/kafka/pull/9375#discussion_r499754411
##
File path:
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java
##
@@ -73,6 +76,15 @@
INT_LIST.add(-987654321);
}
+
kkonstantine commented on a change in pull request #9375:
URL: https://github.com/apache/kafka/pull/9375#discussion_r499750739
##
File path:
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java
##
@@ -73,6 +76,15 @@
INT_LIST.add(-987654321);
}
[
https://issues.apache.org/jira/browse/KAFKA-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-7334:
---
Labels: newbie (was: )
> Suggest changing config for state.dir in case of FileNotFou
[
https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208194#comment-17208194
]
Sagar Rao commented on KAFKA-10559:
---
hey [~ableegoldman], I can pick this one if neede
lkokhreidze commented on a change in pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#discussion_r485886423
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationIntegrationTest.java
##
@@ -0,0 +1,242 @@
+
1 - 100 of 131 matches
Mail list logo
