[kafka] branch trunk updated: MINOR: revise error message from TransactionalRequestResult#await (#9843)

[chia7712]

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 e5733f3  MINOR: revise error message from 
TransactionalRequestResult#await (#9843)
e5733f3 is described below

commit e5733f3aded628551843f8a738ca2e794671d6b6
Author: Chia-Ping Tsai <chia7...@gmail.com>
AuthorDate: Fri Jan 8 12:07:49 2021 +0800

    MINOR: revise error message from TransactionalRequestResult#await (#9843)
    
    Reviewers: Gwen Shapira <csh...@gmail.com>
---
 .../kafka/clients/producer/internals/TransactionalRequestResult.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java
 
b/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java
index 9881fe8..d442b18 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java
@@ -71,7 +71,7 @@ public final class TransactionalRequestResult {
                 throw error();
             }
             if (!success) {
-                throw new TimeoutException("Timeout expired after " + timeout 
+ unit.name().toLowerCase(Locale.ROOT) + " while awaiting " + operation);
+                throw new TimeoutException("Timeout expired after " + timeout 
+ " " + unit.name().toLowerCase(Locale.ROOT) + " while awaiting " + operation);
             }
         } catch (InterruptedException e) {
             throw new InterruptException("Received interrupt while awaiting " 
+ operation, e);