Skip to content

MINOR: Add test for ConsumerNetworkClient.trySend#6739

Merged
hachikuji merged 2 commits intoapache:trunkfrom
lambdaliu:add_ConsumerNetworkClient_trySend_test
May 17, 2019
Merged

MINOR: Add test for ConsumerNetworkClient.trySend#6739
hachikuji merged 2 commits intoapache:trunkfrom
lambdaliu:add_ConsumerNetworkClient_trySend_test

Conversation

@lambdaliu
Copy link
Copy Markdown
Contributor

add test for the change of ConsumerNetworkClient.trySend in #6264,

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@hachikuji
Copy link
Copy Markdown
Contributor

retest this please

Copy link
Copy Markdown
Contributor

@hachikuji hachikuji left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for the test case. Left two small comments, but looks good otherwise.


consumerClient.trySend(time.milliseconds());
// only check one time when the node doesn't ready
assertEquals(checkCount.getAndSet(0), 1);
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: the expectation should be the first argument

*/
package org.apache.kafka.clients.consumer.internals;

import org.apache.kafka.clients.ClientRequest;
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This import was not needed, so checkstyle is failing.

@lambdaliu lambdaliu force-pushed the add_ConsumerNetworkClient_trySend_test branch from e99566a to 3e50e73 Compare May 17, 2019 02:36
Copy link
Copy Markdown
Contributor

@hachikuji hachikuji left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks, LGTM.

@hachikuji hachikuji merged commit 64c2d49 into apache:trunk May 17, 2019
@lambdaliu lambdaliu deleted the add_ConsumerNetworkClient_trySend_test branch May 18, 2019 04:10
pengxiaolong pushed a commit to pengxiaolong/kafka that referenced this pull request Jun 14, 2019
Reviewers: Jason Gustafson <jason@confluent.io>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants