Re: Kafka_2.12-1.1.0 config

2018-09-21 Thread Subash Konar
e.kafka.clients.producer.internals.ErrorLoggingCallback) > > org.apache.kafka.common.errors.RecordTooLargeException: The message is > > 2170148 bytes when serialized which is larger than the maximum request > size > > you have configured with the max.request.size configuration. > > > > Thanks, > > Sarath Reddy. > > > > > > > -- Thanks and Regards, Subash Konar

Re: Does kafka support the delay queue

2018-09-19 Thread Subash Konar
r more details -- Thanks and Regards, Subash Konar On Thu, Sep 20, 2018 at 7:31 AM lx wrote: > Hi,kafka.apache.org > Does kafka support delay queues?how can kafka implement delay queues? > I hope my doubts can be answered.thanks > > > Sincerely > Lx -- Thanks and Regards, Subash Konar

Re: Kafka producer huge memory usage (leak?)

2018-09-18 Thread Subash Konar
-- * > >> > >> Both of these were holding about 352MB of space. 3 such instances, so > >> they were consuming about 1.2GB of memory. > >> > >> Now regarding usage of producers. Not a huge amount of logs are being > >> sent to Kafka cluster. It is about 200 msgs/sec. Only one producer > object > >> is being used throughout application. Async send function is used. > >> > >> What could be the cause of such huge memory usage? Is this some sort of > >> memory leak in this specific Kafka version? > >> > >> > -- Thanks and Regards, Subash Konar

Re: Kerberos ticket fails to renew

2018-09-10 Thread Subash Konar
iled [Caused by GSSException: No valid credentials > provided (Mechanism level: Failed to find any Kerberos tgt)]) occurred > when evaluating SASL token received from the Kafka Broker. > Kafka Client will go to AUTHENTICATION_FAILED state. > -- Thanks and Regards, Subash Konar

Re: information about kafka

2018-03-19 Thread Subash Konar
There are two systems as of now 1.Stream processing (continuous live data coming in) 2.Batch(Store and keep data as a batch and submit for processing) Sent from my Samsung 7 On 19 Mar 2018 11:42 p.m., "abdelhadi FEKHAR" wrote: Hi, in science for collecting data in real time, does it exist

Issue in kafka

2018-03-07 Thread Subash Konar
89. Below is my server.properties configuration listeners=PLAINTEXT:///:9092 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 Please help resolving the issue -- Thanks and Regards, Subash

Kafka Issue

2018-03-07 Thread Subash Konar
broker 89. Below is my server.properties configuration listeners=PLAINTEXT:///:9092 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 Please help resolving the issue -- Thanks and Regards, Subash