You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2018/12/05 21:24:21 UTC
[kafka] branch 2.1 updated: MINOR: Safe string conversion to avoid
NPEs
This is an automated email from the ASF dual-hosted git repository.
ewencp pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.1 by this push:
new fe2bd8e MINOR: Safe string conversion to avoid NPEs
fe2bd8e is described below
commit fe2bd8ede410373a6f32839efe2ab6e60c03a773
Author: Cyrus Vafadari <cy...@confluent.io>
AuthorDate: Wed Dec 5 13:23:52 2018 -0800
MINOR: Safe string conversion to avoid NPEs
Should be ported back to 2.0
Author: Cyrus Vafadari <cy...@confluent.io>
Reviewers: Ewen Cheslack-Postava <ew...@confluent.io>
Closes #6004 from cyrusv/cyrus-npe
(cherry picked from commit 9f954ac614cd5dd7efbcabe34799207128f16e63)
Signed-off-by: Ewen Cheslack-Postava <me...@ewencp.org>
---
.../main/java/org/apache/kafka/connect/connector/ConnectRecord.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java b/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
index 55272c2..03326cc 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
@@ -140,9 +140,9 @@ public abstract class ConnectRecord<R extends ConnectRecord<R>> {
"topic='" + topic + '\'' +
", kafkaPartition=" + kafkaPartition +
", key=" + key +
- ", keySchema=" + keySchema.toString() +
+ ", keySchema=" + keySchema +
", value=" + value +
- ", valueSchema=" + valueSchema.toString() +
+ ", valueSchema=" + valueSchema +
", timestamp=" + timestamp +
", headers=" + headers +
'}';