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:33 UTC
[kafka] branch 2.0 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.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.0 by this push:
new 4baf0af MINOR: Safe string conversion to avoid NPEs
4baf0af is described below
commit 4baf0afd0478392308d55052266762b3faafe516
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 2b5d75c..4aa7d5a 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 +
'}';