tree 6bfd78aa669fafd0ebcb9c50adce529ec8c73ac3
parent a1dca8c4e31eb6522bc40e2de4882be74266a657
author Miloš Matijašević <milosmatijasevic2015@gmail.com> 1611630292 +0100
committer GitHub <noreply@github.com> 1611630292 +0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJgD4bUCRBK7hj4Ov3rIwAAdHIIAHJw/YtrbNvRIv59RF5SLAzV
 lhs1Ju1Tw/sEapFiBh144dIVERaUIZ0hqJ6kHPnAXuYl5KCB97TL+iD4ZITFTeOU
 aFUIW8J4XGg6HR6vJsQUmKdFbJmudYCGNwtvfWT67G36PyAdJz4vx2UofgTMSIIK
 W2rLP1qN3VHL7fNiZFX5xI/mt6LpVuvH5b+GXZFFYT5EQM81PEjtFYbxrt+6/ulG
 0k59uFu8Shrgy7LZaWHqq36JZvd9OORxiyFsD6QLEvulcNf0t7J47ImOFB8K9ntg
 qVnMQavNwrCD8fFWsqfpID3c7hihMf99nDr955LxDv0O4gzP/x6P+kxpzzL9l0I=
 =ppPo
 -----END PGP SIGNATURE-----
 

Clearing message queues after seek requests (#419)

### Motivation

Message queues should be cleared after seek requests (`Seek` and `SeekByTime`). If this is not performed messages that stay in message queues will be consumed before the sough message.

### Modifications

Cleaning `queueCh` and `messageCh` after successful seek request in partition_consumer.go.

### Verifying this change

- [x] Make sure that the change passes the CI checks.

This change is already covered by existing tests, such as `TestConsumerSeekByTime` and `TestConsumerSeek`.

This change added tests and can be verified as follows:

  - Extended `TestConsumerSeekByTime` and `TestConsumerSeek` test for consuming correctly sought message even if some messages stay in message queues.


Signed-off-by: milos-matijasevic <milosmatijasevic2015@gmail.com>