kafka-streaming-click-analysis
kafka-streaming-click-analysis copied to clipboard
IBM
Use Kafka and Apache Spark streaming to perform click stream analytics
When running the val query = messages.writeStream .outputMode("complete") .option("truncate", "false") .format("console") .start() command, I get the following error: ERROR MicroBatchExecution: Query [id = 4d06c381-ed3c-4cc2-b3c3-225ab1b16c18, runId = 9b7f6d9b-a47f-4eda-b6bc-d284e30202ba] terminated with error...
I tried executing the project locally using Spark Shell but facing issues with data displays in the terminal. In the default startingOffset setting which is 'latest', the output is a...
https://www.ibm.com/cloud/message-hub https://cloud.ibm.com/catalog/services/event-streams Beyond just a simple branding swap, this change may affect the code in this repo (variable names, etc).
