feat: add partitions to PRINT TOPIC output

confluentinc · Nov 18, 2020 · c9102ac · c9102ac
1 parent 976c852
commit c9102ac
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-app/src/main/java/io/confluent/ksql/rest/server/resources/streaming/RecordFormatter.java b/...-app/src/main/java/io/confluent/ksql/rest/server/resources/streaming/RecordFormatter.java
@@ -157,7 +157,8 @@ private List<String> formatRecords(final Iterable<ConsumerRecord<Bytes, Bytes>>
   private String formatRecord(final ConsumerRecord<Bytes, Bytes> record) {
     return "rowtime: " + formatRowTime(record.timestamp())
         + ", " + "key: " + keyDeserializers.format(record.key())
-        + ", value: " + valueDeserializers.format(record.value());
+        + ", value: " + valueDeserializers.format(record.value())
+        + ", partition: " + record.partition();
   }
 
   private static String formatRowTime(final long timestamp) {