kafka-producer-api

0열

2답변

kafka customet partioner error

같은 프로젝트에서 두 클래스 모두 같은 프로젝트에 썼지 만 오류가 발생하는 이유는 확실하지 않습니다.이 프로그램에 대한 저를 도와주세요. 아래 프로그램은 카프카 프로듀서 프로그램입니다. 프로그램을 실행하면 SensorPartitioner 클래스가 없으므로 오류가 발생했습니다. 오류 : 아래 Exception in thread "main" org.apache

apache-kafka kafka-producer-api apache-kafka-connect 2017-03-05

---

1열

2답변

Hortonworks의 Apache kafka 오류

저는 kafka를 처음 사용하기 때문에 Hortonworks Sandbox에서 예제 프로그램을 시도하고 있습니다. 오류가 발생했습니다. 어떤 도움을 주시면 감사하겠습니다. from kafka import KafkaProducer from kafka.errors import KafkaError producer = KafkaProducer(bootstra

python apache-kafka kafka-producer-api 2017-03-11

---

2열

1답변

고객 및 사용자를위한 카프카 할당량

저는 카프카를 처음 접했고 카프카 할당량 시스템이 어떻게 작동하는지 알고 싶습니다. 지금까지 나는 다음과 같은 명령을 사용하여 새 클라이언트에 대한 할당량을 (생산 및 소비)를 설정 할 수 있었다 here 문서 다음 한 빈/kafka-configs.sh --zookeeper 10.11.10.2:2181 --alter --add-설정 'producer_byt

apache-kafka kafka-producer-api 2017-03-13

---

1열

1답변

KafkaTemplate 스레드가 안전합니까?

KafkaTemplate은 봄 부팅 스레드 안전합니다. 하나의 KafkaTemplate을 만들고이를 웹 서비스의 여러 요청에 대해 동일한 카프카 항목으로 보내는 데 사용할 수 있습니까?

spring-boot apache-kafka kafka-producer-api 2017-02-08

---

2열

1답변

Kafka Avro 시리얼 화기 : org.apache.avro.AvroRuntimeException : 열지 않음

특정 형식을 사용하여 Avro Serializer와 함께 Apache Kafka를 사용하고 있습니다. 내 자신의 사용자 지정 클래스를 만들고 카프카 메시지 값으로 사용하려고합니다. Exception in thread "main" org.apache.avro.AvroRuntimeException: not open at org.apache.avro.f

java scala apache-kafka avro kafka-producer-api 2017-02-10

---

0열

1답변

도커 컨테이너에 로컬 카프카를 연결하는 방법은 무엇입니까?

로컬 호스트에 kafka 서버가 있고이를 도커 컨테이너에 연결하고 싶습니다. 나는 고정 표시기 컨테이너에 현지 서비스를 연결하는 방법을 검색했고 나는이 발견 how-to-connect-to-local-mysql-server-through-docker 을하지만 그것은 작동하지 않았다. 제발 도와주세요, 고마워요 ~

docker apache-kafka kafka-producer-api 2017-02-14

---

0열

1답변

Kafka Python Client - 가능한 연결/시간 초과 오류를 처리하는 방법?

나는 Kafka 대기열에 연결하고 대기열에 메시지를 보내는 Python 응용 프로그램을 작성 중입니다. def send_msg(self, topic, msg): self.producer = KafkaProducer(bootstrap_servers=['XX.XXX.XX.XXX:XXXX']) future = self.producer.send(

python-3.x kafka-producer-api kafka-python 2017-02-21

---

0열

1답변

kafka 최대 처리량 (MB/초)

kafka의 최대 처리량 (MB/초)은 얼마입니까? 크기가 각각 2MB 인 메시지를 보내고 초당 약 30 개의 레코드 (즉, 60MB/초)의 처리량을 얻으려고합니다. 이론적 인 최대 처리량에 도달했는지 확인하고 싶습니다.

apache-kafka kafka-producer-api 2017-02-21

---

1열

1답변

여러 소비자가 동일한 카프카 메시지를 읽는 방법

나는 Kakfa Spring 통합에있어 매우 새로운 기술입니다. 나는 Kafka 메시지 전송과 One Listener를 구현했으며 나에게 잘 작동했다. 하지만 Listener와 동일한 메시지를 두 곳에서 보내고 싶습니다. 아무도 나를 도울 수 있습니까? 아래는 제 코드입니다. spring.kafka.bootstrap-servers=localhost:9092

apache-kafka kafka-consumer-api kafka-producer-api spring-kafka 2017-03-02

---

0열

1답변

Kafka의 파티션 수를 늘릴 때 메시지가 RoundRobin 순서로 배포되지 않음

안녕하세요 저는 kafka 버전 0.10.2와 사육사 버전 3.4.9를 사용하고 있습니다. 두 개의 파티션과 두 개의 소비자가 실행되는 주제가 있습니다. 그래서 처리 속도가 빨라짐에 따라 파티션 수를 10 개로 늘려 소비자 수를 늘릴 수 있도록 결정했습니다. 그래서이 명령을 실행 ./kafka-topics.sh --zookeeper 로컬 호스트 : --pa

apache-kafka kafka-consumer-api kafka-producer-api 2017-03-04

---