Snowshoe logo
troubleshooting

What is causing the error in the RisingWave stream processor configuration?

I am trying to ingest data from Kafka, deduplicate it, and sink it back to Kafka using RisingWave. However, I am encountering an error related to the configuration parameters. Here is the configuration snippet: CREATE TABLE IF NOT EXISTS test_source ( id varchar, timestamp timestamp, field integer ) WITH ( connector='kafka', topic='test_risingwave_source', properties.bootstrap.server='localhost:9092', scan.startup.mode='earliest', scan.startup.timestamp_millis='140000000' ) ROW FORMAT JSON; CREATE SINK test_sink FROM test_source WITH ( connector='kafka', kafka.brokers='localhost:9092', kafka.topic='test_risingwave_sink', format='append_only', force_append_only='true' ); The error message is: ERROR: QueryError: internal error: Rpc error: gRPC error (Internal error): Executor error: Sink error: config error: missing field properties.bootstrap.server``. What could be the issue?

Ra

Ralph Matthias Debusmann

Asked on Mar 27, 2023

  • The error is caused by using outdated parameters in the RisingWave stream processor configuration.
  • The correct parameters to use are properties.bootstrap.server instead of kafka.brokers and topic instead of kafka.topic.
  • The documentation has been updated to reflect the correct parameters.
  • Make sure to replace kafka.brokers with properties.bootstrap.server and kafka.topic with topic in the configuration to resolve the error.
Mar 27, 2023Edited by