Skip to content
Permalink
Browse files
Fixed spelling mistakes
  • Loading branch information
nabarunnag committed Feb 19, 2020
1 parent 75d1107 commit 43805783cc7f87aea325ecbe4df22c1f9c2e9083
Showing 4 changed files with 6 additions and 6 deletions.
@@ -5,7 +5,7 @@ The GeodeKafkaSink allows Geode to consume data off of topics and store data fro

### How to install the geode-kafka-connector
---
#### Prequisite
#### Prerequisite
* Kafka is installed and is up and running. See the Kafka quickstart for more info: [Kafka Quickstart](https://kafka.apache.org/quickstart)
* A Geode Cluster with at least one locator and one server and regions to source from and sink to.
* Topics created in Kafka to source from and sink to.
@@ -60,7 +60,7 @@ bin/connect-standalone.sh config/connect-standalone.properties config/connect-ge
| locators | no, but...| A comma separated string of locators that configure which locators to connect to | localhost[10334] |
|region-to-topics| yes | A comma separated list of "one region to many topics" mappings. Each mapping is surrounded by brackets. For example "[regionName:topicName], "[anotherRegion: topicName, anotherTopic]" | [gkcregion:gkctopic]|
|security-client-auth-init| no | Point to class that implements the [AuthInitialize Interface](https://gemfire.docs.pivotal.io/99/geode/managing/security/implementing_authentication.html)
|security-username| no | Supply a username to be used to authenticate with Geode. Will autoset the security-client-auth-init to use a SystemPropertyAuthInit if one isn't supplied by the user| null|
|security-username| no | Supply a username to be used to authenticate with Geode. Will automatically set the security-client-auth-init to use a SystemPropertyAuthInit if one isn't supplied by the user| null|
|security-password| no | Supply a password to be used to authenticate with Geode| null|
|geode-connector-batch-size| no | Maximum number of records to return on each poll| 100 |
|geode-connector-queue-size| no | Maximum number of entries in the connector queue before backing up all Geode cq listeners sharing the task queue | 10000 |
@@ -76,7 +76,7 @@ protected static ConfigDef configurables() {
configDef.define(LOCATORS, ConfigDef.Type.STRING, DEFAULT_LOCATOR, ConfigDef.Importance.HIGH,
"A comma separated string of locators that configure which locators to connect to");
configDef.define(SECURITY_USER, ConfigDef.Type.STRING, null, ConfigDef.Importance.HIGH,
"Supply a username to be used to authenticate with Geode. Will autoset the security-client-auth-init to use a SystemPropertyAuthInit if one isn't supplied by the user");
"Supply a username to be used to authenticate with Geode. Will automatically set the security-client-auth-init to use a SystemPropertyAuthInit if one isn't supplied by the user");
configDef.define(SECURITY_PASSWORD, ConfigDef.Type.STRING, null, ConfigDef.Importance.HIGH,
"Supply a password to be used to authenticate with Geode");
configDef.define(SECURITY_CLIENT_AUTH_INIT, ConfigDef.Type.STRING, null,
@@ -144,7 +144,7 @@ public void usesSecurityShouldBeTrueIfSecurityUserSet() {
@Test
public void usesSecurityShouldBeTrueIfSecurityClientAuthInitSet() {
Map<String, String> props = new HashMap<>();
props.put(GeodeConnectorConfig.SECURITY_CLIENT_AUTH_INIT, "someclass");
props.put(GeodeConnectorConfig.SECURITY_CLIENT_AUTH_INIT, "some_class");
GeodeConnectorConfig config =
new GeodeConnectorConfig(GeodeConnectorConfig.configurables(), props);
assertTrue(config.usesSecurity());
@@ -22,8 +22,8 @@ public class JavaProcess {
public Process process;
Class classWithMain;

public JavaProcess(Class classWithmain) {
this.classWithMain = classWithmain;
public JavaProcess(Class classWithMain) {
this.classWithMain = classWithMain;
}

public void exec(String... args) throws IOException, InterruptedException {

0 comments on commit 4380578

Please sign in to comment.