Czy można odczytać wiadomości od brokera 0.9.0 za pomocą KafkaConsumer wersji 0.10.0?
Czytając dokumentację widzę opisjak uaktualnić brokerów od 0.9 do 0.10 w taki sposób, aby kontynuować pracę z istniejącymi dziennikami. Brokerowi można nawet poinstruować, aby nadal wysyłał 0,9 wiadomości do starych klientów.
Ale szukam odwrotnie: nowy konsument, stary broker.
Naiwne próby, otrzymuję wyjątek:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field "topic_metadata": Error reading array of size 1142898, only 2701 bytes available
Czy istnieje sposób na poinformowanie konsumenta 0.10.0, aby oczekiwał na wiadomości w starym stylu?
Odpowiedzi:
1 dla odpowiedzi № 1Jakiś czas temu otworzyłem podobny problem wKafka Jira i otrzymała dość jednoznaczną odpowiedź - najpierw uaktualnij brokerów, potem klientów, a nie odwrotnie. Zapewnia to pełną funkcjonalność niezbędną do obsłużenia twojego żądania i broker może z wdzięcznością sobie z tym poradzić.
Oto link do problemu, który otworzyłem, jeśli interesują Cię szczegóły - https://issues.apache.org/jira/browse/KAFKA-2496.