diff --git a/gcn_monitor/kafka.py b/gcn_monitor/kafka.py index 888f005..e783b57 100644 --- a/gcn_monitor/kafka.py +++ b/gcn_monitor/kafka.py @@ -37,13 +37,12 @@ def parse_filenames(message): Returns ------- fileName: string - The Kafka topic corresponding to the notice type. - fileName: string - The Key for S3's put_object method, formatted as `topics///++.` defined at https://docs.confluent.io/kafka-connectors/s3-sink/current/overview.html#s3-object-names + The Key for S3's put_object method, formatted as `topics///++.bin` + This format for all returned names is defined at https://docs.confluent.io/kafka-connectors/s3-sink/current/overview.html#s3-object-names messageKeyFileName: string - The Key for S3's put_object method, formatted as `topics///++.` defined at https://docs.confluent.io/kafka-connectors/s3-sink/current/overview.html#s3-object-names + The Key for S3's put_object method, formatted as `topics///++..key.bin` headersFileName: string - The Key for S3's put_object method, formatted as `topics///++.` defined at https://docs.confluent.io/kafka-connectors/s3-sink/current/overview.html#s3-object-names + The Key for S3's put_object method, formatted as `topics///++..headers.json` Example