You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2020/10/20 05:59:09 UTC

[kafka] branch trunk updated: MINOR: Remove unnecessary assertion from ConnectHeader (#9452)

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 8f96c34  MINOR: Remove unnecessary assertion from ConnectHeader (#9452)
8f96c34 is described below

commit 8f96c3450feaf40758bb968833475ee2c3ef20c3
Author: jackyoh <ja...@is-land.com.tw>
AuthorDate: Tue Oct 20 13:58:02 2020 +0800

    MINOR: Remove unnecessary assertion from ConnectHeader (#9452)
    
    Reviewers: Chia-Ping Tsai <ch...@gmail.com>
---
 .../api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java | 1 -
 1 file changed, 1 deletion(-)

diff --git a/connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java b/connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java
index ed4be09..3b9f347 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java
@@ -36,7 +36,6 @@ class ConnectHeader implements Header {
         Objects.requireNonNull(key, "Null header keys are not permitted");
         this.key = key;
         this.schemaAndValue = schemaAndValue != null ? schemaAndValue : NULL_SCHEMA_AND_VALUE;
-        assert this.schemaAndValue != null;
     }
 
     @Override