Update headers handling for http source
This commit is contained in:
@@ -37,7 +37,7 @@ func handleHTTP(rawURL string) (core.Producer, error) {
|
|||||||
query := streams.ParseQuery(rawQuery)
|
query := streams.ParseQuery(rawQuery)
|
||||||
for _, header := range query["header"] {
|
for _, header := range query["header"] {
|
||||||
key, value, _ := strings.Cut(header, ":")
|
key, value, _ := strings.Cut(header, ":")
|
||||||
req.Header.Add(key, value)
|
req.Header.Add(key, strings.TrimSpace(value))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user