-
Notifications
You must be signed in to change notification settings - Fork 3.5k
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
Added suppport for Kafka partitioner and explicit setting of partition on record #3462
Conversation
run integration tests |
retest this please |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Couple of minor things.
site2/docs/adaptors-kafka.md
Outdated
@@ -129,7 +129,7 @@ Properties: | |||
| Config property | Supported | Notes | | |||
|:----------------------------------------|:----------|:------------------------------------------------------------------------------| | |||
| `acks` | Ignored | Durability and quorum writes are configured at the namespace level | | |||
| `auto.offset.reset` | Yes | Will have a default value of 'latest' if user does not give specific setting. | | |||
| `auto.offset.reset` | Yes | Will have a default value of `latest` if user does not give specific setting. | |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Added superfluous whitespace.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I just fixed the ..
and aligned the columns in the source md text structure.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
...pulsar-client-kafka/src/main/java/org/apache/kafka/clients/producer/PulsarKafkaProducer.java
Outdated
Show resolved
Hide resolved
...client-test/src/test/java/org/apache/pulsar/tests/integration/compat/kafka/KafkaApiTest.java
Outdated
Show resolved
Hide resolved
@ivankelly PTAL again |
@@ -18,6 +18,7 @@ | |||
*/ | |||
package org.apache.kafka.clients.producer; | |||
|
|||
import java.nio.charset.Charset; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
import static java.nio.charset.StandardCharsets.UTF_8;
site2/docs/adaptors-kafka.md
Outdated
@@ -129,7 +129,7 @@ Properties: | |||
| Config property | Supported | Notes | | |||
|:----------------------------------------|:----------|:------------------------------------------------------------------------------| | |||
| `acks` | Ignored | Durability and quorum writes are configured at the namespace level | | |||
| `auto.offset.reset` | Yes | Will have a default value of 'latest' if user does not give specific setting. | | |||
| `auto.offset.reset` | Yes | Will have a default value of `latest` if user does not give specific setting. | |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
retest this please |
run cpp tests |
run integration tests |
Motivation
partitioner.class
with a custom partitioner