diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-06 16:08:01 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-06 16:14:49 -0700 |
| commit | 868115c703afc4403adc8d9481bf31d2c15064dd (patch) | |
| tree | 335b0090cd382226b9b9f2edb39752b52b9c2234 /test/test_util.py | |
| parent | 3a4ceef3816e9ddfcb86099f691f72f1f60921cd (diff) | |
| download | kafka-python-868115c703afc4403adc8d9481bf31d2c15064dd.tar.gz | |
Raise an error if we attempt to group duplicate topic-partition payloads
- previously this would simply drop one of the payloads
Diffstat (limited to 'test/test_util.py')
| -rw-r--r-- | test/test_util.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/test/test_util.py b/test/test_util.py index 6a8f45b..ea3783e 100644 --- a/test/test_util.py +++ b/test/test_util.py @@ -108,7 +108,6 @@ class UtilTest(unittest.TestCase): l = [ t("a", 1), - t("a", 1), t("a", 2), t("a", 3), t("b", 3), @@ -124,3 +123,8 @@ class UtilTest(unittest.TestCase): 3: t("b", 3), } }) + + # should not be able to group duplicate topic-partitions + t1 = t("a", 1) + with self.assertRaises(AssertionError): + kafka.util.group_by_topic_and_partition([t1, t1]) |