ingestion-beam/src/main/java/com/mozilla/telemetry/io/Write.java [315:322]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      this(topic, compression, Integer.MAX_VALUE);
    }

    @Override
    public WithFailures.Result<PDone, PubsubMessage> expand(PCollection<PubsubMessage> input) {
      PDone done = input //
          .apply(CompressPayload.of(compression).withMaxCompressedBytes(maxCompressedBytes)) //
          .apply(PubsubConstraints.truncateAttributes()) //
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



ingestion-beam/src/main/java/com/mozilla/telemetry/io/Write.java [344:351]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      this(topic, compression, Integer.MAX_VALUE);
    }

    @Override
    public WithFailures.Result<PDone, PubsubMessage> expand(PCollection<PubsubMessage> input) {
      PDone done = input //
          .apply(CompressPayload.of(compression).withMaxCompressedBytes(maxCompressedBytes)) //
          .apply(PubsubConstraints.truncateAttributes()) //
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -