Мой код реализован для записи данных Avro через сервер Schema_Registry в брокер Kafka. Локальный тест хорош (I setup a local Broker and Schema_Registry server). но когда я изменил свой файл конфигурации и использовал удаленный сервер kafka и schema_registry, запись не удалась из-за TimeoutException. (but when I logged in the remote server and used Avro producer/consumer command line, it works good too. )
Нужно ли менять конфигурацию на стороне Schema_Registry или на стороне моего клиента?
Файл свойств моего сервера schema_registry выглядит следующим образом:
listeners=http://0.0.0.0:8081
kafkastore.connection.url=localhost:2181
kafkastore.topic=_schemas
debug=fals
Мой код производителя следующий:
props.put("bootstrap.servers", "10.5.149.21:9092");//this is a remote ip
props.put("schema.registry.url","http://10.5.149.21:8081");