This is an automated email from the ASF dual-hosted git repository.
nnag pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/geode-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 4380578 Fixed spelling mistakes
4380578 is described below
commit 43805783cc7f87aea325ecbe4df22c1f9c2e9083
Author: Naburun Nag <[email protected]>
AuthorDate: Wed Feb 19 13:46:21 2020 -0800
Fixed spelling mistakes
---
README.md | 4 ++--
src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java | 2 +-
src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java | 2 +-
src/test/java/org/apache/geode/kafka/utilities/JavaProcess.java | 4 ++--
4 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/README.md b/README.md
index fb1d6a1..19dbf14 100644
--- a/README.md
+++ b/README.md
@@ -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 |
diff --git a/src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
b/src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
index 476c07c..e1e7b64 100644
--- a/src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
+++ b/src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
@@ -76,7 +76,7 @@ public class GeodeConnectorConfig extends AbstractConfig {
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,
diff --git a/src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java
b/src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java
index dfe786c..34fc97b 100644
--- a/src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java
+++ b/src/test/java/org/apache/geode/kafka/GeodeConnectorConfigTest.java
@@ -144,7 +144,7 @@ public class GeodeConnectorConfigTest {
@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());
diff --git a/src/test/java/org/apache/geode/kafka/utilities/JavaProcess.java
b/src/test/java/org/apache/geode/kafka/utilities/JavaProcess.java
index c289c80..2d20244 100644
--- a/src/test/java/org/apache/geode/kafka/utilities/JavaProcess.java
+++ b/src/test/java/org/apache/geode/kafka/utilities/JavaProcess.java
@@ -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 {
