kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkConnector.java [12:25]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private Map<String, String> props;

  @Override
  public String version() {
    return AppInfoParser.getVersion();
  }

  @Override
  public void start(Map<String, String> map) {
    props = map;
  }

  @Override
  public Class<? extends Task> taskClass() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PubSubLiteSourceConnector.java [13:26]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private Map<String, String> props;

  @Override
  public String version() {
    return AppInfoParser.getVersion();
  }

  @Override
  public void start(Map<String, String> map) {
    props = map;
  }

  @Override
  public Class<? extends Task> taskClass() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -