Skip to content

Cassandra Socks5 Proxy options #131

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 3 commits into
base: 1.x
Choose a base branch
from
Open

Cassandra Socks5 Proxy options #131

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
3ba36b1
Add options for specifying a socks proxy host and port to the sample …
mashkoor-Ahmed Jan 7, 2022
80a1526
Add TODO reminder to consume related changes in Java Driver
mashkoor-Ahmed Jan 7, 2022
c034b9b
Change default value for socksProxyPort to an int
mashkoor-Ahmed Jan 18, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions dist/conf/cassandra-sink-distributed.json.sample
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,8 @@
"ssl.truststore.password": "",
"ssl.truststore.path": "",
"ssl.cipherSuites": "",
"socks.proxyHost": "None",
"socks.proxyPort": 0,
"topic.my_topic.my_ks.my_table.mapping": "col1=key.f1, col2=value.f1, __ttl=value.f2, __timestamp=value.f3, col3=header.f1, col4=now()",
"topic.my_topic.my_ks.my_table.consistencyLevel": "LOCAL_ONE",
"topic.my_topic.my_ks.my_table.ttl": -1,
Expand Down
10 changes: 10 additions & 0 deletions dist/conf/cassandra-sink-standalone.properties.sample
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,16 @@ topics=my_topic
# Path to the private key file, when using OpenSSL.
#ssl.openssl.privateKey=

### SOCKS Proxy Settings ###

# Host which runs as a SOCKS5 proxy, through which Cassandra traffic should be routed.
# Defaults to None.
#socks.proxyHost=None

# Port on which the SOCKS5 proxy is running.
# Defaults to 0.
#socks.proxyPort=0

### Settings for topic my_topic ###

#### Settings for table my_ks.my_table in topic my_topic ####
Expand Down
4 changes: 3 additions & 1 deletion pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,9 @@
<kafka.connect.version>2.4.0</kafka.connect.version>
<confluent.version>5.2.1</confluent.version>
<caffeine.version>2.6.2</caffeine.version>
<oss.driver.version>4.6.0</oss.driver.version>
<oss.driver.version>4.6.0</oss.driver.version> <!--
TODO Before Merging - Bump up version to consume Socks Proxy changes in Java Driver
-->
<dsbulk.version>1.6.0</dsbulk.version>
<reactive-streams.version>1.0.3</reactive-streams.version>
<guava.version>25.1-jre</guava.version>
Expand Down