in kinesis/kinesis.go [411:428]
func replaceDots(obj map[interface{}]interface{}, replacement string) map[interface{}]interface{} {
for k, v := range obj {
var curK = k
switch kt := k.(type) {
case string:
curK = strings.ReplaceAll(kt, ".", replacement)
}
delete(obj, k)
switch vt := v.(type) {
case map[interface{}]interface{}:
v = replaceDots(vt, replacement)
}
obj[curK] = v
}
return obj
}