luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

change operation name for the new metric

Browse source
This commit is contained in:
Qilin Jin 2021-12-02 10:41:05 -08:00
parent 2e0b9815cc
commit c85b1f42b7
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java
View file

@ -45,7 +45,7 @@ import software.amazon.kinesis.schemaregistry.SchemaRegistryDecoder;
@KinesisClientInternalApi @KinesisClientInternalApi
public class ProcessTask implements ConsumerTask { public class ProcessTask implements ConsumerTask {
private static final String PROCESS_TASK_OPERATION = "ProcessTask"; private static final String PROCESS_TASK_OPERATION = "ProcessTask";
private static final String APPLICATION_LEVEL_METRICS = "ApplicationLevelMetrics"; private static final String APPLICATION_TRACKER_OPERATION = "ApplicationTracker";
private static final String DATA_BYTES_PROCESSED_METRIC = "DataBytesProcessed"; private static final String DATA_BYTES_PROCESSED_METRIC = "DataBytesProcessed";
private static final String RECORDS_PROCESSED_METRIC = "RecordsProcessed"; private static final String RECORDS_PROCESSED_METRIC = "RecordsProcessed";
private static final String RECORD_PROCESSOR_PROCESS_RECORDS_METRIC = "RecordProcessor.processRecords"; private static final String RECORD_PROCESSOR_PROCESS_RECORDS_METRIC = "RecordProcessor.processRecords";
@ -113,7 +113,7 @@ public class ProcessTask implements ConsumerTask {
*/ */
@Override @Override
public TaskResult call() { public TaskResult call() {
final MetricsScope scope_app = MetricsUtil.createMetricsWithOperation(metricsFactory, APPLICATION_LEVEL_METRICS); final MetricsScope scope_app = MetricsUtil.createMetricsWithOperation(metricsFactory, APPLICATION_TRACKER_OPERATION);
final MetricsScope scope_shard = MetricsUtil.createMetricsWithOperation(metricsFactory, PROCESS_TASK_OPERATION); final MetricsScope scope_shard = MetricsUtil.createMetricsWithOperation(metricsFactory, PROCESS_TASK_OPERATION);
shardInfo.streamIdentifierSerOpt() shardInfo.streamIdentifierSerOpt()
.ifPresent(streamId -> MetricsUtil.addStreamId(scope_shard, StreamIdentifier.multiStreamInstance(streamId))); .ifPresent(streamId -> MetricsUtil.addStreamId(scope_shard, StreamIdentifier.multiStreamInstance(streamId)));

2
amazon-kinesis-client/src/test/java/software/amazon/kinesis/ApplicationTest.java
View file

@ -52,7 +52,7 @@ public class ApplicationTest {
String streamName1 = "consumer-level-metrics-1"; String streamName1 = "consumer-level-metrics-1";
String streamName2 = "consumer-level-metrics-2"; String streamName2 = "consumer-level-metrics-2";
String region = "us-east-2"; String region = "us-east-2";
String applicationName = "consumer-level-metrics-test"; String applicationName = "consumer-level-metrics-test-new";
new ApplicationTest(applicationName, streamName1, streamName2, region).run(); new ApplicationTest(applicationName, streamName1, streamName2, region).run();
} }