Gdzie ustawić maksymalny rozmiar wiadomości w Apache Kafka? - java, apache-kafka

W jakim pliku mogę zwiększyć maksymalny rozmiar wiadomości dla Kafki? (Wysyłam rekordy String, bajt [], a kiedy wysyłam bajt [] z 770kb Kafka nie wysyła wiadomości

Odpowiedzi:

W kafce 0.11.0 należy ustawić cztery opcje konfiguracji

Opcje konfiguracji brokera (Detale):

1. message.max.bytes - Największa wielkość partii rekordu dozwolona przez Kafkę.

2. replica.fetch.max.bytes - Liczba bajtów wiadomości do pobrania dla każdej partycji.

Opcje konfiguracji producenta (Detale):

1. max.request.size - Maksymalny rozmiar żądania w bajtach. Zaleca się dopasowanie tej wartości do (message.max.bytes).

Opcje konfiguracji konsumenta (Detale):

1. max.partition.fetch.bytes - maksymalna liczba bajtów na partycję zwrócona przez serwer. powinien być większy niż max.message.size, aby konsument mógł odczytać największą wiadomość wysłaną przez brokera.