kafka-producer-api

0열

1답변

나는 카프카의 새로운 트랜잭션 생산을 테스트하기 위해이 간단한 프로그램을 작성 중단에도 불구하고 기록을 보여줍니다 --- ~ » kafka-console-consumer --bootstrap-server localhost:9092 \ --topic topic \ --from-beginning \ --consumer-prope

0열

1답변

필수 인수가 없습니다. "[authorizer-properties]"apache kafka 간단한 제작자 API 오류

kafka 제작자 코드를 일식에 쓰는 동안 아래에 오류 설명이 표시됩니다. 여기 간단한 제작자 코드를 작성하고 kafka 콘솔에 메시지를 표시하고 싶습니다. 소비자 내가 사육사와 카프카 서버를 시작하고 주제를 완벽하게 만들었습니다. import java.util.Properties; import kafka.javaapi.producer.Producer;

1열

2답변

리더가 없습니다. Console의 카프카 (ssl + acl 구성이있는 프로듀서)

kska 0.11.0.1을 ssl + acls과 함께 사용하려고합니다. 내 구성은 다음과 같습니다. 다음으로 제조자가 subject=/C=in/ST=maha/L=mum/O=atos/OU=atos/CN=kafka issuer=/C=in/ST=maha/L=mum/O=atos/OU=atos/CN=kafka/[email protected] CN 상 : se

0열

1답변

카프카의 레코드 대 요청 및 배치의 개념

나는 프로듀서 API의 매개 변수를 읽는 동안 이러한 용어가 같은 의미로 사용되는 것을 보았습니다. 그렇다면 이러한 용어는 동일한 것을 의미합니까, 아니면 개념적으로 다른 점이 있습니까?

0열

1답변

서블릿을 사용하여 KafkaProducer를 연결하십시오.

서블릿을 사용하여 KafkaProducer를 연결하고 Eclipse에서 프로젝트를 설정하려고합니다. 난 KafkaProducer 실행할 때하지만 예외가 : org.apache.catalina.core.StandardWrapperValve 심한 호출 : 경로 컨텍스트 에 서블릿 [simple_kafka.SimpleProducer]의 의 Servlet.serv

0열

1답변

kafka-console-producer 파일 읽기 실패

kafka 11을 사용 중이고 파일에서 주제에 쓰려고합니다. 나는 kafka-console-producer --broker-list my-bootstrap-url:9092 --topic my.test.messages < my_file.txt 아래의 명령을 사용하고 그리고 내가 콘솔에 메시지를 작성하는 경우가 잘 작동하는 것 같다하지만 파일이 실패에서 쓰

-1열

2답변

Kafka를 사용하여 파일을 전송하는 방법

내 프로세스는 많은 시간 동안 파일을 생성합니다. 로컬 디렉토리에서 HDFS의 일부 위치로 파일을 전송하고 싶습니다. NiFi를 사용하는 대신 Java에서 해당 흐름을 개발할 수 있습니까? . 그렇다면 Java에서 참조 코드를 제공하여 안내하십시오. 제발 도와주세요!

1열

1답변

는 카프카 주제

나는 카프카에 새로 온 사람과 프로토 타입에 작업하는 카프카에 독점 스트리밍 서비스를 연결하는 데에 보낸 마지막 메시지 얻기. 나는 우리의 사내 스트림 소비자가 연결할 때받은 마지막 메시지의 ID로 로그온 할 필요가 같은 주제에 보낸 마지막 메시지의 키를 얻기 위해 찾고 있어요. 는이 작업을 수행 할 KafkaProducer 또는 KafkaConsumer을

0열

2답변

카프카 제작자가 카프카 서버가 다운되었을 때 무기한으로 블록을 보냅니다.

카프카 0.11.0.0을 사용하고 있습니다. 카프카 (Kafka) 주제에 게시하는 테스트 프로그램이 있습니다. 사육사와 Kafka 서버가 다운 된 경우 (내 개발 환경에서는 정상이며 필요에 따라 가져온다) KafkaProducer <> .send() 호출이 무한정 정지됩니다. send() return을 사용하여 오류를 나타내는 것이 바람직합니다. 또는 서버

0열

1답변

봄 카프카 (생산자로 TCP 포트 사용)

나는 카프카와 스트리밍을 처음 접하기 때문에 나와 맺어진다. 나는 사육사와 카프카를 성공적으로 설치하여 시작했다. 간단한 주제를 작성하고 해당 주제로 보내지는 내용을 콘솔에서 듣고 표시하는 콘솔 소비자를 시작합니다. 프로듀서는 현재 엔드 포인트 호출의 결과로 정보를 보냅니다. 나는 NMEA 형식의 데이터를 TCP 포트로 보낼 장치가 있습니다. 카파 프로듀서