ableegoldman merged PR #12288:
URL: https://github.com/apache/kafka/pull/12288
--
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...@kafka.ap
ableegoldman commented on PR #12288:
URL: https://github.com/apache/kafka/pull/12288#issuecomment-1154724371
Failing tests are unrelated:
`testIncrementalAlterConfigs() – kafka.server.KRaftClusterTest`
`testFailureToFenceEpoch(String).quorum=kraft – kafka.api.TransactionsTest`
Me
C0urante commented on code in PR #12281:
URL: https://github.com/apache/kafka/pull/12281#discussion_r896319034
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java:
##
@@ -222,14 +222,10 @@ protected PluginClassLoader newPluginCl
hachikuji commented on code in PR #12181:
URL: https://github.com/apache/kafka/pull/12181#discussion_r896305171
##
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala:
##
@@ -846,6 +862,135 @@ class ControllerIntegrationTest extends QuorumTestHarness
{
C0urante commented on PR #12291:
URL: https://github.com/apache/kafka/pull/12291#issuecomment-1154607749
@cadonna this is a follow-up from the earlier work in
https://github.com/apache/kafka/pull/12191. It's not urgent but it should help
reduce some flakiness; if you have time would you min
C0urante opened a new pull request, #12291:
URL: https://github.com/apache/kafka/pull/12291
This causes the artificial reductions in the Connect REST request timeout to
be more isolated. Specifically, they now only take place in the tests that need
them (instead of any tests that happen to
Chris Egerton created KAFKA-13987:
-
Summary: BlockingConnectorTest causing flakiness in other tests
Key: KAFKA-13987
URL: https://issues.apache.org/jira/browse/KAFKA-13987
Project: Kafka
Issu
C0urante opened a new pull request, #12290:
URL: https://github.com/apache/kafka/pull/12290
These tests currently create threads that block forever until the JVM is
shut down. This change unblocks those threads once their respective test cases
are finished.
This is valuable not only
artemlivshits commented on code in PR #12181:
URL: https://github.com/apache/kafka/pull/12181#discussion_r896208216
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -1569,24 +1628,47 @@ class Partition(val topicPartition: TopicPartition,
): Boolean = {
alterPa
hachikuji commented on PR #12206:
URL: https://github.com/apache/kafka/pull/12206#issuecomment-1154541770
@niket-goel It looks like we are running into
https://issues.apache.org/jira/browse/KAFKA-13940, which is causing the new
integration test to be flaky. I think our options are either to
[
https://issues.apache.org/jira/browse/KAFKA-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13984:
---
Summary: Fix TopicBasedRemoteLogMetadataManager#initializeResources should
exit immediately when partition s
C0urante commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r896236376
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java:
##
@@ -16,56 +16,322 @@
*/
package org.apache.kafka.connect.stora
C0urante commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r896234648
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1327,30 +1334,39 @@ public WorkerTask doBuild(Task task,
conn
C0urante commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r896234734
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java:
##
@@ -16,56 +16,322 @@
*/
package org.apache.kafka.connect.stora
[
https://issues.apache.org/jira/browse/KAFKA-13986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niket Goel reassigned KAFKA-13986:
--
Assignee: Niket Goel
> DescribeQuorum does not return the observers (brokers) for the Metadat
niket-goel commented on PR #12206:
URL: https://github.com/apache/kafka/pull/12206#issuecomment-1154525501
Thanks @hachikuji . I have created
https://issues.apache.org/jira/browse/KAFKA-13986 for the observer count issue
and will raise a PR once this one is merged
--
This is an automated
[
https://issues.apache.org/jira/browse/KAFKA-13986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553818#comment-17553818
]
Niket Goel commented on KAFKA-13986:
The fix should be something on the lines of:
{c
[
https://issues.apache.org/jira/browse/KAFKA-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553814#comment-17553814
]
A. Sophie Blee-Goldman commented on KAFKA-10121:
Bumping this up to 'Cri
[
https://issues.apache.org/jira/browse/KAFKA-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-10121:
---
Priority: Critical (was: Minor)
> Streams Task Assignment optimization desi
[
https://issues.apache.org/jira/browse/KAFKA-12639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553811#comment-17553811
]
Guozhang Wang commented on KAFKA-12639:
---
This is a separate issue, as `joinGroupIf
[
https://issues.apache.org/jira/browse/KAFKA-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553810#comment-17553810
]
Matthew de Detrich commented on KAFKA-13957:
I have fixed the test at https:
mdedetrich opened a new pull request, #12289:
URL: https://github.com/apache/kafka/pull/12289
Previously the tests would fail even on retryable errors. This change adds a
retryUntil similar to the current until method however it will retry the test
if it throws an exception that passes a pr
hachikuji commented on PR #12206:
URL: https://github.com/apache/kafka/pull/12206#issuecomment-1154495677
@dajac I think this is the reason there are no observers:
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/raft/RaftManager.scala#L188.
We should just use `config.no
ableegoldman opened a new pull request, #12288:
URL: https://github.com/apache/kafka/pull/12288
Minor followup to #12235 that adds a null check on the record key in the
new ClientUtils#producerRecordSizeInBytes utility method, as there are valid
cases in which we might be sending records w
[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553806#comment-17553806
]
Guozhang Wang commented on KAFKA-10575:
---
I took another look at this ticket while
ableegoldman commented on code in PR #12235:
URL: https://github.com/apache/kafka/pull/12235#discussion_r896155831
##
streams/src/test/java/org/apache/kafka/test/MockRecordCollector.java:
##
@@ -46,13 +47,15 @@ public void send(final String topic,
f
Niket Goel created KAFKA-13986:
--
Summary: DescribeQuorum does not return the observers (brokers)
for the Metadata log
Key: KAFKA-13986
URL: https://issues.apache.org/jira/browse/KAFKA-13986
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10575:
--
Labels: (was: new-streams-runtime-should-fix)
> StateRestoreListener#onRestoreEnd should alw
[
https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10199:
--
Labels: (was: new-streams-runtime-should-fix)
> Separate state restoration into separate thr
[
https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10199:
--
Labels: new-streams-runtime-should-fix (was: )
> Separate state restoration into separate thr
guozhangwang commented on code in PR #12287:
URL: https://github.com/apache/kafka/pull/12287#discussion_r896037230
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java:
##
@@ -502,9 +502,8 @@ public void addStoreLevelMutableMetri
guozhangwang commented on PR #12287:
URL: https://github.com/apache/kafka/pull/12287#issuecomment-1154265926
cc @vamossagar12 @cadonna
--
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 specifi
guozhangwang opened a new pull request, #12287:
URL: https://github.com/apache/kafka/pull/12287
Use the newly added function to replace the old `addMetric` function that
may throw illegal argument exceptions.
Although in some cases concurrency should not be possible they do not
neces
mumrah merged PR #12250:
URL: https://github.com/apache/kafka/pull/12250
--
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...@kafka.apache.o
hachikuji commented on code in PR #12250:
URL: https://github.com/apache/kafka/pull/12250#discussion_r895992684
##
core/src/test/scala/unit/kafka/server/KafkaRaftServerTest.scala:
##
@@ -215,4 +223,47 @@ class KafkaRaftServerTest {
() => KafkaRaftServer.initializeLogDirs(
niket-goel commented on PR #12206:
URL: https://github.com/apache/kafka/pull/12206#issuecomment-1154209076
Thanks for the in-depth review @dajac @hachikuji and @dengziming. I have
updated the PR with the final NITs from @dajac fixed. Are we good to merge with
1 LGTM or do we need 1 more?
guozhangwang merged PR #12121:
URL: https://github.com/apache/kafka/pull/12121
--
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...@kafka.ap
guozhangwang commented on code in PR #12121:
URL: https://github.com/apache/kafka/pull/12121#discussion_r895970308
##
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java:
##
@@ -509,7 +509,10 @@ public void addMetric(MetricName metricName, MetricConfig
config, Me
[
https://issues.apache.org/jira/browse/KAFKA-8713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553724#comment-17553724
]
Cheng Pan commented on KAFKA-8713:
--
Thanks [~rotem-ad], I'm sorry I haven't worked in th
[
https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacopo Riciputi updated KAFKA-13985:
Description:
Applying a SMT that filters out messages it can brings to enter in this path:
[
https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacopo Riciputi updated KAFKA-13985:
Description:
Applying a SMT that filters out messages it can brings to enter in this path:
[
https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacopo Riciputi updated KAFKA-13985:
Description:
Applying a SMT that filters out messages it can brings to enter in this path:
tombentley commented on code in PR #11781:
URL: https://github.com/apache/kafka/pull/11781#discussion_r895874082
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1327,30 +1334,39 @@ public WorkerTask doBuild(Task task,
co
hachikuji commented on PR #12274:
URL: https://github.com/apache/kafka/pull/12274#issuecomment-1154107684
@dengziming The difference is that advancing the high watermark would then
be the trigger for fulfilling the Fetch. If the observer does not have the
latest high watermark, then it mean
mimaison merged PR #12283:
URL: https://github.com/apache/kafka/pull/12283
--
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...@kafka.apache
ijuma commented on PR #11261:
URL: https://github.com/apache/kafka/pull/11261#issuecomment-1154058710
Thanks!
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fathima Khazana Abdul Haiyum updated KAFKA-13979:
-
Description:
We have 3 nodes in our MSK cluster which run Apache
divijvaidya commented on PR #12283:
URL: https://github.com/apache/kafka/pull/12283#issuecomment-1154035937
@mimaison perhaps you could review this quick code change?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
mimaison commented on PR #12285:
URL: https://github.com/apache/kafka/pull/12285#issuecomment-1154027464
Thanks for the PR!
Since this PR only touches Streams, I'll let committers focused on Streams
review it.
--
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/KAFKA-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reopened KAFKA-13414:
My PR only updated some of the classes under connect.storage. The following
files still need
[
https://issues.apache.org/jira/browse/KAFKA-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553626#comment-17553626
]
Mickael Maison commented on KAFKA-13414:
Feel free to grab the ticket if it's so
[
https://issues.apache.org/jira/browse/KAFKA-13436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-13436.
Fix Version/s: 3.3.0
Resolution: Fixed
> Omitted BrokerTopicMetrics metrics in the
mimaison merged PR #11473:
URL: https://github.com/apache/kafka/pull/11473
--
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...@kafka.apache
dajac commented on code in PR #12206:
URL: https://github.com/apache/kafka/pull/12206#discussion_r895790891
##
clients/src/main/java/org/apache/kafka/clients/admin/QuorumInfo.java:
##
@@ -0,0 +1,153 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
dengziming commented on code in PR #12265:
URL: https://github.com/apache/kafka/pull/12265#discussion_r895799683
##
core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala:
##
@@ -244,6 +248,9 @@ class BrokerMetadataListener(
_publisher = Some(publisher)
[
https://issues.apache.org/jira/browse/KAFKA-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553613#comment-17553613
]
Matias Cascallares commented on KAFKA-13983:
Would it be possible to add a m
mimaison merged PR #11780:
URL: https://github.com/apache/kafka/pull/11780
--
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...@kafka.apache
dengziming commented on PR #12274:
URL: https://github.com/apache/kafka/pull/12274#issuecomment-1153977501
> I think we should increase the `MetadataMaxIdleIntervalMs` to something
like 800ms or 1000ms
@showuon Neither changing `MetadataMaxIdleIntervalMs` nor changing
`KafkaRaftClien
dengziming commented on PR #12274:
URL: https://github.com/apache/kafka/pull/12274#issuecomment-1153971776
> only letting observers fetch up to the high watermark
@hachikuji Not sure did I understand correctly, the problem is that observer
HW is always less than leader HW because the
dengziming commented on PR #11261:
URL: https://github.com/apache/kafka/pull/11261#issuecomment-1153951329
> Was this fixed some other way?
No, there are too many conflicts, I split this PR into 2 PRs, #12157 and
#11784.
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacopo updated KAFKA-13985:
---
Description:
Applying a SMT that filter message it can laverage to enter in this if:
>From WorkerSourceT
[
https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacopo updated KAFKA-13985:
---
Description:
Applying a SMT that filter message it can laverage to enter in this if:
>From WorkerSourceT
[
https://issues.apache.org/jira/browse/KAFKA-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13984:
---
Summary: Fix TopicBasedRemoteLogMetadataManager#initializeResources should
exit immediately when partition n
[
https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacopo updated KAFKA-13985:
---
Description:
Applying a SMT that filter message it can laverage to enter in this if:
>From WorkerSourceT
Jacopo created KAFKA-13985:
--
Summary: MirrorSourceTask commitRecord throws NPE if SMT is
filtering out source record
Key: KAFKA-13985
URL: https://issues.apache.org/jira/browse/KAFKA-13985
Project: Kafka
bozhao12 opened a new pull request, #12286:
URL: https://github.com/apache/kafka/pull/12286
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
[
https://issues.apache.org/jira/browse/KAFKA-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553562#comment-17553562
]
Matthew de Detrich commented on KAFKA-13957:
I am working on this issue, I m
[
https://issues.apache.org/jira/browse/KAFKA-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthew de Detrich reassigned KAFKA-13957:
--
Assignee: Matthew de Detrich
> Flaky Test StoreQueryIntegrationTest.shouldQue
[
https://issues.apache.org/jira/browse/KAFKA-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13984:
---
Description:
When executing {*}TopicBasedRemoteLogMetadataManager.initializeResources(){*},
if the result
[
https://issues.apache.org/jira/browse/KAFKA-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaobo updated KAFKA-13984:
---
Description:
When executing {*}TopicBasedRemoteLogMetadataManager.initializeResources(){*},
if the result
zhaobo created KAFKA-13984:
--
Summary: Fix
TopicBasedRemoteLogMetadataManager#initializeResources should return
immediately when the result of isPartitionsCountSameAsConfigured method is false
Key: KAFKA-13984
URL: https
cadonna commented on code in PR #10881:
URL: https://github.com/apache/kafka/pull/10881#discussion_r895663246
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNodeTest.java:
##
@@ -23,43 +23,32 @@
import org.apache.kafka.streams.kstream.inter
[
https://issues.apache.org/jira/browse/KAFKA-8713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553550#comment-17553550
]
Rotem Adhoh commented on KAFKA-8713:
[~pan3793] This exact same bug exists in Conflue
cadonna commented on code in PR #12161:
URL: https://github.com/apache/kafka/pull/12161#discussion_r895651419
##
streams/src/test/java/org/apache/kafka/streams/integration/PauseResumeIntegrationTest.java:
##
@@ -0,0 +1,380 @@
+/*
+ * Licensed to the Apache Software Foundation (A
liuzhuang2017 commented on PR #12272:
URL: https://github.com/apache/kafka/pull/12272#issuecomment-1153833490
@[guozhangwang](https://github.com/guozhangwang), Sorry to bother you, can
you help me review this pr? Thank you.
--
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/KAFKA-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aman Singh updated KAFKA-13983:
---
Description:
Currently, resource names in ACLS can contain any special characters, but
resource nam
[
https://issues.apache.org/jira/browse/KAFKA-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aman Singh updated KAFKA-13983:
---
Issue Type: Bug (was: Improvement)
> Support special character in Resource name in ACLs operation b
[
https://issues.apache.org/jira/browse/KAFKA-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aman Singh updated KAFKA-13983:
---
Description:
Currently, resource names in ACLS can contain any special characters, but
resource nam
Aman Singh created KAFKA-13983:
--
Summary: Support special character in Resource name in ACLs
operation by sanitizing
Key: KAFKA-13983
URL: https://issues.apache.org/jira/browse/KAFKA-13983
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-13967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13967:
---
Fix Version/s: 3.3.0
> Guarantees for producer callbacks on transaction commit should be doc
[
https://issues.apache.org/jira/browse/KAFKA-13967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13967:
---
Fix Version/s: 3.3
> Guarantees for producer callbacks on transaction commit should be docum
tombentley commented on code in PR #12045:
URL: https://github.com/apache/kafka/pull/12045#discussion_r895546403
##
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java:
##
@@ -34,35 +35,56 @@
*/
public abstract class SampledStat implements MeasurableS
[
https://issues.apache.org/jira/browse/KAFKA-13967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13967:
---
Fix Version/s: (was: 3.3)
> Guarantees for producer callbacks on transaction commit shou
jnh5y commented on code in PR #12161:
URL: https://github.com/apache/kafka/pull/12161#discussion_r895578928
##
streams/src/test/java/org/apache/kafka/streams/integration/PauseResumeIntegrationTest.java:
##
@@ -0,0 +1,380 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
cadonna commented on code in PR #12161:
URL: https://github.com/apache/kafka/pull/12161#discussion_r895564024
##
streams/src/test/java/org/apache/kafka/streams/integration/PauseResumeIntegrationTest.java:
##
@@ -0,0 +1,380 @@
+/*
+ * Licensed to the Apache Software Foundation (A
cadonna commented on code in PR #12161:
URL: https://github.com/apache/kafka/pull/12161#discussion_r89390
##
streams/src/test/java/org/apache/kafka/streams/integration/PauseResumeIntegrationTest.java:
##
@@ -0,0 +1,380 @@
+/*
+ * Licensed to the Apache Software Foundation (A
cadonna commented on code in PR #12161:
URL: https://github.com/apache/kafka/pull/12161#discussion_r895542975
##
streams/src/test/java/org/apache/kafka/streams/integration/PauseResumeIntegrationTest.java:
##
@@ -0,0 +1,380 @@
+/*
+ * Licensed to the Apache Software Foundation (A
[
https://issues.apache.org/jira/browse/KAFKA-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-13982:
--
Labels: connect (was: )
> Replace EasyMock and PowerMock with Mockito for WorkerConfigTransfo
[
https://issues.apache.org/jira/browse/KAFKA-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-13982:
--
Description: I believe the file
connect/runtime/src/test/java/org/apache/kafka/connect/runtime
[
https://issues.apache.org/jira/browse/KAFKA-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov reassigned KAFKA-13982:
-
Assignee: Christo Lolov
> Replace EasyMock and PowerMock with Mockito for WorkerConfigT
Christo Lolov created KAFKA-13982:
-
Summary: Replace EasyMock and PowerMock with Mockito for
WorkerConfigTransformerTest
Key: KAFKA-13982
URL: https://issues.apache.org/jira/browse/KAFKA-13982
Project
clolov commented on PR #10881:
URL: https://github.com/apache/kafka/pull/10881#issuecomment-1153680218
Hello @ijuma, @ableegoldman, @wycc! I have been working on trying to
upgrade Kafka Streams from JUnit 4 to JUnit 5 and I was wondering what is the
state of this pull request and all th
[
https://issues.apache.org/jira/browse/KAFKA-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553474#comment-17553474
]
Christo Lolov commented on KAFKA-13414:
---
Hello [~mimaison]! I have resolved this i
[
https://issues.apache.org/jira/browse/KAFKA-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov resolved KAFKA-13414.
---
Resolution: Fixed
> Replace Powermock/EasyMock by Mockito in connect.storage package
> -
clolov commented on PR #12285:
URL: https://github.com/apache/kafka/pull/12285#issuecomment-1153573803
Okay, I will work on 1 and 3, thank you for the review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
[
https://issues.apache.org/jira/browse/KAFKA-7342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov reassigned KAFKA-7342:
Assignee: Christo Lolov (was: Chia-Ping Tsai)
> Migrate streams modules to JUnit 5
>
96 matches
Mail list logo
