[...] try (KafkaProducerString, producer = new KafkaProducer(props)) { for (long i =**0; i <**10; i++) { final String orderId = "id" + Long.toString(i); final Payment payment = new Payment(orderId,**1000.00d); final ProducerRecord record = new ProducerRecord("transactions", payment.getId().toString(), payment); producer.send(record); } } catch (final InterruptedException e) { e.printStackTrace(); } [...]