apache / apache/beam

[Bug]: Add a Python Kafka read test that uses the with_metadata option

Open
#23,314 3 comments 0 reactions 0 assignees View on GitHub
bug io kafka P2 python
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

### What happened?

Python Kafka with_metadata option [1] uses a transform in Java side [2] that is not invoked by regular Python KafkaIO tests. So we need a separate test for this.

[1] https://github.com/apache/beam/blob/d578e3df7c963e57f251fb27739fbc1d3811e722/sdks/python/apache_beam/io/kafka.py#L162

[2] https://github.com/apache/beam/blob/d578e3df7c963e57f251fb27739fbc1d3811e722/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L1781

### Issue Priority

Priority: 2

### Issue Component

Component: io-py-kafka

Contributor guide

Open the contributing guide

Research direction

Start with the with_metadata option in sdks/python/apache_beam/io/kafka.py and the related transform in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java. Read the existing Python KafkaIO tests and add a separate Kafka read test that invokes with_metadata. Done means the Python test exercises the Java-side transform that regular KafkaIO tests miss.

Written by the indexing model from the issue text.

Assessment

Tech stack
java, kafka, python
Domain
stream-processing, testing
Issue type
Bug
Difficulty
3/5
Estimated time
1-2 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
45/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.