Skip to content

MINOR: Move testCallInFlightTimeouts to Java and remove internal factory hack#22220

Open
JiayaoS wants to merge 1 commit intoapache:trunkfrom
JiayaoS:feature/AdminClientTimeoutIntegrationTest
Open

MINOR: Move testCallInFlightTimeouts to Java and remove internal factory hack#22220
JiayaoS wants to merge 1 commit intoapache:trunkfrom
JiayaoS:feature/AdminClientTimeoutIntegrationTest

Conversation

@JiayaoS
Copy link
Copy Markdown
Contributor

@JiayaoS JiayaoS commented May 6, 2026

Moves testCallInFlightTimeouts from the Scala core module to a new
Java AdminClientTimeoutIntegrationTest in clients-integration-tests.
By placing the test in the org.apache.kafka.clients.admin package, it
can directly access KafkaAdminClient.createInternal(). This allows us
to:

  1. Delete the KafkaAdminClientInternalFactory backdoor, restoring
    proper encapsulation.
  2. Inline FailureInjectingTimeoutProcessorFactory into the test class,
    reducing test fixture clutter.

@github-actions github-actions Bot added triage PRs from the community core Kafka Broker clients labels May 6, 2026
@JiayaoS JiayaoS changed the title MINOR: Move AdminClient timeout test to Java and remove internal factory hack MINOR: Move testCallInFlightTimeouts to Java and remove internal factory hack May 6, 2026
@JiayaoS JiayaoS force-pushed the feature/AdminClientTimeoutIntegrationTest branch from c10fd1a to 865e133 Compare May 6, 2026 04:29
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

ci-approved clients core Kafka Broker triage PRs from the community

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants