add Kafka Metric protobuf

controller-api/src/main/proto/responsive/metrics/v1/metrics.proto

@@ -0,0 +1,30 @@
+syntax = "proto3";
+
+package responsive.metrics.v1.metrics.proto;
+
+import "opentelemetry/proto/resource/v1/resource.proto";
+import "opentelemetry/proto/metrics/v1/metrics.proto";
+
+option java_multiple_files = true;
+option java_package = "dev.responsive.metrics.v1";
+
+// a globally unique identifier for a resource in Responsive's
+// metrics ecosystem
+message TenantResource {
+  // the tenant in our system (organization ID) - we can always
+  // create a dedicated internal tenant for metrics that do not
+  // belong to any particular tenant
+  string tenant = 1;
+
+  // the resource (the entity in the system that reported the
+  // metrics that are collected)
+  opentelemetry.proto.resource.v1.Resource resource = 2;
+}
+
+// a metric that is reported from Responsive, for now this is
+// just a simple wrapper over the open telemetry definition of
+// a Resource Metrics. It is expected, though not enforced, that
+// the metrics.resource here matches the TenantResource.resource
+message ExportedMetric {
+  opentelemetry.proto.metrics.v1.ResourceMetrics metrics = 1;
+}

kafka-client/src/main/java/dev/responsive/kafka/internal/metrics/exporter/otel/OtelMetricsService.java

@@ -31,6 +31,7 @@
 import io.opentelemetry.instrumentation.jmx.yaml.JmxConfig;
 import io.opentelemetry.instrumentation.jmx.yaml.JmxRule;
 import io.opentelemetry.instrumentation.jmx.yaml.RuleParser;
+import io.opentelemetry.instrumentation.resources.ContainerResource;
 import io.opentelemetry.sdk.OpenTelemetrySdk;
 import io.opentelemetry.sdk.metrics.SdkMeterProvider;
 import io.opentelemetry.sdk.metrics.export.PeriodicMetricReader;
@@ -83,15 +84,18 @@ public static OtelMetricsService create(
         .build();
 
     final var appId = ConfigUtils.responsiveAppId(streamsConfig, config);
-    final var attributes = Attributes
-        .builder()
-        .put(SERVICE_NAME_ATTR, appId + "-otel")
-        .put(RESPONSIVE_APPLICATION_ID_ATTR, appId)
-        .build();
+    final var resource = Resource
+        .empty() // the .default() one has attributes we don't care about
+        .merge(ContainerResource.get())
+        .merge(Resource.create(
+            Attributes.builder()
+                .put(SERVICE_NAME_ATTR, appId + "-otel")
+                .put(RESPONSIVE_APPLICATION_ID_ATTR, appId)
+                .build()));
 
     final var meterProvider = SdkMeterProvider
         .builder()
-        .setResource(Resource.create(attributes))
+        .setResource(resource)
         .registerMetricReader(metricReader)
         .build();
 

settings.gradle.kts

@@ -91,13 +91,15 @@ dependencyResolutionManagement {
             library("otel-exporter-logging", "io.opentelemetry:opentelemetry-exporter-logging:1.32.0");
             library("otel-exporter-otlp", "io.opentelemetry:opentelemetry-exporter-otlp:1.32.0");
             library("otel-jmx", "io.opentelemetry.instrumentation:opentelemetry-jmx-metrics:1.32.0-alpha")
+            library("otel-resource", "io.opentelemetry.instrumentation:opentelemetry-resources:1.32.0-alpha")
             bundle("otel", listOf(
                     "otel-api",
                     "otel-sdk",
                     "otel-sdk-metrics",
                     "otel-exporter-logging",
                     "otel-exporter-otlp",
                     "otel-jmx",
+                    "otel-resource"
             ))
 
             // do not include these in jars that are distributed - these