You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ap...@apache.org on 2021/01/05 22:01:44 UTC
[incubator-pinot] 07/07: quickstart broker tls properties
This is an automated email from the ASF dual-hosted git repository.
apucher pushed a commit to branch pinot-broker-https-discussion
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 1460b0acb0357a031458deb11d6bc62f5c884f7c
Author: Alexander Pucher <al...@alexpucher.com>
AuthorDate: Tue Jan 5 13:55:16 2021 -0800
quickstart broker tls properties
---
.../org/apache/pinot/tools/admin/command/QuickstartRunner.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/QuickstartRunner.java b/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/QuickstartRunner.java
index 0ec8ce7..9225533 100644
--- a/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/QuickstartRunner.java
+++ b/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/QuickstartRunner.java
@@ -171,6 +171,13 @@ public class QuickstartRunner {
Properties prop = new Properties();
prop.put("pinot.broker.client.queryPort", String.valueOf(DEFAULT_BROKER_PORT + i));
+ prop.put("pinot.broker.client.protocol", "https");
+ prop.put("pinot.broker.client.tls.keystore.path", "/Users/alex/projects/incubator-pinot/truststore/generated.keystore.jks");
+ prop.put("pinot.broker.client.tls.keystore.password", "changeit");
+ prop.put("pinot.broker.client.tls.truststore.path", "/Users/alex/projects/incubator-pinot/truststore/generated.truststore.jks");
+ prop.put("pinot.broker.client.tls.truststore.password", "changeit");
+ prop.put("pinot.broker.client.tls.requires_client_auth", "false");
+
try (OutputStream os = new FileOutputStream(configFileName)) {
prop.store(os, "");
}
@@ -310,7 +317,7 @@ public class QuickstartRunner {
throws Exception {
int brokerPort = _brokerPorts.get(RANDOM.nextInt(_brokerPorts.size()));
return JsonUtils.stringToJsonNode(new PostQueryCommand().setBrokerPort(String.valueOf(brokerPort))
- .setQueryType(CommonConstants.Broker.Request.SQL).setQuery(query).run());
+ .setBrokerProtocol("https").setQueryType(CommonConstants.Broker.Request.SQL).setQuery(query).run());
}
public static void registerDefaultPinotFS() {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org