about build_size_bytes

[xiaoliang-samsung]

bulkSize = XContentMapValues.nodeIntegerValue(indexSettings.get("bulk_size_bytes"), 10_1024_1024);

So if I input 10485760 as bulk size bytes ,the final bulk size would be 1?

[jatrost]

If you put 10485760 as the bulk size, then the bulk size fetched from Kafka would be set to 10MB. This value controls the size passed in the FetchRequest to Kafka.

Ref:

1. https://github.com/endgameinc/elasticsearch-river-kafka/blob/master/src/main/java/org/elasticsearch/river/kafka/KafkaClient.java#L101
2. https://github.com/kafka-dev/kafka/blob/master/core/src/main/scala/kafka/api/FetchRequest.scala#L37