Skip to content

Commit ae4cdd4

Browse files
committed
Initial Commit for Streaming
1 parent 873e595 commit ae4cdd4

16 files changed

+946
-1
lines changed

.gitignore

+2
Original file line numberDiff line numberDiff line change
@@ -3,3 +3,5 @@
33
################################################################################
44

55
/main/src/HueLogging.ServiceV2/Properties/launchSettings.json
6+
7+
*.env

docker-compose.yml

+37-1
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,19 @@ services:
99
ports:
1010
- "9092:9092"
1111
environment:
12-
KAFKA_ADVERTISED_HOST_NAME: ${hostip}
12+
KAFKA_ADVERTISED_HOST_NAME: ${HueLogging:MachineHostIp}
1313
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
1414
volumes:
1515
- /var/run/docker.sock:/var/run/docker.sock
16+
cassandra:
17+
image: cassandra
18+
ports:
19+
- "9042:9042"
20+
- "7000:7000"
21+
environment:
22+
CASSANDRA_BROADCAST_ADDRESS: ${HueLogging:MachineHostIp}
23+
volumes:
24+
- ${HueLogging:CassandraVolumePath}:/var/lib/cassandra
1625
polling-service:
1726
build:
1827
context: ./main/src
@@ -25,3 +34,30 @@ services:
2534
- .env
2635
depends_on:
2736
- kafka
37+
jobmanager:
38+
image: flink
39+
expose:
40+
- "6123"
41+
ports:
42+
- "8081:8081"
43+
command: jobmanager
44+
environment:
45+
- JOB_MANAGER_RPC_ADDRESS=jobmanager
46+
links:
47+
- "cassandra:cassandra"
48+
- "kafka:kafka"
49+
taskmanager:
50+
image: flink
51+
expose:
52+
- "6121"
53+
- "6122"
54+
depends_on:
55+
- jobmanager
56+
command: taskmanager
57+
links:
58+
- "jobmanager:jobmanager"
59+
- "cassandra:cassandra"
60+
- "kafka:kafka"
61+
environment:
62+
- JOB_MANAGER_RPC_ADDRESS=jobmanager
63+

stream/.gitignore

+84
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,84 @@
1+
# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and WebStorm
2+
# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
3+
4+
# User-specific stuff
5+
.idea/**/workspace.xml
6+
.idea/**/tasks.xml
7+
.idea/**/usage.statistics.xml
8+
.idea/**/dictionaries
9+
.idea/**/shelf
10+
11+
# Generated files
12+
.idea/**/contentModel.xml
13+
14+
# Sensitive or high-churn files
15+
.idea/**/dataSources/
16+
.idea/**/dataSources.ids
17+
.idea/**/dataSources.local.xml
18+
.idea/**/sqlDataSources.xml
19+
.idea/**/dynamic.xml
20+
.idea/**/uiDesigner.xml
21+
.idea/**/dbnavigator.xml
22+
23+
# Gradle
24+
.idea/**/gradle.xml
25+
.idea/**/libraries
26+
27+
# Gradle and Maven with auto-import
28+
# When using Gradle or Maven with auto-import, you should exclude module files,
29+
# since they will be recreated, and may cause churn. Uncomment if using
30+
# auto-import.
31+
# .idea/modules.xml
32+
# .idea/*.iml
33+
# .idea/modules
34+
35+
# CMake
36+
cmake-build-*/
37+
38+
# Mongo Explorer plugin
39+
.idea/**/mongoSettings.xml
40+
41+
# File-based project format
42+
*.iws
43+
44+
# IntelliJ
45+
out/
46+
47+
# mpeltonen/sbt-idea plugin
48+
.idea_modules/
49+
50+
# JIRA plugin
51+
atlassian-ide-plugin.xml
52+
53+
# Cursive Clojure plugin
54+
.idea/replstate.xml
55+
56+
# Crashlytics plugin (for Android Studio and IntelliJ)
57+
com_crashlytics_export_strings.xml
58+
crashlytics.properties
59+
crashlytics-build.properties
60+
fabric.properties
61+
62+
# Editor-based Rest Client
63+
.idea/httpRequests
64+
65+
# Android studio 3.1+ serialized cache file
66+
.idea/caches/build_file_checksums.ser
67+
68+
# Eclipse
69+
.classpath
70+
.project
71+
.settings/
72+
73+
# Intellij
74+
.idea/
75+
*.iml
76+
*.iws
77+
78+
# Mac
79+
.DS_Store
80+
81+
# Maven
82+
log/
83+
target/
84+

stream/hue-logging-stream/.gitignore

+67
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,67 @@
1+
# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and WebStorm
2+
# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
3+
4+
# User-specific stuff
5+
.idea/**/workspace.xml
6+
.idea/**/tasks.xml
7+
.idea/**/usage.statistics.xml
8+
.idea/**/dictionaries
9+
.idea/**/shelf
10+
11+
# Generated files
12+
.idea/**/contentModel.xml
13+
14+
# Sensitive or high-churn files
15+
.idea/**/dataSources/
16+
.idea/**/dataSources.ids
17+
.idea/**/dataSources.local.xml
18+
.idea/**/sqlDataSources.xml
19+
.idea/**/dynamic.xml
20+
.idea/**/uiDesigner.xml
21+
.idea/**/dbnavigator.xml
22+
23+
# Gradle
24+
.idea/**/gradle.xml
25+
.idea/**/libraries
26+
27+
# Gradle and Maven with auto-import
28+
# When using Gradle or Maven with auto-import, you should exclude module files,
29+
# since they will be recreated, and may cause churn. Uncomment if using
30+
# auto-import.
31+
# .idea/modules.xml
32+
# .idea/*.iml
33+
# .idea/modules
34+
35+
# CMake
36+
cmake-build-*/
37+
38+
# Mongo Explorer plugin
39+
.idea/**/mongoSettings.xml
40+
41+
# File-based project format
42+
*.iws
43+
44+
# IntelliJ
45+
out/
46+
47+
# mpeltonen/sbt-idea plugin
48+
.idea_modules/
49+
50+
# JIRA plugin
51+
atlassian-ide-plugin.xml
52+
53+
# Cursive Clojure plugin
54+
.idea/replstate.xml
55+
56+
# Crashlytics plugin (for Android Studio and IntelliJ)
57+
com_crashlytics_export_strings.xml
58+
crashlytics.properties
59+
crashlytics-build.properties
60+
fabric.properties
61+
62+
# Editor-based Rest Client
63+
.idea/httpRequests
64+
65+
# Android studio 3.1+ serialized cache file
66+
.idea/caches/build_file_checksums.ser
67+

0 commit comments

Comments
 (0)