Skip to content

Commit 68b3d2b

Browse files
committed
Consumer commit fix
1 parent 5675261 commit 68b3d2b

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

src/karapace/kafka_rest_apis/consumer_manager.py

+3-1
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
Copyright (c) 2023 Aiven Ltd
33
See LICENSE for details
44
"""
5+
56
import traceback
67

78
from aiokafka.errors import (
@@ -10,7 +11,8 @@
1011
KafkaConfigurationError,
1112
KafkaError,
1213
TopicAuthorizationFailedError,
13-
UnknownTopicOrPartitionError, UnknownError,
14+
UnknownTopicOrPartitionError,
15+
UnknownError,
1416
)
1517
from asyncio import Lock
1618
from collections import defaultdict, namedtuple

tests/integration/kafka_rest_apis/test_rest_consumer.py

+1-5
Original file line numberDiff line numberDiff line change
@@ -294,11 +294,7 @@ async def test_offsets_no_payload(rest_async_client, admin_client, producer, tra
294294
producer.flush()
295295

296296
# Commit should not throw any error, even before consuming events
297-
res = await rest_async_client.post(
298-
offsets_path,
299-
headers=header,
300-
json={}
301-
)
297+
res = await rest_async_client.post(offsets_path, headers=header, json={})
302298
assert res.ok, f"Expected a successful response: {res}"
303299

304300
resp = await rest_async_client.get(consume_path, headers=header)

0 commit comments

Comments
 (0)