Hi
I'm using: org.apache.kafka:connect-api:3.4.0
I have a simple connector:
======
public class SimpleSinkConnector extends SinkConnector {
@Override
public List<Map<String, String>> taskConfigs(int maxTasks) {
ArrayList<Map<String, String>> configs = new ArrayList<>();
for (int i = 0; i < maxTasks; i++) {
configs.add(new HashMap<>());
}
return configs;
}
======
I don't have config params (POC). So, for testing purposes I just returned the
ArrayList. It took me now 2 hours to figure out why no Task was created. At the
end of the day: I added the for loop - then it worked. Reproduced the behavior
several times.
Can anybody conform this strange behavior? I would expect an exception if
something is expected ...
Thanks
Michael
________________________________
BearingPoint GmbH
Sitz: Wien
Firmenbuchgericht: Handelsgericht Wien
Firmenbuchnummer: FN 175524z
The information in this email is confidential and may be legally privileged. If
you are not the intended recipient of this message, any review, disclosure,
copying, distribution, retention, or any action taken or omitted to be taken in
reliance on it is prohibited and may be unlawful. If you are not the intended
recipient, please reply to or forward a copy of this message to the sender and
delete the message, any attachments, and any copies thereof from your system.
