KIP-160 — Augment KStream.print(), KStream.writeAsText() to allow users pass in extra parameters in the printed string
Accepted Kafka 1.0 Streams
KIP-160 adds overloads to `KStream.print()` and `KStream.writeAsText()` that accept a `KeyValueMapper<K, V, String>` so callers can produce custom-formatted output strings instead of the fixed `[key, value]` default. The hardcoded format prevents users from emitting contextually useful representations (e.g. including a timestamp prefix or field projection) without forking Streams internals.
Details
| Author | jameschien |
| Status | Accepted |
| Kafka Version | 1.0 |
| JIRA | KAFKA-4830 |
| Wiki | View on Apache Wiki |
| Created | 2017-05-22 |
| Last Modified | 2017-07-06 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.