Update kafka.go