- 5月 10, 2020
-
-
由 Ismael Juma 创作于
It is used by the MQTT proxy and it doesn't have a `Socket` readily available since it uses Netty. See https://github.com/confluentinc/newwave/pull/48 for more details. Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>, Chris Egerton <chrise@confluent.io>
- 5月 09, 2020
-
-
由 Manikumar Reddy 创作于
-
由 Manikumar Reddy 创作于
Conflicts: * ReplicaManager.scala: Minor conflict. Merge overcounting fetches changes to ce-kafka code * ReplicaManagerTest.scala: Update upstream method rename and add argument to LeaderAndIsrRequest.Builder() * ConsumeBenchWorker.java: Minor conflict. Merge upstream one line change. * dependencies.gradle: Minor conflict. Merge upgrade to Gradle 6.4 changes. * AclEntryTest.scala: Minor conflict. Merge upstream changes. * ControllerChannelManagerTest.scala: Minor conflict. Merge upstream changes. * TopicCommandWithZKClientTest.scala: Minor conflict. Merge upstream changes * SslTransportLayerTest.java: Merge upstream `testNetworkThreadTimeRecorded` method changes to `testNetworkIoTimeRecorded` method * SimpleFetchTest.scala: Deleted in upstream. deleted the same from ce-kafka Update request rate metrics for tiered fetches also
-
由 Brian Byrne 创作于
-
由 Vikas Singh 创作于
scala.collection.IterableView is scala.collection.View now and nither of them exist in other version (one is in 2.12 and another one is in 2.13). This change takes the type declaration out so that Scala infers it based on its version. The type was added for code clarity, but can't have that now. In addition JavaConverters is deprecated, so needed to add a SuppressWarning. compilation with `-PscalaVersion=2.13` passes now. It used to fail
-
由 Ismael Juma 创作于
We are now using the same code for SASL and SSL, the latter was updated to have the correct behavior a while back via 17b2bde4. Ported the unit tests from 17b2bde4 to SaslAuthenticatorTest, two of them failed without this change. Also updated some unit tests to use localhost instead of 127.0.0.1 so that they pass after these changes. Finally, included a few minor clean-ups. Credit to @progocz for finding the issue in CCloud and filing the ticket. This was also independently found by @gardnervickers and @lbradstreet. Reviewers: David Arthur <mumrah@gmail.com>
-
由 Manikumar Reddy 创作于
-
由 Vikas Singh 创作于
* CNKAF-632: RemoveBrokers api plumbing This change adds RemoveBrokers api plumbing to propagate the user request from KafkaApi layer to controller and from there to the databalancer layer where it will be acted upon. It validates the request and propagates any error synchronously. Other errors that are encountered while removing broker will be reported asynchronously and are available using DescribeBrokerRemovals api. Next steps: 1. Add persistence so that api is honored even in case of failure 2. Implement call to CC to take broker out of cluster.
-
由 Xiang Li 创作于
* downstream validation
- 5月 08, 2020
-
-
由 Stanislav Kozlovski 创作于
5f83c51f moved the `LeaderReplicationThrottledReplicasProp` and `FollowerReplicationThrottledReplicasProp` definitions from LogConfig to KafkaConfig. The CI build there passed but on merge we saw that it broke the built because new usage was added to SBK's ExecutorTest
-
由 Stanislav Kozlovski 创作于
This patch replaces the LogConfig throttled replicas prop with the definition in KafkaConfig
-
由 Steve Rodrigues 创作于
scoverage breaks the Scala 2.13 builds and SBK can't use scoverage anyways. (Mistaken inclusion originally.)
-
由 Bob Barrett 创作于
-
由 Bob Barrett 创作于
-
由 Bob Barrett 创作于
* CNKAF-566: Only remove throttles for completed tasks * Log error when failing to remove throttles
-
由 Brian Byrne 创作于
Topic read validation will be moved to mirror topic creation.
-
由 Stanislav Kozlovski 创作于
Part of https://confluentinc.atlassian.net/wiki/spaces/CNKAF/pages/1219931556/SBK+Remove+Broker+Mega-Pager, this patch introduces an internal Kafka RPC client for SBK. It is similar to Kafka's own ReplicaFetcherBlockingSend class, in that it can send requests to one broker only, at most one request concurrently and blocks until the response is received. This is the behavior that SBK will need for calling the InitiateShutdown request as part of the remove broker operation. There are also some small changes to EmbeddedKafka to make it friendlier to double-shutdown (one from the test, another from the test teardown) This patch adds a test dependency of ce-sbk->ce-broker-plugins, for the EmbeddedKafkaCluster integration helpers. Future ce-sbk integration tests should be written with those, as like the rest of ce-kafka's non-core code
-
由 Brian Byrne 创作于
-
由 Rajini Sivaram 创作于
Reviewers: Ismael Juma, Sanjana Kaundinya
- 5月 07, 2020
-
-
-
由 Rigel Bezerra de Melo 创作于
This PR introduces an interface for a HTTP server to be run inside the broker, and a mechanism to load such server from the classpath (to avoid cyclic dependencies between repositories). Binding of the actual implementation of the Kafka HTTP Server is done by registered a implementation of KafkaHttpServerProvider in the classpath (see KafkaHttpServerLoader for details about loading). KafkaHttpServer has a life-cycle detached from the broker life-cycle. The server is started after the broker starts up, and is stopped before the broker shuts down. Runtime dependencies are passed down from the broker to the server at loading time via KafkaHttpServerInjector. A included KafkaHttpServerBinder can be used to construct such injector. This new Kafka HTTP Server is going to be used to substitute MetadataService as a means of running an HTTP server in the broker (to completely separate it from RBAC). Changes in ConfluentProvider, AuthorizerServerInfo, and Broker.scala are to add the RBAC dependencies in the KafkaHttpServerBinder, so that RBAC (HTTP service) can be run in the new HTTP server, and MetadataService can be deleted. Co-authored-by: Stanislav Kozlovski <stanislav_kozlovski@outlook.com>
-
由 Sanjana Kaundinya 创作于
-
由 Scott Hendricks 创作于
Reviewers: Colin P. McCabe <cmccabe@apache.org>
-
由 Chris Egerton 创作于
The rest.advertised.listener config is currently broken as setting it to http when listeners are configured for both https and http will cause the framework to choose whichever of the two listeners is listed first. The changes here attempt to fix this by checking not only that ServerConnector::getName begins with the specified protocol, but also that that protocol is immediately followed by an underscore, which the framework uses as a delimiter between the protocol and the remainder of the connector name. An existing unit test for the RestServer::advertisedUrl method has been expanded to include a case that fails with the framework in its current state and passes with the changes in this commit. * KAFKA-9768: Fix handling of rest.advertised.listener config * KAFKA-9768: Add comments on server connector names * KAFKA-9768: Update RestServerTest comment Co-authored-by: Randall Hauch <rhauch@gmail.com> Reviewers: Randall Hauch <rhauch@gmail.com>, Konstantine Karantasis <konstantine@confluent.io>, Andrew Choi <andchoi@linkedin.com>
-
由 Lucas Bradstreet 创作于
This change makes our system tests download CP 5.5 in both the vagrant and ducker based system tests.
-