lhotari commented on a change in pull request #14078:
URL: https://github.com/apache/pulsar/pull/14078#discussion_r800689073
##########
File path: pulsar-proxy/pom.xml
##########
@@ -174,10 +174,17 @@
<groupId>com.beust</groupId>
<artifactId>jcommander</artifactId>
</dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-core</artifactId>
- </dependency>
+
+ <dependency>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-core</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>com.github.seancfoley</groupId>
+ <artifactId>ipaddress</artifactId>
+ <version>5.3.3</version>
Review comment:
done
##########
File path:
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java
##########
@@ -162,6 +164,43 @@
)
private String functionWorkerWebServiceURLTLS;
+ @FieldContext(category = CATEGORY_BROKER_PROXY,
+ doc = "When enabled, checks that the target broker is active
before connecting. "
+ + "zookeeperServers and configurationStoreServers must be
configured in proxy configuration "
+ + "for retrieving the active brokers.")
+ private boolean checkActiveBrokers = false;
+
+ @FieldContext(
+ category = CATEGORY_BROKER_PROXY,
+ doc = "Broker proxy connect timeout.\n"
+ + "The timeout value for Broker proxy connect timeout is
in millisecond. Set to 0 to disable."
+ )
+ private int brokerProxyConnectTimeoutMs = 10000;
+
+ @FieldContext(
+ category = CATEGORY_BROKER_PROXY,
+ doc = "Broker proxy read timeout.\n"
+ + "The timeout value for Broker proxy read timeout is in
millisecond. Set to 0 to disable."
+ )
+ private int brokerProxyReadTimeoutMs = 75000;
+
+ @FieldContext(
+ category = CATEGORY_BROKER_PROXY,
+ doc = "Allowed broker target host names. "
+ + "Supports multiple comma separated entries and a
wildcard.")
+ private String brokerProxyAllowedHostNames = "*";
+
+ @FieldContext(
+ category = CATEGORY_BROKER_PROXY,
+ doc = "Allowed broker target ip addresses or ip networks /
netmasks. "
+ + "Supports multiple comma separated entries.")
+ private String brokerProxyAllowedIPAddresses = "*";
+
+ @FieldContext(
+ category = CATEGORY_BROKER_PROXY,
+ doc = "Allowed broker target ports")
+ String brokerProxyAllowedTargetPorts = "6650,6651";
Review comment:
done
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
