ijuma merged pull request #10522:
URL: https://github.com/apache/kafka/pull/10522
--
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.
For queries about this service, please
ijuma merged pull request #10524:
URL: https://github.com/apache/kafka/pull/10524
--
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.
For queries about this service, please
ijuma commented on pull request #10491:
URL: https://github.com/apache/kafka/pull/10491#issuecomment-817501577
@jthurne This change causes new failures:
> [2021-04-12T03:23:02.541Z] > A failure occurred while executing
org.nosphere.apache.rat.RatWork
>
>
chia7712 commented on pull request #10488:
URL: https://github.com/apache/kafka/pull/10488#issuecomment-817499047
@dengziming Could you trigger QA again? thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
chia7712 commented on a change in pull request #10469:
URL: https://github.com/apache/kafka/pull/10469#discussion_r611320152
##
File path: tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java
##
@@ -111,13 +111,8 @@ public static void main(String[] args) throws
[
https://issues.apache.org/jira/browse/KAFKA-12510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319012#comment-17319012
]
Jordan Moore commented on KAFKA-12510:
--
Please update the issue with more details.
For example,
[
https://issues.apache.org/jira/browse/KAFKA-12517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319011#comment-17319011
]
Jordan Moore commented on KAFKA-12517:
--
I think the recommendation is to actually use
[
https://issues.apache.org/jira/browse/KAFKA-12530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319006#comment-17319006
]
Jordan Moore commented on KAFKA-12530:
--
Duplicates
KAFKA-12529
KAFKA-12528
> kafka-configs.sh
showuon commented on pull request #10409:
URL: https://github.com/apache/kafka/pull/10409#issuecomment-817457115
@ableegoldman , I've updated this PR to revert the increasing heartbeat
interval change. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-12534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319001#comment-17319001
]
Jordan Moore commented on KAFKA-12534:
--
Include --command-config parameter with a file that
showuon commented on a change in pull request #10409:
URL: https://github.com/apache/kafka/pull/10409#discussion_r611308540
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
##
@@ -172,38 +170,35
showuon commented on a change in pull request #10409:
URL: https://github.com/apache/kafka/pull/10409#discussion_r611308156
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
##
@@ -154,8 +154,6 @@
[
https://issues.apache.org/jira/browse/KAFKA-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318999#comment-17318999
]
Jordan Moore commented on KAFKA-12621:
--
Based on various examples, you only need the znode on the
ijuma commented on pull request #10491:
URL: https://github.com/apache/kafka/pull/10491#issuecomment-817450432
Started another build (the previous got canceled due to environmental
issues).
--
This is an automated message from the Apache Git Service.
To respond to the message, please
kamalcph commented on a change in pull request #10499:
URL: https://github.com/apache/kafka/pull/10499#discussion_r611300574
##
File path: tests/docker/ducker-ak
##
@@ -217,6 +217,8 @@ ask_yes_no() {
# $1: The name of the image to build.
ducker_build() {
local
kamalcph commented on a change in pull request #10499:
URL: https://github.com/apache/kafka/pull/10499#discussion_r611300404
##
File path: tests/docker/ducker-ak
##
@@ -311,15 +313,16 @@ use only ${num_nodes}."
ducker_build "${image_name}"
-docker inspect
satishd commented on a change in pull request #10478:
URL: https://github.com/apache/kafka/pull/10478#discussion_r611288890
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -255,19 +261,21 @@ case object SnapshotGenerated extends
LogStartOffsetIncrementReason {
ijuma commented on pull request #10489:
URL: https://github.com/apache/kafka/pull/10489#issuecomment-817431040
This PR has the same package in two separate jars. That is what's called
"split packages" in the article above.
--
This is an automated message from the Apache Git Service.
To
kowshik commented on pull request #10489:
URL: https://github.com/apache/kafka/pull/10489#issuecomment-817414476
I just looked at the clients code under `kafka/clients/`. As an example to
@ijuma's suggestion, I see the interface: `org.apache.kafka.common.KafkaFuture`
and its
kowshik commented on a change in pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#discussion_r611267145
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java
##
@@ -0,0 +1,316 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/KAFKA-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christian Köcke updated KAFKA-12653:
Description:
Hey,
in my setup I try to set several zookeeper nodes within my kafka
[
https://issues.apache.org/jira/browse/KAFKA-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christian Köcke updated KAFKA-12653:
Description:
Hey,
in my setup I try to set several zookeeper nodes within my kafka
[
https://issues.apache.org/jira/browse/KAFKA-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christian Köcke updated KAFKA-12653:
Description:
Hey,
in my setup I try to set several zookeeper nodes within my kafka
[
https://issues.apache.org/jira/browse/KAFKA-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christian Köcke updated KAFKA-12653:
Description:
Hey,
in my setup I try to set several zookeeper nodes within my kafka
Christian Köcke created KAFKA-12653:
---
Summary: Reverse DNS Lookup on Zookeeper Connect String
Key: KAFKA-12653
URL: https://issues.apache.org/jira/browse/KAFKA-12653
Project: Kafka
Issue
ijuma edited a comment on pull request #10489:
URL: https://github.com/apache/kafka/pull/10489#issuecomment-817341612
One option is to use `log.remote.storage` as the public api package and add
`internals` for the non public. That's similar to what we do for the clients
api. We need to
ijuma commented on pull request #10489:
URL: https://github.com/apache/kafka/pull/10489#issuecomment-817341654
Also cc @kowshik
--
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
ijuma commented on pull request #10489:
URL: https://github.com/apache/kafka/pull/10489#issuecomment-817341612
One option is to use `log.remote.storage` as the public api package and add
`internals` for the non public. That's similar to what we do for the clients
api.
--
This is an
ijuma commented on pull request #10524:
URL: https://github.com/apache/kafka/pull/10524#issuecomment-817339182
cc @satishd
--
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.
ijuma opened a new pull request #10524:
URL: https://github.com/apache/kafka/pull/10524
`testRuntime` is deprecated in Gradle 6.x and has been removed in Gradle 7.0.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
ijuma commented on a change in pull request #10523:
URL: https://github.com/apache/kafka/pull/10523#discussion_r611216846
##
File path: raft/src/main/java/org/apache/kafka/raft/CandidateState.java
##
@@ -241,12 +236,14 @@ public int epoch() {
}
@Override
-
jolshan commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r611214209
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1165,16 +1189,23 @@ class KafkaApis(val requestChannel: RequestChannel,
}
jolshan commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r611214209
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1165,16 +1189,23 @@ class KafkaApis(val requestChannel: RequestChannel,
}
[
https://issues.apache.org/jira/browse/KAFKA-12651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318793#comment-17318793
]
Chris Egerton commented on KAFKA-12651:
---
Whoops, turns out the REST resources aren't online
[
https://issues.apache.org/jira/browse/KAFKA-12651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-12651.
---
Resolution: Not A Problem
> Connect should register REST extensions before REST resources
>
C0urante closed pull request #10521:
URL: https://github.com/apache/kafka/pull/10521
--
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.
For queries about this service,
C0urante commented on pull request #10521:
URL: https://github.com/apache/kafka/pull/10521#issuecomment-817316483
Whoops, turns out the REST resources aren't online immediately after being
registered and are only brought up at a [later
amit cahanovich created KAFKA-12652:
---
Summary: connector doesnt accept transformation configuration
Key: KAFKA-12652
URL: https://issues.apache.org/jira/browse/KAFKA-12652
Project: Kafka
predatorray commented on pull request #5858:
URL: https://github.com/apache/kafka/pull/5858#issuecomment-817269784
@viktorsomogyi I have opened the PR #10518.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
39 matches
Mail list logo
