davidzollo commented on issue #8956: URL: https://github.com/apache/seatunnel/issues/8956#issuecomment-2749858530
There is a bug. If there is anybody who'd like to fix this issue, please leave a message. Kind reminder: Other guys can pick it up if the PR is not submitted within three weeks. Here are some helpful resources to get started: - [Contribution Setup Guide](https://seatunnel.apache.org/docs/contribution/setup) - [Code Submission Guide](https://seatunnel.apache.org/community/submit_guide/submit-code) By the way, since this might be your first contribution, I think we can have a more in-depth communication to help you get familiar with SeaTunnel. Feel free to contact me on LinkedIn ([David Zollo](https://www.linkedin.com/in/davidzollo)) or WeChat ID(davidzollo). When adding me, please let me know your GitHub ID. I'd be happy to assist you! The following is pseudo code for your reference. ``` public class KafkaSource implements SeaTunnelSource<SeaTunnelRow, KafkaSourceSplit, KafkaSourceState>, SupportParallelism { private static final String QUEUE_SIZE_KEY = "queue.size"; private static final int DEFAULT_QUEUE_SIZE = 1000; ... public SourceReader<SeaTunnelRow, KafkaSourceSplit> createReader( SourceReader.Context readerContext) { int queueSize = config.getInt(QUEUE_SIZE_KEY, DEFAULT_QUEUE_SIZE); BlockingQueue<RecordsWithSplitIds<ConsumerRecord<byte[], byte[]>>> elementsQueue = new ArrayBlockingQueue<>(queueSize); ... } } ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
