Skip to content

Commit af6eb92

Browse files
committed
chore: upgrade to kafka_protocol-4.2.9
1 parent d45c4cf commit af6eb92

3 files changed

Lines changed: 4 additions & 3 deletions

File tree

changelog.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
* 4.1.0
22
- Fix 'failed' telemetry counter double-increment due to race condition. [#102](https://github.com/kafka4beam/wolff/pull/102)
33
- Added producer process label `{wolff_producer, KafkaClientId, Topic, Partition}` [#102](https://github.com/kafka4beam/wolff/pull/102)
4+
- Upgrade to `kafka_protocol-4.2.9` for better CRC32C performance.
45

56
* 4.0.13 (merge 1.5.19)
67
- Handle `record_list_too_large` error returned from Kafka.

rebar.config

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
{deps, [ {kafka_protocol, "4.2.8"}
1+
{deps, [ {kafka_protocol, "4.2.9"}
22
, {replayq, "0.4.1"}
33
, {lc, "0.3.5"}
44
, {telemetry, "1.1.0"}

test/wolff_tests.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1030,8 +1030,8 @@ batch_bytes(Batch) ->
10301030
wolff_producer:batch_bytes(Batch).
10311031

10321032
encoded_bytes(Batch) ->
1033-
Encoded = kpro_batch:encode(2, Batch, no_compression),
1034-
iolist_size(Encoded).
1033+
{Bytes, _Encoded} = kpro_batch:encode(2, Batch, no_compression),
1034+
Bytes.
10351035

10361036
create_topic(Topic, Partitions, ReplicationFactor, MaxMessageBytes, SegmentBytes) ->
10371037
Cmd = create_topic_cmd(Topic, Partitions, ReplicationFactor, MaxMessageBytes, SegmentBytes),

0 commit comments

Comments
 (0)