apache / apache/druid

Missing integration tests for Kafka/Kinesis indexing services

Open
#7,245 0 comments 1 reaction 0 assignees View on GitHub
Area - Streaming Ingestion Area - Testing
Dominant language
Java
Stars
14.1k
Forks
3.8k
Avg merge
2d 58m
Merged PRs (30d)
233

Description

Currently we have only an integration for Kafka indexing service with non-transactional topics. It would be nice if we can test it with transactional topics too.

For Kinesis indexing service, we don't have any yet. I'm considering https://github.com/localstack/localstack to set up test environment for kinesis because it seems to be able to run in a docker container and easy to integrate with Java codes.

Contributor guide

Open the contributing guide

Research direction

Start by locating the existing Kafka indexing-service integration for non-transactional topics and identify how its test environment is configured. Then investigate the Kinesis indexing service and whether LocalStack in a Docker container can support Java integration tests. Done means transactional Kafka coverage and an integration test for Kinesis indexing.

Written by the indexing model from the issue text.

Assessment

Tech stack
docker, java, kafka
Domain
data-engineering, stream-processing, testing
Issue type
Feature
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.