Kafka source - how to set partition key?

One thing that went wrong for me is I was projecting only some fields, but I set my partition key to a field that was not in my projected fields.

You might want to look at the server error logs: I have found them more useful than the HTTP responses.

You can change the log level by doing an http post to /admin/loggers/[logName] with the level you want.