sudeshwasnik commented on code in PR #14966:
URL: https://github.com/apache/kafka/pull/14966#discussion_r1424444423
##########
connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java:
##########
@@ -70,74 +80,115 @@ public class OffsetsApiIntegrationTest {
private static final long OFFSET_COMMIT_INTERVAL_MS =
TimeUnit.SECONDS.toMillis(1);
private static final long OFFSET_READ_TIMEOUT_MS =
TimeUnit.SECONDS.toMillis(30);
private static final int NUM_WORKERS = 3;
- private static final String CONNECTOR_NAME = "test-connector";
- private static final String TOPIC = "test-topic";
private static final int NUM_TASKS = 2;
private static final int NUM_RECORDS_PER_PARTITION = 10;
- private Map<String, String> workerProps;
- private EmbeddedConnectCluster.Builder connectBuilder;
+ private static final Map<Map<String, String>, EmbeddedConnectCluster>
CONNECT_CLUSTERS = new ConcurrentHashMap<>();
+ @Rule
+ public TestName currentTest = new TestName();
private EmbeddedConnectCluster connect;
+ private String connectorName;
+ private String topic;
@Before
public void setup() {
- Properties brokerProps = new Properties();
- brokerProps.put("transaction.state.log.replication.factor", "1");
- brokerProps.put("transaction.state.log.min.isr", "1");
-
- // setup Connect worker properties
- workerProps = new HashMap<>();
- workerProps.put(OFFSET_COMMIT_INTERVAL_MS_CONFIG,
String.valueOf(OFFSET_COMMIT_INTERVAL_MS));
-
- // build a Connect cluster backed by Kafka and Zk
- connectBuilder = new EmbeddedConnectCluster.Builder()
- .name("connect-cluster")
- .numWorkers(NUM_WORKERS)
- .brokerProps(brokerProps)
- .workerProps(workerProps);
+ connectorName = currentTest.getMethodName();
+ topic = currentTest.getMethodName();
+ connect = defaultConnectCluster();
}
@After
public void tearDown() {
- connect.stop();
+ Set<String> remainingConnectors = new HashSet<>(connect.connectors());
+ if (remainingConnectors.remove(connectorName)) {
+ connect.deleteConnector(connectorName);
+ }
+ try {
Review Comment:
line 102 -> `remainingConnectors.remove(connectorName)` will remove elements
anyways, so line-106's assertEquals will always be true - so the assertion is
pointless. Which I thought wasn't okayy.
but your point is valid too! feel free to resolve this comment
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
