Updated Apache Kafka consumer/producer plugins (replacement for pull request #123)