Skip to content

Commit 09ffb03

Browse files
authored
Enhance stdout exporter to include trace id (#1504)
1 parent 08308da commit 09ffb03

File tree

2 files changed

+5
-4
lines changed
  • runtime/exporter-stdout/src

2 files changed

+5
-4
lines changed

runtime/exporter-stdout/src/main/java/io/aklivity/zilla/runtime/exporter/stdout/internal/stream/StdoutEventsStream.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,8 @@
2929

3030
public class StdoutEventsStream
3131
{
32-
// {zilla namespace}:{component name} [dd/MMM/yyyy:HH:mm:ss Z] {event name} {event body}\n
33-
private static final String FORMAT = "%s [%s] %s %s%n";
32+
// {zilla namespace}:{component name} [dd/MMM/yyyy:HH:mm:ss Z] [trace id] {event name} {event body}\n
33+
private static final String FORMAT = "%s [%s] [%016xd] %s %s%n";
3434
private static final DateTimeFormatter FORMATTER = DateTimeFormatter.ofPattern("dd/MMM/yyyy:HH:mm:ss Z");
3535

3636
private final StdoutExporterContext context;
@@ -62,9 +62,10 @@ private void handleEvent(
6262
{
6363
final EventFW event = eventRO.wrap(buffer, index, index + length);
6464
String qname = context.supplyQName(event.namespacedId());
65+
long traceId = event.traceId();
6566
String eventName = context.supplyEventName(event.id());
6667
String extension = formatter.format(msgTypeId, buffer, index, length);
67-
out.format(FORMAT, qname, asDateTime(event.timestamp()), eventName, extension);
68+
out.format(FORMAT, qname, asDateTime(event.timestamp()), traceId, eventName, extension);
6869
}
6970

7071
private static String asDateTime(

runtime/exporter-stdout/src/test/java/io/aklivity/zilla/runtime/exporter/stdout/internal/events/EventIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,6 @@ public class EventIT
6363
public void shouldLogEvents() throws Exception
6464
{
6565
k3po.finish();
66-
output.expect(Pattern.compile("test.net0 \\[[^\\]]+\\] BINDING_TEST_CONNECTED test event message\n"));
66+
output.expect(Pattern.compile("test.net0 \\[[^\\]]+\\] \\[[^\\]]+\\] BINDING_TEST_CONNECTED test event message\n"));
6767
}
6868
}

0 commit comments

Comments
 (0)