1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
Description: Fix memory alignment of int64 variable used as atomic. This fixes
a test crash on 32-bit architectures.
Forwarded: https://github.com/Shopify/sarama/pull/874
Bug-Debian: https://bugs.debian.org/860705
Author: David Lazăr <dlazar@gmail.com>
---
--- golang-github-shopify-sarama.orig/mocks/consumer.go 2017-05-06 10:49:51.609417526 +0000
+++ golang-github-shopify-sarama/mocks/consumer.go 2016-05-16 18:24:53.000000000 +0000
@@ -162,6 +162,7 @@
// Errors and Messages channel, you should specify what values will be provided on these
// channels using YieldMessage and YieldError.
type PartitionConsumer struct {
+ highWaterMarkOffset int64
l sync.Mutex
t ErrorReporter
topic string
@@ -173,7 +174,6 @@
consumed bool
errorsShouldBeDrained bool
messagesShouldBeDrained bool
- highWaterMarkOffset int64
}
///////////////////////////////////////////////////
|
