GitHub user shivsantham opened a pull request:
https://github.com/apache/kafka/pull/4109
KAFKA-6024 - Move validation in KafkaConsumer ahead of acquireAndEnsuâ¦
In several methods, parameter validation is done after calling
acquireAndEnsureOpen() in Kafka Consumer :
public void seek(TopicPartition partition, long offset) {
acquireAndEnsureOpen();
try {
if (offset < 0)
throw new IllegalArgumentException("seek offset must not be
a negative number");
Since the value of parameter would not change per invocation, it seems
performing validation ahead of acquireAndEnsureOpen() call would be better.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/shivsantham/kafka kafka-6024
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/4109.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4109
----
commit 79b6fbcff617f6412798d6395b3378df5dd601ed
Author: siva santhalingam <siva.santhalin...@gmail.com>
Date: 2017-10-21T07:05:03Z
KAFKA-6024 - Move validation in KafkaConsumer ahead of
acquireAndEnsureOpen()
----
---
