Questions about kafka-producer-api
Read more about kafka-producer-api
python (65.1k questions)
javascript (44.2k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (12.9k questions)
Why do I get Intermittent "NoBrokersAvailable" errors, with python application (kafka-python Producer)?
I’m trying to make a connection to Kafka on AWS. Communication is done over TLS.<br>
Kafka-python==2.0.2 is used, and the KafkaProducer configuration is as follows:
From Kafka import KafkaProduc...
bowoojang
Votes: 0
Answers: 2
Send my metrics data to Kafka via Opentelemetry
use serde::{Deserialize, Serialize};
use std::time::Duration;
use kafka::producer::{Producer, Record, RequiredAcks};
use opentelemetry::{global, KeyValue};
#[tokio::main]
async fn main() {
let mu...
Keval Bhogayata
Votes: 0
Answers: 1
Send Json to kafka Topic
I'm trying to send Json data into kafka topics:
I have this Scala code:
def sendMessage(sender_id: String, receiver_id: String, content: String) = {
val newMessage = new Producer(brokers = KAFKA...
Iheb Mar
Votes: 0
Answers: 1
Kafka producer: NoBrokersAvailable in docker
I'm starting with kafka and my project consists in get data and put it into a kafka topic.
I was trying to do it without docker, executing the data-generator in an python environment and it works perf...
Ruben Oubiña Mosteiro
Votes: 0
Answers: 0