[jira] [Created] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

Thomas Dickinson created KAFKA-7958: --- Summary: Transactions are broken with kubernetes hosted brokers Key: KAFKA-7958 URL: https://issues.apache.org/jira/browse/KAFKA-7958 Project: Kafka

Re: how to decode record correctly

done! just because of the bytebuffer usage. 徐建海 于2019年2月19日周二 下午7:57写道： > public class DefaultRecord implements Record { > > // excluding key, value and headers: 5 bytes length + 10 bytes timestamp > + 5 bytes offset + 1 byte attributes > public static final int MAX_RECORD_OVERHEAD =

Build failed in Jenkins: kafka-trunk-jdk8 #3398

See Changes: [jason] KAFKA-7909; Ensure timely rebalance completion after pending members -- [...truncated 2.31 MB...]

Jenkins build is back to normal : kafka-2.2-jdk8 #23

See

Re: [ANNOUNCE] Apache Kafka 2.1.1

Yay! Thanks for running the release Colin, and to everyone who reported and fixed bugs :) On Tue, Feb 19, 2019, 3:37 PM Colin McCabe wrote: > The Apache Kafka community is pleased to announce the release for Apache > Kafka 2.1.1. > > This is a bugfix release for Kafka 2.1.0. All of the

[jira] [Created] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest #testMetricsReporterUpdate

Matthias J. Sax created KAFKA-7957: -- Summary: Flaky Test DynamicBrokerReconfigurationTest #testMetricsReporterUpdate Key: KAFKA-7957 URL: https://issues.apache.org/jira/browse/KAFKA-7957 Project:

[ANNOUNCE] Apache Kafka 2.1.1

The Apache Kafka community is pleased to announce the release for Apache Kafka 2.1.1. This is a bugfix release for Kafka 2.1.0. All of the changes in this release can be found in the release notes: https://www.apache.org/dist/kafka/2.1.1/RELEASE_NOTES.html You can download the source and

Re: [DISCUSSION] KIP-422: Add support for user/client configuration in the Kafka Admin Client

Hello Jun, Viktor, Snoke and Stan, Thanks for taking time to look at this KIP-422! For some reason, this email was put in my spam folder. Sorry about that. Jun is right, the main motivation for this KIP-422 is to allow users to config user/clientId quota through AdminClient. In addition, this

[jira] [Created] (KAFKA-7956) Avoid blocking in ShutdownableThread.awaitShutdown if the thread has not been started

Gardner Vickers created KAFKA-7956: -- Summary: Avoid blocking in ShutdownableThread.awaitShutdown if the thread has not been started Key: KAFKA-7956 URL: https://issues.apache.org/jira/browse/KAFKA-7956

[jira] [Created] (KAFKA-7955) Provide a BOM for EmbeddedConnectCluster and EmbeddedCluster

Jeremy Custenborder created KAFKA-7955: -- Summary: Provide a BOM for EmbeddedConnectCluster and EmbeddedCluster Key: KAFKA-7955 URL: https://issues.apache.org/jira/browse/KAFKA-7955 Project:

[jira] [Created] (KAFKA-7954) When broker IP addresses change client never resolves new addresses to fetch metadata

Robert Pofuk created KAFKA-7954: --- Summary: When broker IP addresses change client never resolves new addresses to fetch metadata Key: KAFKA-7954 URL: https://issues.apache.org/jira/browse/KAFKA-7954

[jira] [Created] (KAFKA-7953) Kafka Producer buffer-full policy should be configurable

Justin Borromeo created KAFKA-7953: -- Summary: Kafka Producer buffer-full policy should be configurable Key: KAFKA-7953 URL: https://issues.apache.org/jira/browse/KAFKA-7953 Project: Kafka

[jira] [Created] (KAFKA-7952) Consider to switch to in-memory stores in test whenever possible

Matthias J. Sax created KAFKA-7952: -- Summary: Consider to switch to in-memory stores in test whenever possible Key: KAFKA-7952 URL: https://issues.apache.org/jira/browse/KAFKA-7952 Project: Kafka

[jira] [Reopened] (KAFKA-7540) Transient failure: kafka.api.ConsumerBounceTest.testClose

[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7540: > Transient failure: kafka.api.ConsumerBounceTest.testClose >

Re: [VOTE] KIP-412: Extend Admin API to support dynamic application log levels

Thanks for the KIP. +1 (non-binding) On 18/02/2019, 12:48, "Stanislav Kozlovski" wrote: Hey everybody, I'm starting a VOTE thread for KIP-412. This feature should significantly improve the flexibility and ease in debugging Kafka in run time KIP-412 -

[jira] [Created] (KAFKA-7951) Log Cleaner thread stop with "Varint is too long" error

Ninth Nails created KAFKA-7951: -- Summary: Log Cleaner thread stop with "Varint is too long" error Key: KAFKA-7951 URL: https://issues.apache.org/jira/browse/KAFKA-7951 Project: Kafka Issue

[jira] [Created] (KAFKA-7950) Kafka tools GetOffsetShell -time description

Kartik created KAFKA-7950: - Summary: Kafka tools GetOffsetShell -time description Key: KAFKA-7950 URL: https://issues.apache.org/jira/browse/KAFKA-7950 Project: Kafka Issue Type: Improvement

Re: [VOTE] KIP-412: Extend Admin API to support dynamic application log levels

+1 (non-binding.) 2 bindings (Rajini, Gwen) and 3 non-bindings (Mickael, Jonathan, Dongjin) until now. Thanks, Dongjin On Tue, Feb 19, 2019 at 10:22 PM Skrzypek, Jonathan < jonathan.skrzy...@gs.com> wrote: > +1 (non-binding) > > Jonathan Skrzypek > > > -Original Message- > From: Gwen

RE: [VOTE] KIP-412: Extend Admin API to support dynamic application log levels

+1 (non-binding) Jonathan Skrzypek -Original Message- From: Gwen Shapira Sent: 19 February 2019 04:57 To: dev Subject: Re: [VOTE] KIP-412: Extend Admin API to support dynamic application log levels +1 On Mon, Feb 18, 2019, 3:48 AM Stanislav Kozlovski wrote: > Hey everybody, I'm

Re: how to decode record correctly

As I found, the private final ByteBuffer value; is not what I passed in key/value pair in client, How can I get the the origin Key/Value in kafka server? 徐建海 于2019年2月19日周二 下午6:51写道： > Hello: > I try to add some feature to Kafka, but I encounter a problem: I need > to get the key and value

Re: how to decode record correctly

public class DefaultRecord implements Record { // excluding key, value and headers: 5 bytes length + 10 bytes timestamp + 5 bytes offset + 1 byte attributes public static final int MAX_RECORD_OVERHEAD = 21; private static final int NULL_VARINT_SIZE_BYTES = ByteUtils.sizeOfVarint(-1);

how to decode record correctly

Hello: I try to add some feature to Kafka, but I encounter a problem: I need to get the key and value from DefaultRecord, how can I do that?

[jira] [Resolved] (KAFKA-7949) Backport knox trusted proxy support for ambari for 2.6

[ https://issues.apache.org/jira/browse/KAFKA-7949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Magyar resolved KAFKA-7949. -- Resolution: Invalid wrong subproject > Backport knox trusted proxy support for ambari for 2.6

[jira] [Created] (KAFKA-7949) Backport knox trusted proxy support for ambari for 2.6

Attila Magyar created KAFKA-7949: Summary: Backport knox trusted proxy support for ambari for 2.6 Key: KAFKA-7949 URL: https://issues.apache.org/jira/browse/KAFKA-7949 Project: Kafka Issue