apache / apache/hop

[Task]: How to use "Beam Kafka Consume"?

Open
#2,447 5 comments 0 reactions 0 assignees View on GitHub
awaiting triage Beam P3
Dominant language
Java
Stars
1.5k
Forks
476
Avg merge
19h
Merged PRs (30d)
227

Description

### What needs to happen?

I filled the form as such:
![image](https://user-images.githubusercontent.com/87799321/220127998-2a0c2255-47b4-4928-bfee-b2279e43ddd1.png)

there is no erro in logs , but also nothing happened .

kafka gui shows that the 's' group is empty.
![image](https://user-images.githubusercontent.com/87799321/220129366-0ce97a34-e87d-4ebb-a1ae-b3e5693902d4.png)

### Issue Priority

Priority: 3

### Issue Component

Component: Beam

Contributor guide

Open the contributing guide

Research direction

Start by reviewing the Beam Kafka Consume configuration shown in the issue screenshots and reproduce it with Kafka's GUI. Check whether the consumer group receives records and determine why the component produces no visible output; done means the configuration consumes records or the issue clearly documents the failing condition.

Written by the indexing model from the issue text.

Assessment

Tech stack
java, kafka
Domain
stream-processing
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
25/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.