feat: Added an implementation of Kafka Binding#114

Merged

dazuma merged 18 commits intocloudevents:mainfrom

dazuma:pr/kafka

Feb 10, 2026

Commits on Feb 9, 2026

feat: Add KafkaBinding skeleton with constructor and formatter registration

dazuma
and
claude
committed
feat: Add KafkaBinding#probable_event? method

dazuma
and
claude
committed
feat: Add KafkaBinding binary mode decode_event

dazuma
and
claude
committed
feat: Add KafkaBinding structured mode decode_event

dazuma
and
claude
committed
feat: Add KafkaBinding binary mode encode_event

dazuma
and
claude
committed
feat: Add KafkaBinding structured mode encode_event

dazuma
and
claude
committed
test: Add KafkaBinding round-trip tests

dazuma
and
claude
committed
tests: Implement Cucumber step definitions for Kafka protocol binding

dazuma
and
claude
committed
fix: Resolve rubocop violations in KafkaBinding

dazuma
and
claude
committed
chore: Add KafkaBinding to CLAUDE.md architecture section

dazuma
and
claude
committed
tests: Simplify round-trip partitionkey assertion to use event equality

dazuma
and
claude
committed
chore: Add comments to KafkaBinding private methods

dazuma
and
claude
committed
fix: Use ContentType parser in KafkaBinding#probable_event?

dazuma
and
claude
committed
feat: Raise BatchNotSupportedError for batch content in KafkaBinding

dazuma
and
claude
committed
fix: Reject CloudEvents 0.3 in KafkaBinding structured mode decode

dazuma
and
claude
committed
fix: Reject non-V1 events in KafkaBinding#encode_event

dazuma
and
claude
committed
fix: Update spec_version checks
dazuma
committed

Commits on Feb 10, 2026

fix: Fix logic in specversion checks
dazuma
committed