Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

howto set several kafka properties #3

Open
eskuai opened this issue Aug 3, 2016 · 0 comments
Open

howto set several kafka properties #3

eskuai opened this issue Aug 3, 2016 · 0 comments

Comments

@eskuai
Copy link

eskuai commented Aug 3, 2016

how to set a new value for another properties like acks , client.d ?

-- listing properties --
metadata.fetch.timeout.ms=2500
message.send.max.retries=0
compression.code=snappy
producer.type=async
client.id=bfc20b63-d287-4998-bf6e-db86a28be051
linger.ms=10
metadata.broker.list=
batch.size=100
acks=1
INFO pool-1-thread-1 - Verifying properties
WARN pool-1-thread-1 - Property metadata.fetch.timeout.ms is not valid
WARN pool-1-thread-1 - Property message.send.max.retries is not valid
WARN pool-1-thread-1 - Property compression.code is not valid
WARN pool-1-thread-1 - Property producer.type is not valid
WARN pool-1-thread-1 - Property client.id is not valid
WARN pool-1-thread-1 - Property linger.ms is not valid
INFO pool-1-thread-1 - Property metadata.broker.list is overridden to
WARN pool-1-thread-1 - Property batch.size is not valid
WARN pool-1-thread-1 - Property acks is not valid

public class ProducerConfig
implements AsyncProducerConfig, SyncProducerConfigShared
{
private final VerifiableProperties props;
private final String brokerList;
private final String partitionerClass;
private final String producerType;
private final CompressionCodec compressionCodec;
private final Seq compressedTopics;
private final int messageSendMaxRetries;
private final int retryBackoffMs;
private final int topicMetadataRefreshIntervalMs;
private final int sendBufferBytes;
private final String clientId;
private final short requestRequiredAcks;
private final int requestTimeoutMs;
private final int queueBufferingMaxMs;
private final int queueBufferingMaxMessages;
private final int queueEnqueueTimeoutMs;
private final int batchNumMessages;
private final String serializerClass;
private final String keySerializerClass;

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant