yashmayya commented on PR #12947:
URL: https://github.com/apache/kafka/pull/12947#issuecomment-1336336173
Hi @C0urante, would you be able to take a look at this whenever possible?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ijuma merged PR #12949:
URL: https://github.com/apache/kafka/pull/12949
--
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:
ijuma commented on PR #12948:
URL: https://github.com/apache/kafka/pull/12948#issuecomment-1336297376
#12675 needs to be merged for this to work.
--
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
ijuma commented on code in PR #12675:
URL: https://github.com/apache/kafka/pull/12675#discussion_r1038894058
##
build.gradle:
##
@@ -647,6 +647,9 @@ subprojects {
"-Xlint:unused"
]
+if (versions.baseScala == '2.13')
+
ijuma opened a new pull request, #12950:
URL: https://github.com/apache/kafka/pull/12950
It doesn't add much value since lambdas
were introduced in Java 8.
Also remove KafkaTimerTest.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
ijuma opened a new pull request, #12949:
URL: https://github.com/apache/kafka/pull/12949
Also remove `ApiUtilsTest`.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify
[
https://issues.apache.org/jira/browse/KAFKA-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant updated KAFKA-14437:
-
Description:
Currently, in StripedReplicaPlacer we don’t take existing partition assignments
ijuma opened a new pull request, #12948:
URL: https://github.com/apache/kafka/pull/12948
It's good for us to track the latest JDK version supported
by Gradle.
Given that Scala 2.12 support has been deprecated,
I did not include a Scala 2.12 variant.
### Committer
mumrah commented on PR #12946:
URL: https://github.com/apache/kafka/pull/12946#issuecomment-1336208057
@dengziming
--
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
yashmayya opened a new pull request, #12947:
URL: https://github.com/apache/kafka/pull/12947
- From the [JIRA ticket](https://issues.apache.org/jira/browse/KAFKA-6586):
> The main methods in ConnectDistributed and ConnectStandalone have a lot of
duplication, and it'd be good to refactor
[
https://issues.apache.org/jira/browse/KAFKA-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya reassigned KAFKA-6586:
-
Assignee: Yash Mayya
> Refactor Connect executables
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abdullah alkhawatrah updated KAFKA-14440:
-
Description:
Hey,
I have a kafka streams service that aggregates events from
[
https://issues.apache.org/jira/browse/KAFKA-14440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abdullah alkhawatrah updated KAFKA-14440:
-
Description:
Hey,
I have a kafka streams service that aggregates events from
Abdullah alkhawatrah created KAFKA-14440:
Summary: Local state wipeout with EOS
Key: KAFKA-14440
URL: https://issues.apache.org/jira/browse/KAFKA-14440
Project: Kafka
Issue Type: Bug
yashmayya commented on code in PR #12800:
URL: https://github.com/apache/kafka/pull/12800#discussion_r1038756498
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java:
##
@@ -329,6 +329,60 @@ public void testGetSetNull() throws
[
https://issues.apache.org/jira/browse/KAFKA-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17642800#comment-17642800
]
Tom Bentley commented on KAFKA-14439:
-
FWIW I spent some time on this a few years ago, see
16 matches
Mail list logo
