Skip to content

S
streamingUserPortrait
Commit 6434b7b7 authored by 赵威's avatar 赵威
Browse files
Options

test redis

parent bbe53666
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
src/main/scala/com.gmei.up/Main.scala
View file @ 6434b7b7
...@@ -45,8 +45,9 @@ object Main extends LazyLogging { ...@@ -45,8 +45,9 @@ object Main extends LazyLogging {
"172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092" "172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092"
) )
// remove test
val kafkaConsumer = new FlinkKafkaConsumer[UserInfo]( val kafkaConsumer = new FlinkKafkaConsumer[UserInfo](
"gm-portrait-update-device", "gm-portrait-update-device-test",
new UserInfoDeserializationSchema, new UserInfoDeserializationSchema,
kafkaConsumerProperties kafkaConsumerProperties
) )
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment