[
https://issues.apache.org/jira/browse/KAFKA-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10143:
Description:
Previously we could use --execute with the --throttle option in order to
aakashnshah commented on pull request #8829:
URL: https://github.com/apache/kafka/pull/8829#issuecomment-642418469
I've updated the KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-610%3A+Error+Reporting+in+Sink+Connectors
@rhauch @wicknicks
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9216.
--
Reviewer: Randall Hauch
Resolution: Fixed
Merged to `trunk` the second PR that enforces
[
https://issues.apache.org/jira/browse/KAFKA-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9845.
--
Fix Version/s: 2.7.0
Reviewer: Randall Hauch
Resolution: Fixed
Merged to
[
https://issues.apache.org/jira/browse/KAFKA-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-6942.
--
Resolution: Invalid
I'm going to close this as INVALID because the versions are available in
kkonstantine commented on pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#issuecomment-642405060
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
kkonstantine commented on pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#issuecomment-642404708
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log
kkonstantine commented on pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#issuecomment-642404597
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
C0urante commented on pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#issuecomment-642402730
I believe I've identified the cause of the failure in
https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/1048. I've pushed a new
commit to fix the logic; it passed tests
[
https://issues.apache.org/jira/browse/KAFKA-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-10115.
---
Reviewer: Randall Hauch
Resolution: Fixed
Merged to `2.6` rather than `trunk`
[
https://issues.apache.org/jira/browse/KAFKA-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9066.
--
Fix Version/s: 2.7.0
Reviewer: Randall Hauch
Resolution: Fixed
Merged to
vvcephei commented on a change in pull request #8851:
URL: https://github.com/apache/kafka/pull/8851#discussion_r438533186
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -959,28 +992,23 @@ private void
mjsax commented on pull request #8851:
URL: https://github.com/apache/kafka/pull/8851#issuecomment-642396153
Closing in favor of #8852
This is an automated message from the Apache Git Service.
To respond to the message,
mjsax closed pull request #8851:
URL: https://github.com/apache/kafka/pull/8851
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
mjsax commented on a change in pull request #8852:
URL: https://github.com/apache/kafka/pull/8852#discussion_r438533555
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -116,89 +112,100 @@ public boolean isValidTransition(final
mjsax commented on a change in pull request #8852:
URL: https://github.com/apache/kafka/pull/8852#discussion_r438533429
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -97,13 +97,9 @@ public boolean isValidTransition(final
mjsax commented on a change in pull request #8852:
URL: https://github.com/apache/kafka/pull/8852#discussion_r438533374
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -57,30 +59,31 @@
* @param stateDirectory the
mjsax commented on a change in pull request #8852:
URL: https://github.com/apache/kafka/pull/8852#discussion_r438533205
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
##
@@ -16,82 +16,85 @@
*/
package
mjsax commented on a change in pull request #8852:
URL: https://github.com/apache/kafka/pull/8852#discussion_r438533174
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
##
@@ -16,82 +16,85 @@
*/
package
mjsax opened a new pull request #8852:
URL: https://github.com/apache/kafka/pull/8852
Not functional change. Pure code cleanup
Call for review @vvcephei
This is an automated message from the Apache Git Service.
To
brary commented on pull request #8200:
URL: https://github.com/apache/kafka/pull/8200#issuecomment-642394605
LGTM!
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642394105
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on a change in pull request #8851:
URL: https://github.com/apache/kafka/pull/8851#discussion_r438531936
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -116,89 +112,100 @@ public boolean isValidTransition(final
mjsax commented on a change in pull request #8851:
URL: https://github.com/apache/kafka/pull/8851#discussion_r438531698
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -97,13 +97,9 @@ public boolean isValidTransition(final
mjsax commented on a change in pull request #8851:
URL: https://github.com/apache/kafka/pull/8851#discussion_r438531571
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -97,13 +97,9 @@ public boolean isValidTransition(final
brary commented on a change in pull request #8200:
URL: https://github.com/apache/kafka/pull/8200#discussion_r438531599
##
File path:
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java
##
@@ -18,13 +18,11 @@
/**
- * Indicates that there
[
https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132901#comment-17132901
]
Yu Wang commented on KAFKA-9841:
Thank you for checking [~vvcephei] and thank you for your help
mjsax commented on a change in pull request #8851:
URL: https://github.com/apache/kafka/pull/8851#discussion_r438531045
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
##
@@ -16,82 +16,85 @@
*/
package
[
https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132899#comment-17132899
]
Rohan Kulkarni commented on KAFKA-9270:
---
[~mjsax] - Sure. I will track the other issue KAFKA-9274
Randall Hauch created KAFKA-10146:
-
Summary: Backport KAFKA-9066 to 2.5 and 2.4 branches
Key: KAFKA-10146
URL: https://issues.apache.org/jira/browse/KAFKA-10146
Project: Kafka
Issue Type:
mjsax opened a new pull request #8851:
URL: https://github.com/apache/kafka/pull/8851
Not functional change. Pure code cleanup
Call for review @vvcephei
This is an automated message from the Apache Git Service.
To
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642392428
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642391750
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642391773
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642391327
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642391433
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642391252
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
C0urante commented on pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#issuecomment-642390162
Fixed the merge conflicts; should be safe to do a new test run now.
This is an automated message from the Apache
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642388373
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642388044
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642387968
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642387910
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
rhauch merged pull request #8829:
URL: https://github.com/apache/kafka/pull/8829
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-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10086:
-
Description:
This ticket was initially just to write an integration test, but I escalated it
vitojeng commented on pull request #8200:
URL: https://github.com/apache/kafka/pull/8200#issuecomment-642387584
Got it!
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-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132887#comment-17132887
]
Randall Hauch commented on KAFKA-9216:
--
Thanks, [~ChrisEgerton]. I think we came to consensus on the
rhauch merged pull request #8828:
URL: https://github.com/apache/kafka/pull/8828
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-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10086:
-
Description:
This ticket was initially just to write an integration test, but I escalated it
kkonstantine commented on pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#issuecomment-642386762
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
ableegoldman commented on a change in pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#discussion_r438524798
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -137,7 +137,7 @@ public void resume() {
[
https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10086:
-
Summary: Standby state isn't always re-used when transitioning to active
(was: Cooperative
[
https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10086:
-
Summary: Cooperative Rebalance causes standby state not to be re-used when
transitioning to
[
https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10086:
-
Description:
This ticket was initially just to write an integration test, but I escalated it
[
https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10086:
-
Priority: Blocker (was: Critical)
> Write Integration Test for
ableegoldman commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642386255
Alright, tests/checkstyle/etc are all ready for the builds to be triggered
This is an automated message from
skaundinya15 opened a new pull request #8850:
URL: https://github.com/apache/kafka/pull/8850
As specified in https://issues.apache.org/jira/browse/KAFKA-10141, it would
be helpful to include as much information as possible when deleting log
segments. This patch introduces log messages
[
https://issues.apache.org/jira/browse/KAFKA-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9066:
-
Fix Version/s: 2.6.0
> Kafka Connect JMX : source & sink task metrics missing for tasks in
rhauch commented on a change in pull request #8828:
URL: https://github.com/apache/kafka/pull/8828#discussion_r438521713
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java
##
@@ -375,6 +383,162 @@ public boolean createTopic(NewTopic
[
https://issues.apache.org/jira/browse/KAFKA-9653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-9653.
---
Resolution: Duplicate
> Duplicate tasks on workers after rebalance
>
[
https://issues.apache.org/jira/browse/KAFKA-9653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9653:
--
Fix Version/s: 2.5.1
2.4.2
2.6.0
[
https://issues.apache.org/jira/browse/KAFKA-9653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132876#comment-17132876
]
Konstantine Karantasis commented on KAFKA-9653:
---
Closing this issue as fixed but also
[
https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132874#comment-17132874
]
Konstantine Karantasis commented on KAFKA-9841:
---
This fix is now merged. Seems it can make
mjsax commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642381041
Btw: checkstyle failed :)
This is an automated message from the Apache Git Service.
To respond to the message,
mjsax commented on pull request #8847:
URL: https://github.com/apache/kafka/pull/8847#issuecomment-642380670
Merged to `trunk` and cherry-picked to `2.6` branch.
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9845:
-
Fix Version/s: 2.5.1
2.4.2
2.6.0
> plugin.path property
lqjacklee created KAFKA-10145:
-
Summary: Enhance to support the multiple join operation
Key: KAFKA-10145
URL: https://issues.apache.org/jira/browse/KAFKA-10145
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9985:
-
Fix Version/s: (was: 2.5.2)
2.5.1
> Sink connector consuming DLQ topic
[
https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-9841:
--
Fix Version/s: 2.4.2
2.6.0
2.3.2
>
rhauch merged pull request #8455:
URL: https://github.com/apache/kafka/pull/8455
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
mjsax merged pull request #8847:
URL: https://github.com/apache/kafka/pull/8847
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
vvcephei commented on a change in pull request #8818:
URL: https://github.com/apache/kafka/pull/8818#discussion_r438517226
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -86,7 +87,7 @@
private boolean
rhauch merged pull request #8502:
URL: https://github.com/apache/kafka/pull/8502
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
mjsax commented on pull request #8200:
URL: https://github.com/apache/kafka/pull/8200#issuecomment-642377008
@vitojeng -- Jenkins got locked down a couple of week ago. Only committer
can trigger builds now.
This is an
vvcephei commented on pull request #8818:
URL: https://github.com/apache/kafka/pull/8818#issuecomment-642376894
Thanks for the review, @mjsax ; I've addressed your comments.
This is an automated message from the Apache Git
C0urante commented on pull request #8455:
URL: https://github.com/apache/kafka/pull/8455#issuecomment-642375059
@rhauch fine by me, applied the suggestions. Thanks for taking a look!
This is an automated message from the
vvcephei commented on pull request #8835:
URL: https://github.com/apache/kafka/pull/8835#issuecomment-642375091
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642374804
Tests are still a WIP. Just wanted to open it up for input on the problem/fix
This is an automated message
rhauch merged pull request #8848:
URL: https://github.com/apache/kafka/pull/8848
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
mjsax commented on a change in pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#discussion_r438514181
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java
##
@@ -92,7 +92,7 @@ public void createTopics()
rhauch commented on a change in pull request #8455:
URL: https://github.com/apache/kafka/pull/8455#discussion_r438513748
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java
##
@@ -379,6 +382,22 @@ private void
mjsax commented on pull request #8835:
URL: https://github.com/apache/kafka/pull/8835#issuecomment-642373516
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
vvcephei commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642373459
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
kkonstantine commented on pull request #8848:
URL: https://github.com/apache/kafka/pull/8848#issuecomment-642370342
Thanks @rhauch.
This is an automated message from the Apache Git Service.
To respond to the message, please
whsoul commented on pull request #7965:
URL: https://github.com/apache/kafka/pull/7965#issuecomment-642370021
@rhauch thanks rhauch
I already create JIRA issue
(https://issues.apache.org/jira/browse/KAFKA-9436)
but forgot label "needs-kip"... but now added
Thanks~
[
https://issues.apache.org/jira/browse/KAFKA-9436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
whsoul updated KAFKA-9436:
--
Labels: needs-kip (was: )
> New Kafka Connect SMT for plainText => Struct(or Map)
>
rhauch edited a comment on pull request #8502:
URL: https://github.com/apache/kafka/pull/8502#issuecomment-642360742
@C0urante the original PR description doesn't mention that the task metrics
for a failed task will also be removed when the connector is deleted (in
addition to the worker
ableegoldman opened a new pull request #8849:
URL: https://github.com/apache/kafka/pull/8849
We need to make sure that corrupted standby tasks are actually cleaned up
upon a TaskCorruptedException. However due to the `commit` prior to invoking
`handleCorruption`, it's possible to throw a
Sophie Blee-Goldman created KAFKA-10144:
---
Summary: Corrupted standby tasks are not always cleaned up
Key: KAFKA-10144
URL: https://issues.apache.org/jira/browse/KAFKA-10144
Project: Kafka
rhauch opened a new pull request #8848:
URL: https://github.com/apache/kafka/pull/8848
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
C0urante commented on pull request #8502:
URL: https://github.com/apache/kafka/pull/8502#issuecomment-642362050
@rhauch sure, I can update the description to make it clear that we will
still remove task metrics when a connector is deleted.
jiameixie commented on pull request #8845:
URL: https://github.com/apache/kafka/pull/8845#issuecomment-642361238
@abbccdda @chia7712 Thanks for your advice. I have updated it.
This is an automated message from the Apache Git
rhauch commented on pull request #8502:
URL: https://github.com/apache/kafka/pull/8502#issuecomment-642360742
@C0urante the original description doesn't mention that the task metrics for
a failed task will also be removed when the connector is deleted (in addition
to the worker stopping
C0urante commented on pull request #8502:
URL: https://github.com/apache/kafka/pull/8502#issuecomment-642357185
@rhauch it'd be nice to verify this in tests but unfortunately I didn't
notice your comment earlier in the day and I don't think I have time to
adjust/write new test cases to
rhauch commented on a change in pull request #7496:
URL: https://github.com/apache/kafka/pull/7496#discussion_r438497632
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -507,6 +508,18 @@ private SinkRecord
[
https://issues.apache.org/jira/browse/KAFKA-9067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9067:
-
Labels: needs-kip (was: )
> BigDecimal conversion unnecessarily enforces the scale
>
[
https://issues.apache.org/jira/browse/KAFKA-9318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9318:
-
Labels: needs-kip (was: )
> Kafka Connect. Add map entry value extraction SMT
>
[
https://issues.apache.org/jira/browse/KAFKA-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10115:
--
Priority: Major (was: Minor)
> Incorporate errors.tolerance with the Errant Record Reporter
[
https://issues.apache.org/jira/browse/KAFKA-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132823#comment-17132823
]
Randall Hauch commented on KAFKA-10115:
---
This is related to KAFKA-9971.
> Incorporate
[
https://issues.apache.org/jira/browse/KAFKA-9314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132822#comment-17132822
]
Randall Hauch commented on KAFKA-9314:
--
This seems at least related to
ableegoldman commented on a change in pull request #8787:
URL: https://github.com/apache/kafka/pull/8787#discussion_r438495057
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -763,18 +778,36 @@ private
1 - 100 of 351 matches
Mail list logo
