Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Zihan Li committed Oct 28, 2023
1 parent e9f2620 commit 0821b9f
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ public class KafkaTopicGroupingWorkUnitPacker extends KafkaWorkUnitPacker {
public static final String DEFAULT_NUM_TOPIC_PARTITIONS_PER_CONTAINER_KEY = GOBBLIN_KAFKA_PREFIX + "default.num.topic.partitions.per.container";
private static final int DEFAULT_DEFAULT_NUM_TOPIC_PARTITIONS_PER_CONTAINER = 10;

//A global configuration for container capacity. The container capacity refers to the peak rate (in MB/s) that agit
//A global configuration for container capacity. The container capacity refers to the peak rate (in MB/s) that a
//single JVM can consume from Kafka for a single topic and controls the number of partitions of a topic that will be
// packed into a single workunit. For example, if the container capacity is set to 10, and each topic partition has a
// weight of 1, then 10 partitions of the topic will be packed into a single workunit. This configuration is topic-independent
Expand Down

0 comments on commit 0821b9f

Please sign in to comment.