enhancement(amqp sink): Support AMQ Properties (content-type) in AMQP sink #17174

arouene · 2023-04-19T15:29:35Z

Related to the issue: Support AMQP properties #17173

Support for the content-type property, some clients needs to have one to know how to deserialize.

The change I propose, is to make a configuration for properties.content_type on the AMQP sink. If it's not set, the older behavior apply (using BasicProperties::default()).

I currently only support content_type and content_encoding, I can implement other properties if needed.

bits-bot · 2023-04-19T15:29:39Z

All committers have signed the CLA.

netlify · 2023-04-19T15:29:43Z

✅ Deploy Preview for vector-project ready!

Name	Link
🔨 Latest commit	`160cdc1`
🔍 Latest deploy log	https://app.netlify.com/sites/vector-project/deploys/64429135c05ab40008e45675
😎 Deploy Preview	https://deploy-preview-17174--vector-project.netlify.app
📱 Preview on mobile	Toggle QR Code... Use your smartphone camera to open QR code link.

To edit notification comments on pull requests, go to your Netlify site settings.

netlify · 2023-04-19T15:29:43Z

✅ Deploy Preview for vrl-playground canceled.

Name	Link
🔨 Latest commit	`160cdc1`
🔍 Latest deploy log	https://app.netlify.com/sites/vrl-playground/deploys/644291359a6a140008a10a65

github-actions · 2023-04-19T16:48:32Z

Regression Detector Results

Run ID: 70d0f811-a344-48db-90f2-d41aebfae746
Baseline: 3c92556
Comparison: 8e917a8
Total vector CPUs: 7

Explanation

A regression test is an integrated performance test for vector in a repeatable rig, with varying configuration for vector. What follows is a statistical summary of a brief vector run for each configuration across SHAs given above. The goal of these tests are to determine quickly if vector performance is changed and to what degree by a pull request.

The table below, if present, lists those experiments that have experienced a statistically significant change in mean optimization goal performance between baseline and comparison SHAs with 90.00% confidence OR have been detected as newly erratic. Negative values mean that baseline is faster, positive comparison. Results that do not exhibit more than a ±5.00% change in their mean optimization goal are discarded. An experiment is erratic if its coefficient of variation is greater than 0.1. The abbreviated table will be omitted if no interesting change is observed.

No interesting changes in experiment optimization goals with confidence ≥ 90.00% and |Δ mean %| ≥ 5.00%.

Fine details of change detection per experiment.

experiment	goal	Δ mean	Δ mean %	confidence	baseline mean	baseline stdev	baseline stderr	baseline CoV	comparison mean	comparison stdev	comparison stderr	comparison CoV	erratic	declared erratic
syslog_log2metric_humio_metrics	ingress throughput	207.27KiB/CPU-s	3.23	100.00%	6.26MiB/CPU-s	215.5KiB/CPU-s	2.78KiB/CPU-s	0.033614	6.46MiB/CPU-s	194.78KiB/CPU-s	2.51KiB/CPU-s	0.029432	False	False
syslog_log2metric_splunk_hec_metrics	ingress throughput	283.27KiB/CPU-s	3.03	100.00%	9.13MiB/CPU-s	277.29KiB/CPU-s	3.58KiB/CPU-s	0.029664	9.4MiB/CPU-s	289.1KiB/CPU-s	3.73KiB/CPU-s	0.030017	False	False
datadog_agent_remap_blackhole_acks	ingress throughput	768.9KiB/CPU-s	2.43	100.00%	30.85MiB/CPU-s	1.45MiB/CPU-s	19.16KiB/CPU-s	0.046992	31.6MiB/CPU-s	857.56KiB/CPU-s	11.07KiB/CPU-s	0.026499	False	False
datadog_agent_remap_datadog_logs_acks	ingress throughput	310.03KiB/CPU-s	0.96	100.00%	31.5MiB/CPU-s	1.55MiB/CPU-s	20.44KiB/CPU-s	0.049103	31.81MiB/CPU-s	1.58MiB/CPU-s	20.88KiB/CPU-s	0.049681	False	False
otlp_grpc_to_blackhole	ingress throughput	7.97KiB/CPU-s	0.77	100.00%	1.01MiB/CPU-s	56.68KiB/CPU-s	748.74B/CPU-s	0.054703	1.02MiB/CPU-s	51.25KiB/CPU-s	677.19B/CPU-s	0.04909	False	False
datadog_agent_remap_blackhole	ingress throughput	235.26KiB/CPU-s	0.74	100.00%	30.96MiB/CPU-s	1.43MiB/CPU-s	18.88KiB/CPU-s	0.046171	31.18MiB/CPU-s	1.41MiB/CPU-s	18.63KiB/CPU-s	0.045194	False	False
http_text_to_http_json	ingress throughput	143.96KiB/CPU-s	0.57	100.00%	24.63MiB/CPU-s	762.52KiB/CPU-s	9.84KiB/CPU-s	0.030232	24.77MiB/CPU-s	603.13KiB/CPU-s	7.79KiB/CPU-s	0.023777	False	False
syslog_humio_logs	ingress throughput	49.49KiB/CPU-s	0.54	100.00%	9.0MiB/CPU-s	305.37KiB/CPU-s	3.94KiB/CPU-s	0.033116	9.05MiB/CPU-s	368.3KiB/CPU-s	4.75KiB/CPU-s	0.039728	False	False
syslog_loki	ingress throughput	35.79KiB/CPU-s	0.42	100.00%	8.4MiB/CPU-s	237.19KiB/CPU-s	3.06KiB/CPU-s	0.027568	8.44MiB/CPU-s	286.52KiB/CPU-s	3.7KiB/CPU-s	0.033163	False	False
splunk_hec_route_s3	ingress throughput	47.77KiB/CPU-s	0.40	100.00%	11.67MiB/CPU-s	593.95KiB/CPU-s	7.66KiB/CPU-s	0.049712	11.71MiB/CPU-s	580.6KiB/CPU-s	7.49KiB/CPU-s	0.048402	False	False
enterprise_http_to_http	ingress throughput	10.44KiB/CPU-s	0.07	98.40%	13.61MiB/CPU-s	300.77KiB/CPU-s	3.88KiB/CPU-s	0.021574	13.62MiB/CPU-s	149.13KiB/CPU-s	1.93KiB/CPU-s	0.010689	False	False
file_to_blackhole	egress throughput	3.75KiB/CPU-s	0.05	1.49%	7.4MiB/CPU-s	3.89MiB/CPU-s	139.03KiB/CPU-s	0.525251	7.4MiB/CPU-s	4.0MiB/CPU-s	144.92KiB/CPU-s	0.540173	True	True
http_to_http_noack	ingress throughput	2.0KiB/CPU-s	0.01	24.33%	13.61MiB/CPU-s	362.48KiB/CPU-s	4.68KiB/CPU-s	0.026011	13.61MiB/CPU-s	344.65KiB/CPU-s	4.45KiB/CPU-s	0.024727	False	False
http_to_http_json	ingress throughput	-269.99B/CPU-s	-0.00	5.04%	13.62MiB/CPU-s	229.09KiB/CPU-s	2.96KiB/CPU-s	0.016424	13.62MiB/CPU-s	228.57KiB/CPU-s	2.95KiB/CPU-s	0.016387	False	False
fluent_elasticsearch	ingress throughput	375.71B/CPU-s	0.00	49.72%	45.41MiB/CPU-s	30.27KiB/CPU-s	395.46B/CPU-s	0.000651	45.41MiB/CPU-s	30.4KiB/CPU-s	397.45B/CPU-s	0.000654	False	False
splunk_hec_indexer_ack_blackhole	ingress throughput	90.33B/CPU-s	0.00	1.51%	13.62MiB/CPU-s	256.11KiB/CPU-s	3.3KiB/CPU-s	0.018367	13.62MiB/CPU-s	255.24KiB/CPU-s	3.29KiB/CPU-s	0.018305	False	False
splunk_hec_to_splunk_hec_logs_acks	ingress throughput	-213.83B/CPU-s	-0.00	2.40%	13.61MiB/CPU-s	396.97KiB/CPU-s	5.12KiB/CPU-s	0.028474	13.61MiB/CPU-s	362.38KiB/CPU-s	4.67KiB/CPU-s	0.025993	False	False
splunk_hec_to_splunk_hec_logs_noack	ingress throughput	-2.09KiB/CPU-s	-0.02	34.09%	13.62MiB/CPU-s	253.31KiB/CPU-s	3.27KiB/CPU-s	0.018165	13.62MiB/CPU-s	267.09KiB/CPU-s	3.45KiB/CPU-s	0.019156	False	False
http_to_http_acks	ingress throughput	-7.64KiB/CPU-s	-0.14	11.97%	5.17MiB/CPU-s	2.69MiB/CPU-s	35.6KiB/CPU-s	0.520495	5.17MiB/CPU-s	2.74MiB/CPU-s	36.19KiB/CPU-s	0.529921	True	False
syslog_splunk_hec_logs	ingress throughput	-22.44KiB/CPU-s	-0.25	100.00%	8.77MiB/CPU-s	229.84KiB/CPU-s	2.96KiB/CPU-s	0.025605	8.74MiB/CPU-s	331.15KiB/CPU-s	4.27KiB/CPU-s	0.036984	False	False
datadog_agent_remap_datadog_logs	ingress throughput	-317.15KiB/CPU-s	-0.94	100.00%	32.8MiB/CPU-s	1.35MiB/CPU-s	17.88KiB/CPU-s	0.041257	32.49MiB/CPU-s	1.58MiB/CPU-s	20.88KiB/CPU-s	0.048633	False	False
socket_to_socket_blackhole	ingress throughput	-161.91KiB/CPU-s	-1.18	100.00%	13.39MiB/CPU-s	294.83KiB/CPU-s	3.8KiB/CPU-s	0.021498	13.23MiB/CPU-s	433.94KiB/CPU-s	5.6KiB/CPU-s	0.03202	False	False
syslog_regex_logs2metric_ddmetrics	ingress throughput	-47.38KiB/CPU-s	-1.29	100.00%	3.6MiB/CPU-s	364.29KiB/CPU-s	4.7KiB/CPU-s	0.098846	3.55MiB/CPU-s	349.31KiB/CPU-s	4.51KiB/CPU-s	0.096017	False	True
otlp_http_to_blackhole	ingress throughput	-35.4KiB/CPU-s	-2.18	100.00%	1.58MiB/CPU-s	97.24KiB/CPU-s	1.25KiB/CPU-s	0.059937	1.55MiB/CPU-s	107.04KiB/CPU-s	1.38KiB/CPU-s	0.067449	False	False

StephenWakely

Nice. Thanks for doing this.

I think really only a minor change to reduce the visibility of build and it looks like some code needs to be run through rustfmt.

src/sinks/amqp/config.rs

src/sinks/amqp/sink.rs

Co-authored-by: Stephen Wakely <[email protected]>

spencergilbert

LGTM from a UX perspective, if any of the properties have a limited set of values we should consider using an enum rather than a string.

neuronull

Some UX related considerations for the doc comments.

src/sinks/amqp/config.rs

Co-authored-by: neuronull <[email protected]>

Refacto for documentation consistency.

github-actions · 2023-04-21T00:28:06Z

Regression Detector Results

Run ID: 3db9a93e-4594-4858-afa1-b589663c3214
Baseline: a2882f3
Comparison: e0614e8
Total vector CPUs: 7

Explanation

A regression test is an integrated performance test for vector in a repeatable rig, with varying configuration for vector. What follows is a statistical summary of a brief vector run for each configuration across SHAs given above. The goal of these tests are to determine quickly if vector performance is changed and to what degree by a pull request.

The table below, if present, lists those experiments that have experienced a statistically significant change in mean optimization goal performance between baseline and comparison SHAs with 90.00% confidence OR have been detected as newly erratic. Negative values mean that baseline is faster, positive comparison. Results that do not exhibit more than a ±5.00% change in their mean optimization goal are discarded. An experiment is erratic if its coefficient of variation is greater than 0.1. The abbreviated table will be omitted if no interesting change is observed.

No interesting changes in experiment optimization goals with confidence ≥ 90.00% and |Δ mean %| ≥ 5.00%.

Fine details of change detection per experiment.

experiment	goal	Δ mean	Δ mean %	confidence	baseline mean	baseline stdev	baseline stderr	baseline CoV	comparison mean	comparison stdev	comparison stderr	comparison CoV	erratic	declared erratic
syslog_regex_logs2metric_ddmetrics	ingress throughput	168.82KiB/CPU-s	4.94	100.00%	3.34MiB/CPU-s	371.51KiB/CPU-s	4.79KiB/CPU-s	0.108691	3.5MiB/CPU-s	398.24KiB/CPU-s	5.14KiB/CPU-s	0.11103	True	True
syslog_log2metric_humio_metrics	ingress throughput	297.21KiB/CPU-s	4.83	100.00%	6.01MiB/CPU-s	309.44KiB/CPU-s	3.99KiB/CPU-s	0.050253	6.3MiB/CPU-s	265.94KiB/CPU-s	3.43KiB/CPU-s	0.041199	False	False
syslog_loki	ingress throughput	260.6KiB/CPU-s	3.09	100.00%	8.23MiB/CPU-s	256.36KiB/CPU-s	3.31KiB/CPU-s	0.030414	8.49MiB/CPU-s	234.73KiB/CPU-s	3.03KiB/CPU-s	0.027013	False	False
syslog_humio_logs	ingress throughput	274.9KiB/CPU-s	3.03	100.00%	8.86MiB/CPU-s	239.77KiB/CPU-s	3.09KiB/CPU-s	0.026411	9.13MiB/CPU-s	270.29KiB/CPU-s	3.49KiB/CPU-s	0.028897	False	False
syslog_splunk_hec_logs	ingress throughput	264.3KiB/CPU-s	2.95	100.00%	8.75MiB/CPU-s	256.7KiB/CPU-s	3.31KiB/CPU-s	0.028651	9.01MiB/CPU-s	238.26KiB/CPU-s	3.07KiB/CPU-s	0.025831	False	False
syslog_log2metric_splunk_hec_metrics	ingress throughput	200.48KiB/CPU-s	2.14	100.00%	9.14MiB/CPU-s	258.96KiB/CPU-s	3.34KiB/CPU-s	0.027671	9.33MiB/CPU-s	317.8KiB/CPU-s	4.1KiB/CPU-s	0.033246	False	False
socket_to_socket_blackhole	ingress throughput	280.59KiB/CPU-s	2.13	100.00%	12.86MiB/CPU-s	495.72KiB/CPU-s	6.4KiB/CPU-s	0.037634	13.14MiB/CPU-s	344.19KiB/CPU-s	4.44KiB/CPU-s	0.025585	False	False
otlp_grpc_to_blackhole	ingress throughput	21.37KiB/CPU-s	2.08	100.00%	1.0MiB/CPU-s	46.97KiB/CPU-s	620.78B/CPU-s	0.045791	1.02MiB/CPU-s	52.02KiB/CPU-s	687.41B/CPU-s	0.049688	False	False
splunk_hec_route_s3	ingress throughput	209.97KiB/CPU-s	1.81	100.00%	11.33MiB/CPU-s	662.67KiB/CPU-s	8.55KiB/CPU-s	0.057102	11.54MiB/CPU-s	684.94KiB/CPU-s	8.84KiB/CPU-s	0.057972	False	False
datadog_agent_remap_blackhole_acks	ingress throughput	527.16KiB/CPU-s	1.68	100.00%	30.63MiB/CPU-s	1.32MiB/CPU-s	17.45KiB/CPU-s	0.043111	31.15MiB/CPU-s	1.11MiB/CPU-s	14.61KiB/CPU-s	0.035476	False	False
otlp_http_to_blackhole	ingress throughput	20.6KiB/CPU-s	1.33	100.00%	1.52MiB/CPU-s	124.22KiB/CPU-s	1.6KiB/CPU-s	0.079936	1.54MiB/CPU-s	112.44KiB/CPU-s	1.45KiB/CPU-s	0.071406	False	False
datadog_agent_remap_datadog_logs	ingress throughput	417.82KiB/CPU-s	1.27	100.00%	32.02MiB/CPU-s	1.15MiB/CPU-s	15.23KiB/CPU-s	0.035983	32.43MiB/CPU-s	1.59MiB/CPU-s	20.97KiB/CPU-s	0.048934	False	False
http_text_to_http_json	ingress throughput	154.57KiB/CPU-s	0.63	100.00%	23.85MiB/CPU-s	639.86KiB/CPU-s	8.26KiB/CPU-s	0.026198	24.0MiB/CPU-s	677.62KiB/CPU-s	8.75KiB/CPU-s	0.02757	False	False
http_to_http_acks	ingress throughput	11.78KiB/CPU-s	0.22	18.37%	5.15MiB/CPU-s	2.67MiB/CPU-s	35.34KiB/CPU-s	0.5196	5.16MiB/CPU-s	2.75MiB/CPU-s	36.37KiB/CPU-s	0.533439	True	False
http_to_http_noack	ingress throughput	8.0KiB/CPU-s	0.06	76.82%	13.6MiB/CPU-s	401.05KiB/CPU-s	5.17KiB/CPU-s	0.028786	13.61MiB/CPU-s	328.9KiB/CPU-s	4.24KiB/CPU-s	0.023594	False	False
enterprise_http_to_http	ingress throughput	2.22KiB/CPU-s	0.02	51.26%	13.62MiB/CPU-s	194.63KiB/CPU-s	2.51KiB/CPU-s	0.013952	13.62MiB/CPU-s	152.86KiB/CPU-s	1.97KiB/CPU-s	0.010956	False	False
splunk_hec_to_splunk_hec_logs_acks	ingress throughput	-185.63B/CPU-s	-0.00	2.07%	13.61MiB/CPU-s	394.22KiB/CPU-s	5.09KiB/CPU-s	0.028276	13.61MiB/CPU-s	371.03KiB/CPU-s	4.79KiB/CPU-s	0.026613	False	False
fluent_elasticsearch	ingress throughput	166.46B/CPU-s	0.00	23.52%	45.41MiB/CPU-s	30.0KiB/CPU-s	392.06B/CPU-s	0.000645	45.41MiB/CPU-s	30.21KiB/CPU-s	394.76B/CPU-s	0.00065	False	False
splunk_hec_to_splunk_hec_logs_noack	ingress throughput	-60.83B/CPU-s	-0.00	0.95%	13.61MiB/CPU-s	274.84KiB/CPU-s	3.55KiB/CPU-s	0.019713	13.61MiB/CPU-s	273.88KiB/CPU-s	3.53KiB/CPU-s	0.019644	False	False
splunk_hec_indexer_ack_blackhole	ingress throughput	-1.23KiB/CPU-s	-0.01	20.89%	13.62MiB/CPU-s	250.69KiB/CPU-s	3.23KiB/CPU-s	0.017977	13.62MiB/CPU-s	256.29KiB/CPU-s	3.31KiB/CPU-s	0.01838	False	False
file_to_blackhole	egress throughput	-5.97KiB/CPU-s	-0.08	2.44%	7.35MiB/CPU-s	3.85MiB/CPU-s	136.4KiB/CPU-s	0.523769	7.34MiB/CPU-s	3.9MiB/CPU-s	139.0KiB/CPU-s	0.530967	True	True
datadog_agent_remap_datadog_logs_acks	ingress throughput	-106.97KiB/CPU-s	-0.33	100.00%	31.77MiB/CPU-s	1.18MiB/CPU-s	15.62KiB/CPU-s	0.037216	31.66MiB/CPU-s	1.22MiB/CPU-s	16.17KiB/CPU-s	0.038643	False	False
datadog_agent_remap_blackhole	ingress throughput	-308.43KiB/CPU-s	-0.99	100.00%	30.52MiB/CPU-s	1.37MiB/CPU-s	18.08KiB/CPU-s	0.044833	30.22MiB/CPU-s	1.84MiB/CPU-s	24.35KiB/CPU-s	0.060982	False	False
http_to_http_json	ingress throughput	-495.86KiB/CPU-s	-3.57	100.00%	13.57MiB/CPU-s	302.63KiB/CPU-s	3.91KiB/CPU-s	0.021784	13.08MiB/CPU-s	1.54MiB/CPU-s	20.28KiB/CPU-s	0.117342	True	False

StephenWakely

Nice, this is looking good. Just one more CI job is failing, if you can run the suggested fix:

Run make check-component-docs
cargo build --quiet
target/debug/vector generate-schema > /tmp/vector-config-schema.json 2>/dev/null
cargo vdev build component-docs /tmp/vector-config-schema.json \
	>/dev/null
cargo vdev check component-docs
Found out-of-sync component Cue files in this branch:
 - website/cue/reference/components/sinks/base/amqp.cue
Run `make generate-component-docs` locally to update your branch and commit/push the changes.

github-actions · 2023-04-21T14:53:19Z

Regression Detector Results

Run ID: 854e8f6b-1e04-422a-81c1-5f35d51d32b7
Baseline: 5dff0ed
Comparison: 160cdc1
Total vector CPUs: 7

Explanation

A regression test is an integrated performance test for vector in a repeatable rig, with varying configuration for vector. What follows is a statistical summary of a brief vector run for each configuration across SHAs given above. The goal of these tests are to determine quickly if vector performance is changed and to what degree by a pull request.

The table below, if present, lists those experiments that have experienced a statistically significant change in mean optimization goal performance between baseline and comparison SHAs with 90.00% confidence OR have been detected as newly erratic. Negative values mean that baseline is faster, positive comparison. Results that do not exhibit more than a ±5.00% change in their mean optimization goal are discarded. An experiment is erratic if its coefficient of variation is greater than 0.1. The abbreviated table will be omitted if no interesting change is observed.

No interesting changes in experiment optimization goals with confidence ≥ 90.00% and |Δ mean %| ≥ 5.00%.

Fine details of change detection per experiment.

experiment	goal	Δ mean	Δ mean %	confidence	baseline mean	baseline stdev	baseline stderr	baseline CoV	comparison mean	comparison stdev	comparison stderr	comparison CoV	erratic	declared erratic
syslog_splunk_hec_logs	ingress throughput	295.14KiB/CPU-s	3.30	100.00%	8.74MiB/CPU-s	358.39KiB/CPU-s	4.62KiB/CPU-s	0.04003	9.03MiB/CPU-s	310.63KiB/CPU-s	4.01KiB/CPU-s	0.033588	False	False
syslog_log2metric_splunk_hec_metrics	ingress throughput	303.83KiB/CPU-s	3.28	100.00%	9.04MiB/CPU-s	210.13KiB/CPU-s	2.71KiB/CPU-s	0.022703	9.33MiB/CPU-s	385.13KiB/CPU-s	4.97KiB/CPU-s	0.040288	False	False
datadog_agent_remap_blackhole	ingress throughput	939.81KiB/CPU-s	3.03	100.00%	30.24MiB/CPU-s	1.98MiB/CPU-s	26.1KiB/CPU-s	0.065316	31.16MiB/CPU-s	905.93KiB/CPU-s	11.69KiB/CPU-s	0.028391	False	False
syslog_loki	ingress throughput	248.46KiB/CPU-s	2.95	100.00%	8.23MiB/CPU-s	339.31KiB/CPU-s	4.38KiB/CPU-s	0.040256	8.47MiB/CPU-s	249.26KiB/CPU-s	3.22KiB/CPU-s	0.028725	False	False
file_to_blackhole	egress throughput	205.21KiB/CPU-s	2.78	69.34%	7.21MiB/CPU-s	3.94MiB/CPU-s	139.32KiB/CPU-s	0.545945	7.41MiB/CPU-s	4.0MiB/CPU-s	144.38KiB/CPU-s	0.539517	True	True
otlp_grpc_to_blackhole	ingress throughput	27.5KiB/CPU-s	2.71	100.00%	1015.66KiB/CPU-s	51.4KiB/CPU-s	679.21B/CPU-s	0.050603	1.02MiB/CPU-s	44.17KiB/CPU-s	583.85B/CPU-s	0.042341	False	False
syslog_log2metric_humio_metrics	ingress throughput	143.0KiB/CPU-s	2.25	100.00%	6.21MiB/CPU-s	295.48KiB/CPU-s	3.81KiB/CPU-s	0.046467	6.35MiB/CPU-s	388.86KiB/CPU-s	5.02KiB/CPU-s	0.059808	False	False
syslog_humio_logs	ingress throughput	196.45KiB/CPU-s	2.17	100.00%	8.86MiB/CPU-s	373.18KiB/CPU-s	4.82KiB/CPU-s	0.041151	9.05MiB/CPU-s	434.43KiB/CPU-s	5.6KiB/CPU-s	0.046889	False	False
datadog_agent_remap_blackhole_acks	ingress throughput	523.28KiB/CPU-s	1.68	100.00%	30.47MiB/CPU-s	1.54MiB/CPU-s	20.3KiB/CPU-s	0.050418	30.98MiB/CPU-s	1.1MiB/CPU-s	14.5KiB/CPU-s	0.035403	False	False
socket_to_socket_blackhole	ingress throughput	210.6KiB/CPU-s	1.60	100.00%	12.85MiB/CPU-s	360.82KiB/CPU-s	4.66KiB/CPU-s	0.027411	13.06MiB/CPU-s	406.79KiB/CPU-s	5.25KiB/CPU-s	0.030416	False	False
syslog_regex_logs2metric_ddmetrics	ingress throughput	15.28KiB/CPU-s	0.43	95.50%	3.45MiB/CPU-s	401.41KiB/CPU-s	5.18KiB/CPU-s	0.113672	3.46MiB/CPU-s	433.3KiB/CPU-s	5.59KiB/CPU-s	0.122176	True	True
http_text_to_http_json	ingress throughput	106.49KiB/CPU-s	0.43	100.00%	24.09MiB/CPU-s	685.69KiB/CPU-s	8.85KiB/CPU-s	0.027794	24.19MiB/CPU-s	756.46KiB/CPU-s	9.77KiB/CPU-s	0.030531	False	False
http_to_http_noack	ingress throughput	8.17KiB/CPU-s	0.06	80.18%	13.61MiB/CPU-s	385.84KiB/CPU-s	4.98KiB/CPU-s	0.027691	13.61MiB/CPU-s	305.1KiB/CPU-s	3.94KiB/CPU-s	0.021883	False	False
enterprise_http_to_http	ingress throughput	3.92KiB/CPU-s	0.03	73.39%	13.62MiB/CPU-s	227.99KiB/CPU-s	2.94KiB/CPU-s	0.016345	13.62MiB/CPU-s	150.28KiB/CPU-s	1.94KiB/CPU-s	0.010771	False	False
splunk_hec_indexer_ack_blackhole	ingress throughput	3.24KiB/CPU-s	0.02	51.48%	13.61MiB/CPU-s	263.92KiB/CPU-s	3.4KiB/CPU-s	0.018929	13.62MiB/CPU-s	245.21KiB/CPU-s	3.16KiB/CPU-s	0.017582	False	False
fluent_elasticsearch	ingress throughput	-525.88B/CPU-s	-0.00	65.21%	45.41MiB/CPU-s	30.47KiB/CPU-s	398.32B/CPU-s	0.000655	45.41MiB/CPU-s	30.14KiB/CPU-s	394.01B/CPU-s	0.000648	False	False
splunk_hec_to_splunk_hec_logs_acks	ingress throughput	75.76B/CPU-s	0.00	0.89%	13.61MiB/CPU-s	380.04KiB/CPU-s	4.9KiB/CPU-s	0.02726	13.61MiB/CPU-s	349.86KiB/CPU-s	4.51KiB/CPU-s	0.025095	False	False
http_to_http_json	ingress throughput	-16.41B/CPU-s	-0.00	0.31%	13.62MiB/CPU-s	229.75KiB/CPU-s	2.96KiB/CPU-s	0.016472	13.62MiB/CPU-s	228.22KiB/CPU-s	2.94KiB/CPU-s	0.016362	False	False
splunk_hec_to_splunk_hec_logs_noack	ingress throughput	-986.89B/CPU-s	-0.01	15.86%	13.62MiB/CPU-s	259.77KiB/CPU-s	3.35KiB/CPU-s	0.01863	13.61MiB/CPU-s	268.27KiB/CPU-s	3.46KiB/CPU-s	0.01924	False	False
datadog_agent_remap_datadog_logs_acks	ingress throughput	-57.75KiB/CPU-s	-0.18	97.30%	32.1MiB/CPU-s	1.31MiB/CPU-s	17.32KiB/CPU-s	0.040832	32.04MiB/CPU-s	1.48MiB/CPU-s	19.53KiB/CPU-s	0.046125	False	False
otlp_http_to_blackhole	ingress throughput	-2.98KiB/CPU-s	-0.19	83.92%	1.53MiB/CPU-s	121.73KiB/CPU-s	1.57KiB/CPU-s	0.077658	1.53MiB/CPU-s	111.05KiB/CPU-s	1.43KiB/CPU-s	0.07098	False	False
splunk_hec_route_s3	ingress throughput	-32.32KiB/CPU-s	-0.28	99.27%	11.44MiB/CPU-s	630.52KiB/CPU-s	8.14KiB/CPU-s	0.053822	11.41MiB/CPU-s	687.72KiB/CPU-s	8.87KiB/CPU-s	0.058867	False	False
http_to_http_acks	ingress throughput	-26.16KiB/CPU-s	-0.49	39.63%	5.18MiB/CPU-s	2.68MiB/CPU-s	35.47KiB/CPU-s	0.517738	5.16MiB/CPU-s	2.71MiB/CPU-s	35.8KiB/CPU-s	0.525088	True	False
datadog_agent_remap_datadog_logs	ingress throughput	-645.61KiB/CPU-s	-1.93	100.00%	32.6MiB/CPU-s	1.39MiB/CPU-s	18.33KiB/CPU-s	0.042545	31.97MiB/CPU-s	1.19MiB/CPU-s	15.74KiB/CPU-s	0.037258	False	False

StephenWakely

Perfect. Thankyou!

… sink (vectordotdev#17174) * Support AMQ Properties in AMQP sinks * Refacto removing properties.rs * Update src/sinks/amqp/config.rs Co-authored-by: Stephen Wakely <[email protected]> * Update src/sinks/amqp/config.rs Co-authored-by: neuronull <[email protected]> * Update config.rs Refacto for documentation consistency. * Rustfmt * Generate component docs --------- Co-authored-by: Stephen Wakely <[email protected]> Co-authored-by: neuronull <[email protected]>

# [1.13.0](answerbook/vector@v1.12.1...v1.13.0) (2023-09-13) ### Bug Fixes * **appsignal sink**: Add TLS config option (vectordotdev#17122) [198068c](answerbook/vector@198068c) - GitHub * **buffers**: correctly handle partial writes in reader seek during initialization (vectordotdev#17099) [a791595](answerbook/vector@a791595) - GitHub * **config**: recurse through schema refs when determining eligibility for unevaluated properties (vectordotdev#17150) [71d1bf6](answerbook/vector@71d1bf6) - GitHub * **docker_logs source**: Support tcp schema [e1c0c02](answerbook/vector@e1c0c02) - GitHub * **elasticsearch sink**: Elasticsearch sink with api_version set to "auto" does not recognize the API version of ES6 as V6 (vectordotdev#17226) (vectordotdev#17227) [9b6ef24](answerbook/vector@9b6ef24) - GitHub * **gcp_stackdriver_metrics sink**: Call function to regenerate auth token (vectordotdev#17297) [bf7904b](answerbook/vector@bf7904b) - GitHub * **influxdb_logs**: encode influx line when no tags present (vectordotdev#17029) [c3aa14f](answerbook/vector@c3aa14f) - GitHub * **reduce transform**: Revert flushing on interval change to `expire_metrics_ms` (vectordotdev#17084) [e86b155](answerbook/vector@e86b155) - GitHub * **releasing**: Fix globbing of release artifacts for GitHub (vectordotdev#17114) [7fe089c](answerbook/vector@7fe089c) - GitHub * **schemas**: Dont panic with non object field kinds (vectordotdev#17140) [1e43208](answerbook/vector@1e43208) - GitHub ### Chores * (syslog source): add source_ip to some syslog tests (vectordotdev#17235) [29c34c0](answerbook/vector@29c34c0) - GitHub * add note to DEVELOPING.md re panics (vectordotdev#17277) [03e905e](answerbook/vector@03e905e) - GitHub * Add UX note about encoding of log_schema keys (vectordotdev#17266) [dc6e54c](answerbook/vector@dc6e54c) - GitHub * **administration**: add `appsignal` to codeowners (vectordotdev#17127) [7b15d19](answerbook/vector@7b15d19) - GitHub * **buffer**: tidy up some of the module level docs for `disk_v2` (vectordotdev#17093) [edaa612](answerbook/vector@edaa612) - GitHub * **ci**: bump docker/metadata-action from 4.3.0 to 4.4.0 (vectordotdev#17170) [854d71e](answerbook/vector@854d71e) - GitHub * **ci**: Disable `appsignal` integration test until CA issues are resolved (vectordotdev#17109) [f3b5d42](answerbook/vector@f3b5d42) - GitHub * **ci**: Disable scheduled runs of Baseline Timings workflow (vectordotdev#17281) [4335b0a](answerbook/vector@4335b0a) - GitHub * **ci**: Fix event assertions for `aws_ec2_metadata` transform (vectordotdev#17413) [da36fb6](answerbook/vector@da36fb6) - GitHub * **ci**: Increase timeout for integration tests (vectordotdev#17326) [e1f125a](answerbook/vector@e1f125a) - GitHub * **ci**: Increase timeout for integration tests to 30m (vectordotdev#17350) [5d3f619](answerbook/vector@5d3f619) - GitHub * **ci**: re-enable `appsignal` integration test (vectordotdev#17111) [48fc574](answerbook/vector@48fc574) - GitHub * **ci**: Remove ci-sweep tasks (vectordotdev#17415) [5c33f99](answerbook/vector@5c33f99) - GitHub * **ci**: remove unnecessary dep install (vectordotdev#17128) [f56d1ef](answerbook/vector@f56d1ef) - GitHub * **ci**: Try to fix apt retries (vectordotdev#17393) [6b3db04](answerbook/vector@6b3db04) - GitHub * **ci**: update unsupported ubuntu version runners (vectordotdev#17113) [e7c4815](answerbook/vector@e7c4815) - GitHub * **ci**: use python v3.8 in ubuntu 20.04 runner (vectordotdev#17116) [7a40c81](answerbook/vector@7a40c81) - GitHub * **config**: begin laying out primitives for programmatically querying schema (vectordotdev#17130) [aad8115](answerbook/vector@aad8115) - GitHub * **config**: emit human-friendly version of enum variant/property names in schema (vectordotdev#17171) [3b38ba8](answerbook/vector@3b38ba8) - GitHub * **config**: improve config schema output with more precise `unevaluatedProperties` + schema ref flattening (vectordotdev#17026) [2d72f82](answerbook/vector@2d72f82) - GitHub * **deps**: Add 3rd party license file and CI checks (vectordotdev#17344) [7350e1a](answerbook/vector@7350e1a) - GitHub * **deps**: bump anyhow from 1.0.70 to 1.0.71 (vectordotdev#17300) [6a5af3b](answerbook/vector@6a5af3b) - GitHub * **deps**: bump assert_cmd from 2.0.10 to 2.0.11 (vectordotdev#17290) [c4784fd](answerbook/vector@c4784fd) - GitHub * **deps**: bump async-compression from 0.3.15 to 0.4.0 (vectordotdev#17365) [b9aac47](answerbook/vector@b9aac47) - GitHub * **deps**: bump async-graphql from 5.0.7 to 5.0.8 (vectordotdev#17357) [05a4f17](answerbook/vector@05a4f17) - GitHub * **deps**: bump async-graphql-warp from 5.0.7 to 5.0.8 (vectordotdev#17367) [693584e](answerbook/vector@693584e) - GitHub * **deps**: bump async-stream from 0.3.4 to 0.3.5 (vectordotdev#17076) [c29c817](answerbook/vector@c29c817) - GitHub * **deps**: bump aws-sigv4 from 0.55.0 to 0.55.1 (vectordotdev#17138) [dbb3f25](answerbook/vector@dbb3f25) - GitHub * **deps**: bump axum from 0.6.12 to 0.6.18 (vectordotdev#17257) [41ac76e](answerbook/vector@41ac76e) - GitHub * **deps**: bump cached from 0.42.0 to 0.43.0 (vectordotdev#17118) [f90b3b3](answerbook/vector@f90b3b3) - GitHub * **deps**: bump chrono-tz from 0.8.1 to 0.8.2 (vectordotdev#17088) [623b838](answerbook/vector@623b838) - GitHub * **deps**: bump clap_complete from 4.2.0 to 4.2.1 (vectordotdev#17229) [d286d16](answerbook/vector@d286d16) - GitHub * **deps**: bump clap_complete from 4.2.1 to 4.2.2 (vectordotdev#17359) [565668e](answerbook/vector@565668e) - GitHub * **deps**: bump clap_complete from 4.2.2 to 4.2.3 (vectordotdev#17383) [111cd07](answerbook/vector@111cd07) - GitHub * **deps**: bump console-subscriber from 0.1.8 to 0.1.9 (vectordotdev#17358) [97b862c](answerbook/vector@97b862c) - GitHub * **deps**: bump directories from 5.0.0 to 5.0.1 (vectordotdev#17271) [be69f5f](answerbook/vector@be69f5f) - GitHub * **deps**: bump dunce from 1.0.3 to 1.0.4 (vectordotdev#17244) [cfc387d](answerbook/vector@cfc387d) - GitHub * **deps**: bump enumflags2 from 0.7.5 to 0.7.6 (vectordotdev#17079) [cbc17be](answerbook/vector@cbc17be) - GitHub * **deps**: bump enumflags2 from 0.7.6 to 0.7.7 (vectordotdev#17206) [c80c5eb](answerbook/vector@c80c5eb) - GitHub * **deps**: bump flate2 from 1.0.25 to 1.0.26 (vectordotdev#17320) [ef13370](answerbook/vector@ef13370) - GitHub * **deps**: bump getrandom from 0.2.8 to 0.2.9 (vectordotdev#17101) [d53240b](answerbook/vector@d53240b) - GitHub * **deps**: bump h2 from 0.3.18 to 0.3.19 (vectordotdev#17388) [6088abd](answerbook/vector@6088abd) - GitHub * **deps**: bump hashlink from 0.8.1 to 0.8.2 (vectordotdev#17419) [01b3cd7](answerbook/vector@01b3cd7) - GitHub * **deps**: bump hyper from 0.14.25 to 0.14.26 (vectordotdev#17347) [c43dcfd](answerbook/vector@c43dcfd) - GitHub * **deps**: bump inventory from 0.3.5 to 0.3.6 (vectordotdev#17401) [5b5ad16](answerbook/vector@5b5ad16) - GitHub * **deps**: bump libc from 0.2.140 to 0.2.141 (vectordotdev#17104) [dd9608a](answerbook/vector@dd9608a) - GitHub * **deps**: bump libc from 0.2.141 to 0.2.142 (vectordotdev#17273) [bc618a2](answerbook/vector@bc618a2) - GitHub * **deps**: bump libc from 0.2.142 to 0.2.143 (vectordotdev#17338) [6afe206](answerbook/vector@6afe206) - GitHub * **deps**: bump libc from 0.2.143 to 0.2.144 (vectordotdev#17346) [99b8dc1](answerbook/vector@99b8dc1) - GitHub * **deps**: bump memmap2 from 0.5.10 to 0.6.0 (vectordotdev#17355) [dae0c6a](answerbook/vector@dae0c6a) - GitHub * **deps**: bump memmap2 from 0.6.0 to 0.6.1 (vectordotdev#17364) [58ba741](answerbook/vector@58ba741) - GitHub * **deps**: bump metrics, metrics-tracing-context, metrics-util (vectordotdev#17336) [9a723e3](answerbook/vector@9a723e3) - GitHub * **deps**: bump mlua from 0.8.8 to 0.8.9 (vectordotdev#17423) [57f8bd4](answerbook/vector@57f8bd4) - GitHub * **deps**: bump mock_instant from 0.2.1 to 0.3.0 (vectordotdev#17210) [40c9afc](answerbook/vector@40c9afc) - GitHub * **deps**: bump mongodb from 2.4.0 to 2.5.0 (vectordotdev#17337) [64f4f69](answerbook/vector@64f4f69) - GitHub * **deps**: bump nkeys from 0.2.0 to 0.3.0 (vectordotdev#17421) [3320eda](answerbook/vector@3320eda) - GitHub * **deps**: bump notify from 5.1.0 to 6.0.0 (vectordotdev#17422) [58603b9](answerbook/vector@58603b9) - GitHub * **deps**: bump num_enum from 0.5.11 to 0.6.0 (vectordotdev#17106) [42f298b](answerbook/vector@42f298b) - GitHub * **deps**: bump num_enum from 0.6.0 to 0.6.1 (vectordotdev#17272) [f696e7b](answerbook/vector@f696e7b) - GitHub * **deps**: bump opendal from 0.30.5 to 0.31.0 (vectordotdev#17119) [8762563](answerbook/vector@8762563) - GitHub * **deps**: bump opendal from 0.31.0 to 0.33.2 (vectordotdev#17286) [3d41931](answerbook/vector@3d41931) - GitHub * **deps**: bump opendal from 0.33.2 to 0.34.0 (vectordotdev#17354) [ae602da](answerbook/vector@ae602da) - GitHub * **deps**: bump openssl from 0.10.48 to 0.10.50 (vectordotdev#17087) [9a56ed8](answerbook/vector@9a56ed8) - GitHub * **deps**: bump openssl from 0.10.50 to 0.10.52 (vectordotdev#17299) [0ecceb3](answerbook/vector@0ecceb3) - GitHub * **deps**: bump pin-project from 1.0.12 to 1.1.0 (vectordotdev#17385) [e8d3002](answerbook/vector@e8d3002) - GitHub * **deps**: bump prettydiff from 0.6.2 to 0.6.4 (vectordotdev#17089) [e090610](answerbook/vector@e090610) - GitHub * **deps**: bump prettydiff from 0.6.2 to 0.6.4 (vectordotdev#17315) [a1ec68d](answerbook/vector@a1ec68d) - GitHub * **deps**: bump proc-macro2 from 1.0.55 to 1.0.56 (vectordotdev#17103) [6f74523](answerbook/vector@6f74523) - GitHub * **deps**: bump proc-macro2 from 1.0.56 to 1.0.57 (vectordotdev#17400) [a6e1ae7](answerbook/vector@a6e1ae7) - GitHub * **deps**: bump prost-build from 0.11.8 to 0.11.9 (vectordotdev#17260) [a88aba4](answerbook/vector@a88aba4) - GitHub * **deps**: bump quote from 1.0.26 to 1.0.27 (vectordotdev#17348) [f81ff18](answerbook/vector@f81ff18) - GitHub * **deps**: bump rdkafka from 0.29.0 to 0.30.0 (vectordotdev#17387) [9703188](answerbook/vector@9703188) - GitHub * **deps**: bump regex from 1.7.3 to 1.8.1 (vectordotdev#17222) [410aa3c](answerbook/vector@410aa3c) - GitHub * **deps**: bump reqwest from 0.11.16 to 0.11.17 (vectordotdev#17316) [09176ec](answerbook/vector@09176ec) - GitHub * **deps**: bump security-framework from 2.8.2 to 2.9.0 (vectordotdev#17386) [1287168](answerbook/vector@1287168) - GitHub * **deps**: bump serde from 1.0.159 to 1.0.160 (vectordotdev#17270) [036ad4a](answerbook/vector@036ad4a) - GitHub * **deps**: bump serde from 1.0.160 to 1.0.162 (vectordotdev#17317) [79e97a2](answerbook/vector@79e97a2) - GitHub * **deps**: bump serde from 1.0.162 to 1.0.163 (vectordotdev#17366) [9852c17](answerbook/vector@9852c17) - GitHub * **deps**: bump serde_json from 1.0.95 to 1.0.96 (vectordotdev#17258) [7570bb3](answerbook/vector@7570bb3) - GitHub * **deps**: bump serde_with from 2.3.1 to 2.3.2 (vectordotdev#17090) [adbf4d5](answerbook/vector@adbf4d5) - GitHub * **deps**: bump serde_yaml from 0.9.19 to 0.9.21 (vectordotdev#17120) [d6f2625](answerbook/vector@d6f2625) - GitHub * **deps**: bump socket2 from 0.4.7 to 0.5.2 (vectordotdev#17121) [db39d83](answerbook/vector@db39d83) - GitHub * **deps**: bump socket2 from 0.5.2 to 0.5.3 (vectordotdev#17384) [ac51b8a](answerbook/vector@ac51b8a) - GitHub * **deps**: bump syslog from 6.0.1 to 6.1.0 (vectordotdev#17301) [61e6154](answerbook/vector@61e6154) - GitHub * **deps**: bump tokio from 1.27.0 to 1.28.0 (vectordotdev#17231) [8067f84](answerbook/vector@8067f84) - GitHub * **deps**: bump tokio from 1.28.0 to 1.28.1 (vectordotdev#17368) [ae6a51b](answerbook/vector@ae6a51b) - GitHub * **deps**: bump tokio-stream from 0.1.12 to 0.1.14 (vectordotdev#17339) [80c8247](answerbook/vector@80c8247) - GitHub * **deps**: bump tokio-tungstenite from 0.18.0 to 0.19.0 (vectordotdev#17404) [ae1dd6e](answerbook/vector@ae1dd6e) - GitHub * **deps**: bump tonic from 0.8.3 to 0.9.1 (vectordotdev#17077) [eafba69](answerbook/vector@eafba69) - GitHub * **deps**: bump tonic from 0.9.1 to 0.9.2 (vectordotdev#17221) [aa9cbd0](answerbook/vector@aa9cbd0) - GitHub * **deps**: bump tonic-build from 0.8.4 to 0.9.2 (vectordotdev#17274) [e0a07c6](answerbook/vector@e0a07c6) - GitHub * **deps**: bump tracing-subscriber from 0.3.16 to 0.3.17 (vectordotdev#17268) [1406c08](answerbook/vector@1406c08) - GitHub * **deps**: bump typetag from 0.2.7 to 0.2.8 (vectordotdev#17302) [c8e0e5f](answerbook/vector@c8e0e5f) - GitHub * **deps**: bump uuid from 1.3.0 to 1.3.1 (vectordotdev#17091) [9cc2f1d](answerbook/vector@9cc2f1d) - GitHub * **deps**: bump uuid from 1.3.0 to 1.3.2 (vectordotdev#17256) [bc6f7fd](answerbook/vector@bc6f7fd) - GitHub * **deps**: bump uuid from 1.3.2 to 1.3.3 (vectordotdev#17403) [3a3fe63](answerbook/vector@3a3fe63) - GitHub * **deps**: bump warp from 0.3.4 to 0.3.5 (vectordotdev#17288) [d8c1f12](answerbook/vector@d8c1f12) - GitHub * **deps**: bump wasm-bindgen from 0.2.84 to 0.2.85 (vectordotdev#17356) [ea24b4d](answerbook/vector@ea24b4d) - GitHub * **deps**: bump wasm-bindgen from 0.2.85 to 0.2.86 (vectordotdev#17402) [0518176](answerbook/vector@0518176) - GitHub * **deps**: bump wiremock from 0.5.17 to 0.5.18 (vectordotdev#17092) [51312aa](answerbook/vector@51312aa) - GitHub * **deps**: Fix up missing license (vectordotdev#17379) [a2b8903](answerbook/vector@a2b8903) - GitHub * **deps**: Reset dependencies bumped by a61dea1 (vectordotdev#17100) [887d6d7](answerbook/vector@887d6d7) - GitHub * **deps**: true up cargo.lock (vectordotdev#17149) [10fce65](answerbook/vector@10fce65) - GitHub * **deps**: Update h2 (vectordotdev#17189) [a2882f3](answerbook/vector@a2882f3) - GitHub * **deps**: Upgrade cue to 0.5.0 (vectordotdev#17204) [d396320](answerbook/vector@d396320) - GitHub * **deps**: Upgrade Debian to bullseye for distroless image (vectordotdev#17160) [c304a8c](answerbook/vector@c304a8c) - GitHub * **deps**: Upgrade rust to 1.69.0 (vectordotdev#17194) [ef15696](answerbook/vector@ef15696) - GitHub * **dev**: Add note about generating licenses to CONTRIBUTING.md (vectordotdev#17410) [539f379](answerbook/vector@539f379) - GitHub * **dev**: ignore `.helix` dir (vectordotdev#17203) [32a935b](answerbook/vector@32a935b) - GitHub * **dev**: Install the correct `mold` based on CPU architecture (vectordotdev#17248) [4b80c71](answerbook/vector@4b80c71) - GitHub * **dev**: remove editors from gitignore (vectordotdev#17267) [61c0d76](answerbook/vector@61c0d76) - GitHub * **docs**: Add Enterprise link and update Support link (vectordotdev#17408) [5184d50](answerbook/vector@5184d50) - GitHub * **docs**: Add missing 0.28.2 version [38607cd](answerbook/vector@38607cd) - Jesse Szwedko * **docs**: Clarify `key_field` for `sample` and `throttle` transforms (vectordotdev#17372) [d1e5588](answerbook/vector@d1e5588) - GitHub * **docs**: Document event type conditions (vectordotdev#17311) [a9c8dc8](answerbook/vector@a9c8dc8) - GitHub * **docs**: make doc style edits (vectordotdev#17155) [65a8856](answerbook/vector@65a8856) - GitHub * **docs**: Remove trailing, unmatched quote (vectordotdev#17163) [3c92556](answerbook/vector@3c92556) - GitHub * **docs**: Remove unneeded `yaml` dependency from website (vectordotdev#17215) [752d424](answerbook/vector@752d424) - GitHub * **docs**: Update component statuses 2023Q2 (vectordotdev#17362) [22cda94](answerbook/vector@22cda94) - GitHub * **docs**: update the `v0.28.0` upgrade guide with note about `datadog_logs` sink `hostname` key (vectordotdev#17156) [c169131](answerbook/vector@c169131) - GitHub * **external docs**: correctly mark some sinks as stateful (vectordotdev#17085) [64d560d](answerbook/vector@64d560d) - GitHub * **loki sink**: warn on label expansions and collisions (vectordotdev#17052) [f06692b](answerbook/vector@f06692b) - GitHub * **pulsar**: pulsar-rs bump to v5.1.1 (vectordotdev#17159) [68b54a9](answerbook/vector@68b54a9) - GitHub * Re-add transform definitions (vectordotdev#17152) [9031d0f](answerbook/vector@9031d0f) - GitHub * Regen docs for sample and throttle (vectordotdev#17390) [6c57ca0](answerbook/vector@6c57ca0) - GitHub * **releasing**: Add known issues fixed by 0.29.1 (vectordotdev#17218) [40d543a](answerbook/vector@40d543a) - GitHub * **releasing**: Bump Vector version to 0.30.0 (vectordotdev#17134) [3834612](answerbook/vector@3834612) - GitHub * **releasing**: Fix homebrew release script (vectordotdev#17131) [cfbf233](answerbook/vector@cfbf233) - Jesse Szwedko * **releasing**: Fix release channels (vectordotdev#17133) [58b44e8](answerbook/vector@58b44e8) - Jesse Szwedko * **releasing**: Prepare v0.28.2 release [a61dea1](answerbook/vector@a61dea1) - Jesse Szwedko * **releasing**: Prepare v0.29.0 release [4bf6805](answerbook/vector@4bf6805) - Jesse Szwedko * **releasing**: Prepare v0.30.0 release [38c3f0b](answerbook/vector@38c3f0b) - Jesse Szwedko * **releasing**: Regenerate Kubernetes manifests for 0.21.2 (vectordotdev#17108) [fd13d64](answerbook/vector@fd13d64) - GitHub * **releasing**: Regenerate manifests for 0.21.1 chart (vectordotdev#17187) [1f0de6b](answerbook/vector@1f0de6b) - GitHub * **releasing**: Regenerate manifests for 0.22.0 chart (vectordotdev#17135) [e7ea0a8](answerbook/vector@e7ea0a8) - GitHub * **releasing**: update patch release template with extra step details [27c3526](answerbook/vector@27c3526) - GitHub * Remove skaffold from project (vectordotdev#17145) [d245927](answerbook/vector@d245927) - GitHub * remove transform type coercion (vectordotdev#17411) [b6c7e0a](answerbook/vector@b6c7e0a) - GitHub * Revert transform definitions (vectordotdev#17146) [05a3f44](answerbook/vector@05a3f44) - GitHub * **socket source**: Remove deprecated `max_length` setting from `tcp` and `unix` modes. (vectordotdev#17162) [9ecfc8c](answerbook/vector@9ecfc8c) - GitHub * **syslog source**: remove the remove of source_ip (vectordotdev#17184) [5dff0ed](answerbook/vector@5dff0ed) - GitHub * **topology**: Transform outputs hash table of OutputId -> Definition (vectordotdev#17059) [1bdb24d](answerbook/vector@1bdb24d) - GitHub * Upgrade `VRL` to `0.3.0` (vectordotdev#17325) [4911d36](answerbook/vector@4911d36) - GitHub ### Features * adds 'metric_name' field to internal logs for the tag_cardinality_limit component (vectordotdev#17295) [4317340](answerbook/vector@4317340) - GitHub * **codecs**: Add full codec support to AWS S3 source/sink (vectordotdev#17098) [d648c86](answerbook/vector@d648c86) - GitHub * **kubernetes_logs**: use kube-apiserver cache for list requests (vectordotdev#17095) [e46fae7](answerbook/vector@e46fae7) - GitHub * Merge with upstream v0.30.0 [6b93177](answerbook/vector@6b93177) - GitHub [LOG-17997](https://logdna.atlassian.net/browse/LOG-17997) * **new sink**: Initial `datadog_events` sink (vectordotdev#7678) [fef3810](answerbook/vector@fef3810) - Jesse Szwedko * Update VRL library [6ace1e6](answerbook/vector@6ace1e6) - Jorge Bay ### Miscellaneous * Merge branch 'master' [d4b35bb](answerbook/vector@d4b35bb) - Jorge Bay * Merge tag 'v0.30.0' into update-upstream [ee2f300](answerbook/vector@ee2f300) - Jorge Bay * Merge commit '9031d0faa2811187874364e1b5a3305c9ed0c0da' into update-upstream [c12faae](answerbook/vector@c12faae) - Jorge Bay * Improve tokio::select behavior for kafka source and finalizers (vectordotdev#17380) [d4df21c](answerbook/vector@d4df21c) - GitHub * Prepare v0.29.1 release [21beed7](answerbook/vector@21beed7) - Kyle Criddle * Add a quickfix to handle special capitalization cases (vectordotdev#17141) [ba63e21](answerbook/vector@ba63e21) - GitHub * Adjust doc comment locations (vectordotdev#17154) [730c938](answerbook/vector@730c938) - GitHub * **amqp sink**: Support AMQ Properties (content-type) in AMQP sink (vectordotdev#17174) [c10d30b](answerbook/vector@c10d30b) - GitHub * **aws provider**: Let `region` be configured for default authentication (vectordotdev#17414) [c81ad30](answerbook/vector@c81ad30) - GitHub * **core**: add unit test (ignored) for support for encoding special chars in `ProxyConfig` (vectordotdev#17148) [5247972](answerbook/vector@5247972) - GitHub * **loki sink**: Fix formatting in labels example (vectordotdev#17396) [f3734e8](answerbook/vector@f3734e8) - GitHub * **observability**: Log underlying error for unhandled HTTP errors (vectordotdev#17327) [bf8376c](answerbook/vector@bf8376c) - GitHub * **observability**: Update internal log rate limiting messages (vectordotdev#17394) [1951535](answerbook/vector@1951535) - GitHub * **pulsar sink**: Refactor to use StreamSink (vectordotdev#14345) [1e97a2f](answerbook/vector@1e97a2f) - GitHub * **topology**: Add source id to metadata (vectordotdev#17369) [c683999](answerbook/vector@c683999) - GitHub * **vdev**: Load compose files and inject network block (vectordotdev#17025) [5d88655](answerbook/vector@5d88655) - GitHub

Support AMQ Properties in AMQP sinks

8e917a8

arouene requested a review from StephenWakely as a code owner April 19, 2023 15:29

arouene requested a review from a team April 19, 2023 15:29

github-actions bot added the domain: sinks Anything related to the Vector's sinks label Apr 19, 2023

bruceg added type: enhancement A value-adding code change that enhances its existing functionality. sink: amqp Anything `amqp` sink related labels Apr 19, 2023

bruceg linked an issue Apr 19, 2023 that may be closed by this pull request

Support AMQP properties #17173

Closed

Refacto removing properties.rs

b2f58d9

StephenWakely requested changes Apr 20, 2023

View reviewed changes

src/sinks/amqp/config.rs Outdated Show resolved Hide resolved

src/sinks/amqp/sink.rs Show resolved Hide resolved

Update src/sinks/amqp/config.rs

c28c4c5

Co-authored-by: Stephen Wakely <[email protected]>

StephenWakely requested a review from a team April 20, 2023 13:43

spencergilbert approved these changes Apr 20, 2023

View reviewed changes

neuronull reviewed Apr 20, 2023

View reviewed changes

src/sinks/amqp/config.rs Outdated Show resolved Hide resolved

src/sinks/amqp/config.rs Outdated Show resolved Hide resolved

src/sinks/amqp/config.rs Outdated Show resolved Hide resolved

Aurélien Rouëné and others added 2 commits April 20, 2023 22:57

Update src/sinks/amqp/config.rs

2e84ee4

Co-authored-by: neuronull <[email protected]>

Update config.rs

d94bd50

Refacto for documentation consistency.

arouene requested a review from StephenWakely April 20, 2023 21:28

Rustfmt

e0614e8

StephenWakely requested changes Apr 21, 2023

View reviewed changes

neuronull approved these changes Apr 21, 2023

View reviewed changes

Generate component docs

160cdc1

github-actions bot added the domain: external docs Anything related to Vector's external, public documentation label Apr 21, 2023

spencergilbert requested a review from StephenWakely April 21, 2023 15:06

StephenWakely approved these changes Apr 24, 2023

View reviewed changes

StephenWakely merged commit c10d30b into vectordotdev:master Apr 24, 2023

arouene deleted the amqp_sink_support_content_type branch April 24, 2023 12:20

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

enhancement(amqp sink): Support AMQ Properties (content-type) in AMQP sink #17174

enhancement(amqp sink): Support AMQ Properties (content-type) in AMQP sink #17174

arouene commented Apr 19, 2023 •

edited

Loading

bits-bot commented Apr 19, 2023 •

edited

Loading

netlify bot commented Apr 19, 2023 •

edited

Loading

netlify bot commented Apr 19, 2023 •

edited

Loading

github-actions bot commented Apr 19, 2023

StephenWakely left a comment

spencergilbert left a comment

neuronull left a comment

github-actions bot commented Apr 21, 2023

StephenWakely left a comment

github-actions bot commented Apr 21, 2023

StephenWakely left a comment

enhancement(amqp sink): Support AMQ Properties (content-type) in AMQP sink #17174

enhancement(amqp sink): Support AMQ Properties (content-type) in AMQP sink #17174

Conversation

arouene commented Apr 19, 2023 • edited Loading

bits-bot commented Apr 19, 2023 • edited Loading

netlify bot commented Apr 19, 2023 • edited Loading

✅ Deploy Preview for vector-project ready!

netlify bot commented Apr 19, 2023 • edited Loading

✅ Deploy Preview for vrl-playground canceled.

github-actions bot commented Apr 19, 2023

Regression Detector Results

StephenWakely left a comment

Choose a reason for hiding this comment

spencergilbert left a comment

Choose a reason for hiding this comment

neuronull left a comment

Choose a reason for hiding this comment

github-actions bot commented Apr 21, 2023

Regression Detector Results

StephenWakely left a comment

Choose a reason for hiding this comment

github-actions bot commented Apr 21, 2023

Regression Detector Results

StephenWakely left a comment

Choose a reason for hiding this comment

arouene commented Apr 19, 2023 •

edited

Loading

bits-bot commented Apr 19, 2023 •

edited

Loading

netlify bot commented Apr 19, 2023 •

edited

Loading

netlify bot commented Apr 19, 2023 •

edited

Loading