小编Liz*_*ury的帖子

如何读取application.conf中的数组环境变量?

我想在application.conf一个变量中定义一个字符串列表。目前在 application.conf 中我有这样的内容:

some.env.variable = ["a", "b"]
Run Code Online (Sandbox Code Playgroud)

我试过:

some.env.variable = ${?I_AM_ENV}.split(",")
Run Code Online (Sandbox Code Playgroud)

I_AM_ENV = a,b 它不起作用。

加载应用程序时出现错误:

Wrong value type at 'some.env.variable', expecting: list but got: string
Run Code Online (Sandbox Code Playgroud)

arrays scala environment-variables typesafe-config

9
推荐指数
2
解决办法
4677
查看次数

一对多 KStream-KTable 连接

我有一个 kStream 大学 - 当大学是 -

University(universityId: String, name: String, studentIds: Seq[String])

val universityKStream = builder.stream[String, University](...)
Run Code Online (Sandbox Code Playgroud)

还有一个 kTable 的学生,当学生是 -

Student(studentId: String, name: String)

val studentsKtable = builder.table[String, Student](...)
Run Code Online (Sandbox Code Playgroud)

我想加入两者并产生一个 ResolvedUniverity 对象的主题:

ResolvedUniversity(universityId: String, name: String, students: Seq[Student])
Run Code Online (Sandbox Code Playgroud)

我不能 groupBy 并用 universityId 聚合学生,因为 student 对象中不存在 universityId 字段..

apache-kafka apache-kafka-streams

2
推荐指数
1
解决办法
2227
查看次数