Hi Team,
In Scala Stream Collector o/p headers we are getting the subnet IP(usually the docker inet IP of the machine on which the collector is hosted). Due this issue our ip_enrichment is not working as expected as we are not getting the userip_address.
below is the collector config we are using:
collector {
interface = "0.0.0.0"
port = 8080
p3p {
policyRef = "/w3c/p3p.xml"
CP = "NOI DSP COR NID PSA OUR IND COM NAV STA"
}
crossDomain {
enabled = false
domains = ["*"]
secure = true
}
cookie {
enabled = true
expiration = "365 days"
name = collectorCookieName
domain = cookieDomain
}
cookieBounce {
enabled = true
name = n3pc
fallbackNetworkUserId = "00000000-0000-4000-A000-000000000000"
forwardedProtocolHeader = "X-Forwarded-Proto"
}
doNotTrackCookie {
enabled = false
name = dnt
value = 1
}
rootResponse {
enabled = false
statusCode = 200
body = ok
}
redirectMacro {
enabled = false
placeholder = "[TOKEN]"
}
cors {
accessControlMaxAge = 10 seconds
}
prometheusMetrics.enabled = false
streams {
good = <good>
bad = <bad>
useIpAddressAsPartitionKey = false
sink {
enabled = kinesis
port = 4150
region = <region>
threadPoolSize = 10
aws {
accessKey = <key>
secretKey = <secret>
}
backoffPolicy {
minBackoff = 1000
maxBackoff = 600000
}
}
buffer {
byteLimit = 4500000
recordLimit = 500
timeLimit = 600000
}
}
}
paths {
"/com.acme/track" = "/com.snowplowanalytics.snowplow/tp2"
"/com.acme/redirect" = "/r/tp2"
"/com.acme/iglu" = "/com.snowplowanalytics.iglu/v1"
}
akka {
loglevel = ERROR
loggers = ["akka.event.slf4j.Slf4jLogger"]
http.server {
remote-address-header = on
raw-request-uri-header = on
parsing {
max-uri-length = 32768
uri-parsing-mode = relaxed
}
}
}
Kindly help me on this as one of our major use case is dependent on this functionality.
Let me know if any other information is required from my end.